Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ vpath %.proto $(PROTOS_PATH)
all: system-check libdapr.so

libdapr.so : ./src/dapr/proto/common/v1/common.pb.o ./src/dapr/proto/runtime/v1/dapr.pb.o ./src/dapr/proto/runtime/v1/dapr.grpc.pb.o ./src/dapr/proto/runtime/v1/appcallback.pb.o ./src/dapr/proto/runtime/v1/appcallback.grpc.pb.o
-mkdir ./out
-mkdir -p ./out
$(CXX) -shared -Wl,-soname,libdapr.so.0 -o ./out/libdapr.0.2.0.so ./src/dapr/proto/runtime/v1/*.o ./src/dapr/proto/common/v1/*.o

%.o : %.cc
Expand Down
12 changes: 12 additions & 0 deletions dapr/proto/runtime/v1/appcallback.proto
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,18 @@ message TopicEventRequest {

// TopicEventResponse is response from app on published message
message TopicEventResponse {
// TopicEventResponseStatus allows apps to have finer control over handling of the message.
enum TopicEventResponseStatus {
// SUCCESS is the default behavior: message is acknowledged and not retried or logged.
SUCCESS = 0;
// RETRY status signals Dapr to retry the message as part of an expected scenario (no warning is logged).
RETRY = 1;
// DROP status signals Dapr to drop the message as part of an unexpected scenario (warning is logged).
DROP = 2;
}

// The list of output bindings.
TopicEventResponseStatus status = 1;
}

// BindingEventRequest represents input bindings event.
Expand Down
12 changes: 12 additions & 0 deletions dapr/proto/runtime/v1/dapr.proto
Original file line number Diff line number Diff line change
Expand Up @@ -64,6 +64,9 @@ message GetStateRequest {

// The read consistency of the state store.
common.v1.StateOptions.StateConsistency consistency = 3;

// The metadata which will be sent to state store components.
map<string,string> metadata = 4;
}

// GetBulkStateRequest is the message to get a list of key-value states from specific state store.
Expand All @@ -76,6 +79,9 @@ message GetBulkStateRequest {

// The number of parallel operations executed on the state store for a get operation.
int32 parallelism = 3;

// The metadata which will be sent to state store components.
map<string,string> metadata = 4;
}

// GetBulkStateResponse is the response conveying the list of state values.
Expand All @@ -96,6 +102,9 @@ message BulkStateItem {
// The entity tag which represents the specific version of data.
// ETag format is defined by the corresponding data store.
string etag = 3;

// The error that was returned from the state store in case of a failed get operation.
string error = 4;
}

// GetStateResponse is the response conveying the state value and etag.
Expand Down Expand Up @@ -123,6 +132,9 @@ message DeleteStateRequest {
// State operation options which includes concurrency/
// consistency/retry_policy.
common.v1.StateOptions options = 4;

// The metadata which will be sent to state store components.
map<string,string> metadata = 5;
}

// SaveStateRequest is the message to save multiple states into state store.
Expand Down
178 changes: 126 additions & 52 deletions src/dapr/proto/runtime/v1/appcallback.pb.cc

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading