diff --git a/dapr/proto/common/v1/common.pb.go b/dapr/proto/common/v1/common.pb.go new file mode 100644 index 00000000..02ebe788 --- /dev/null +++ b/dapr/proto/common/v1/common.pb.go @@ -0,0 +1,335 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: dapr/proto/common/v1/common.proto + +package v1 + +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + any "github.com/golang/protobuf/ptypes/any" + math "math" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +// Type of HTTP 1.1 Methods +// RFC 7231: https://tools.ietf.org/html/rfc7231#page-24 +type HTTPExtension_Verb int32 + +const ( + HTTPExtension_NONE HTTPExtension_Verb = 0 + HTTPExtension_GET HTTPExtension_Verb = 1 + HTTPExtension_HEAD HTTPExtension_Verb = 2 + HTTPExtension_POST HTTPExtension_Verb = 3 + HTTPExtension_PUT HTTPExtension_Verb = 4 + HTTPExtension_DELETE HTTPExtension_Verb = 5 + HTTPExtension_CONNECT HTTPExtension_Verb = 6 + HTTPExtension_OPTIONS HTTPExtension_Verb = 7 + HTTPExtension_TRACE HTTPExtension_Verb = 8 +) + +var HTTPExtension_Verb_name = map[int32]string{ + 0: "NONE", + 1: "GET", + 2: "HEAD", + 3: "POST", + 4: "PUT", + 5: "DELETE", + 6: "CONNECT", + 7: "OPTIONS", + 8: "TRACE", +} + +var HTTPExtension_Verb_value = map[string]int32{ + "NONE": 0, + "GET": 1, + "HEAD": 2, + "POST": 3, + "PUT": 4, + "DELETE": 5, + "CONNECT": 6, + "OPTIONS": 7, + "TRACE": 8, +} + +func (x HTTPExtension_Verb) String() string { + return proto.EnumName(HTTPExtension_Verb_name, int32(x)) +} + +func (HTTPExtension_Verb) EnumDescriptor() ([]byte, []int) { + return fileDescriptor_0c448f683ad359d5, []int{0, 0} +} + +// HTTPExtension includes HTTP verb and querystring +// when Dapr runtime delivers HTTP content. +// +// For example, when callers calls http invoke api +// POST http://localhost:3500/v1.0/invoke//method/?query1=value1&query2=value2 +// +// Dapr runtime will parse POST as a verb and extract querystring to quersytring map. +type HTTPExtension struct { + // verb is HTTP verb. + // + // This is required. + Verb HTTPExtension_Verb `protobuf:"varint,1,opt,name=verb,proto3,enum=dapr.proto.common.v1.HTTPExtension_Verb" json:"verb,omitempty"` + // querystring includes HTTP querystring. + Querystring map[string]string `protobuf:"bytes,2,rep,name=querystring,proto3" json:"querystring,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *HTTPExtension) Reset() { *m = HTTPExtension{} } +func (m *HTTPExtension) String() string { return proto.CompactTextString(m) } +func (*HTTPExtension) ProtoMessage() {} +func (*HTTPExtension) Descriptor() ([]byte, []int) { + return fileDescriptor_0c448f683ad359d5, []int{0} +} + +func (m *HTTPExtension) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_HTTPExtension.Unmarshal(m, b) +} +func (m *HTTPExtension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_HTTPExtension.Marshal(b, m, deterministic) +} +func (m *HTTPExtension) XXX_Merge(src proto.Message) { + xxx_messageInfo_HTTPExtension.Merge(m, src) +} +func (m *HTTPExtension) XXX_Size() int { + return xxx_messageInfo_HTTPExtension.Size(m) +} +func (m *HTTPExtension) XXX_DiscardUnknown() { + xxx_messageInfo_HTTPExtension.DiscardUnknown(m) +} + +var xxx_messageInfo_HTTPExtension proto.InternalMessageInfo + +func (m *HTTPExtension) GetVerb() HTTPExtension_Verb { + if m != nil { + return m.Verb + } + return HTTPExtension_NONE +} + +func (m *HTTPExtension) GetQuerystring() map[string]string { + if m != nil { + return m.Querystring + } + return nil +} + +// DataWithContentType represents bytearray body and its content type +type DataWithContentType struct { + // content_type is the type of data content. + // + // This field is required. + ContentType string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` + // body conveys the content body. + // + // This field is required. + Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *DataWithContentType) Reset() { *m = DataWithContentType{} } +func (m *DataWithContentType) String() string { return proto.CompactTextString(m) } +func (*DataWithContentType) ProtoMessage() {} +func (*DataWithContentType) Descriptor() ([]byte, []int) { + return fileDescriptor_0c448f683ad359d5, []int{1} +} + +func (m *DataWithContentType) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_DataWithContentType.Unmarshal(m, b) +} +func (m *DataWithContentType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_DataWithContentType.Marshal(b, m, deterministic) +} +func (m *DataWithContentType) XXX_Merge(src proto.Message) { + xxx_messageInfo_DataWithContentType.Merge(m, src) +} +func (m *DataWithContentType) XXX_Size() int { + return xxx_messageInfo_DataWithContentType.Size(m) +} +func (m *DataWithContentType) XXX_DiscardUnknown() { + xxx_messageInfo_DataWithContentType.DiscardUnknown(m) +} + +var xxx_messageInfo_DataWithContentType proto.InternalMessageInfo + +func (m *DataWithContentType) GetContentType() string { + if m != nil { + return m.ContentType + } + return "" +} + +func (m *DataWithContentType) GetBody() []byte { + if m != nil { + return m.Body + } + return nil +} + +type InvokeRequest struct { + // method is a method name which will be invoked by caller. + // + // This field is required. + Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` + // data conveys the content body which caller sent. + // + // This field is required. + Data *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` + // http_extension includes http specific fields if request conveys + // http-compatible request. + // + // This field is optional. + HttpExtension *HTTPExtension `protobuf:"bytes,3,opt,name=http_extension,json=httpExtension,proto3" json:"http_extension,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *InvokeRequest) Reset() { *m = InvokeRequest{} } +func (m *InvokeRequest) String() string { return proto.CompactTextString(m) } +func (*InvokeRequest) ProtoMessage() {} +func (*InvokeRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_0c448f683ad359d5, []int{2} +} + +func (m *InvokeRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_InvokeRequest.Unmarshal(m, b) +} +func (m *InvokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_InvokeRequest.Marshal(b, m, deterministic) +} +func (m *InvokeRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_InvokeRequest.Merge(m, src) +} +func (m *InvokeRequest) XXX_Size() int { + return xxx_messageInfo_InvokeRequest.Size(m) +} +func (m *InvokeRequest) XXX_DiscardUnknown() { + xxx_messageInfo_InvokeRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_InvokeRequest proto.InternalMessageInfo + +func (m *InvokeRequest) GetMethod() string { + if m != nil { + return m.Method + } + return "" +} + +func (m *InvokeRequest) GetData() *any.Any { + if m != nil { + return m.Data + } + return nil +} + +func (m *InvokeRequest) GetHttpExtension() *HTTPExtension { + if m != nil { + return m.HttpExtension + } + return nil +} + +type InvokeResponse struct { + // data conveys the content body of InvokeService response. + // + // This field is required. + Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *InvokeResponse) Reset() { *m = InvokeResponse{} } +func (m *InvokeResponse) String() string { return proto.CompactTextString(m) } +func (*InvokeResponse) ProtoMessage() {} +func (*InvokeResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_0c448f683ad359d5, []int{3} +} + +func (m *InvokeResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_InvokeResponse.Unmarshal(m, b) +} +func (m *InvokeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_InvokeResponse.Marshal(b, m, deterministic) +} +func (m *InvokeResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_InvokeResponse.Merge(m, src) +} +func (m *InvokeResponse) XXX_Size() int { + return xxx_messageInfo_InvokeResponse.Size(m) +} +func (m *InvokeResponse) XXX_DiscardUnknown() { + xxx_messageInfo_InvokeResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_InvokeResponse proto.InternalMessageInfo + +func (m *InvokeResponse) GetData() *any.Any { + if m != nil { + return m.Data + } + return nil +} + +func init() { + proto.RegisterEnum("dapr.proto.common.v1.HTTPExtension_Verb", HTTPExtension_Verb_name, HTTPExtension_Verb_value) + proto.RegisterType((*HTTPExtension)(nil), "dapr.proto.common.v1.HTTPExtension") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.common.v1.HTTPExtension.QuerystringEntry") + proto.RegisterType((*DataWithContentType)(nil), "dapr.proto.common.v1.DataWithContentType") + proto.RegisterType((*InvokeRequest)(nil), "dapr.proto.common.v1.InvokeRequest") + proto.RegisterType((*InvokeResponse)(nil), "dapr.proto.common.v1.InvokeResponse") +} + +func init() { proto.RegisterFile("dapr/proto/common/v1/common.proto", fileDescriptor_0c448f683ad359d5) } + +var fileDescriptor_0c448f683ad359d5 = []byte{ + // 493 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x52, 0xd1, 0x6e, 0xd3, 0x30, + 0x14, 0x25, 0x69, 0xda, 0x6e, 0xb7, 0x6b, 0x65, 0x99, 0x0a, 0x95, 0xf1, 0xb2, 0x95, 0x97, 0x4a, + 0x08, 0x47, 0x2d, 0x3c, 0xa0, 0x09, 0x21, 0x75, 0xad, 0xb5, 0x0d, 0x4d, 0x6d, 0xc9, 0xcc, 0x90, + 0x78, 0x99, 0x92, 0xd6, 0xa4, 0x51, 0x5b, 0x3b, 0x4b, 0x9c, 0x88, 0x7c, 0x0c, 0x3f, 0xc0, 0xc7, + 0xf0, 0x4d, 0xc8, 0x4e, 0x3b, 0x06, 0x9a, 0xc4, 0xde, 0xce, 0xb9, 0x3e, 0xe7, 0xe4, 0x28, 0xf7, + 0xc2, 0xf1, 0xc2, 0x8f, 0x13, 0x37, 0x4e, 0xa4, 0x92, 0xee, 0x5c, 0x6e, 0x36, 0x52, 0xb8, 0x79, + 0x7f, 0x8b, 0x88, 0x19, 0xe3, 0xb6, 0x96, 0x94, 0x98, 0x6c, 0x1f, 0xf2, 0xfe, 0xe1, 0xf3, 0x50, + 0xca, 0x70, 0xcd, 0x4b, 0x6b, 0x90, 0x7d, 0x73, 0x7d, 0x51, 0x94, 0xa2, 0xee, 0x2f, 0x1b, 0x9a, + 0xe7, 0x8c, 0xcd, 0xe8, 0x77, 0xc5, 0x45, 0x1a, 0x49, 0x81, 0xdf, 0x83, 0x93, 0xf3, 0x24, 0xe8, + 0x58, 0x47, 0x56, 0xaf, 0x35, 0xe8, 0x91, 0x87, 0x12, 0xc9, 0x5f, 0x16, 0x72, 0xcd, 0x93, 0xc0, + 0x33, 0x2e, 0x7c, 0x0d, 0x8d, 0xdb, 0x8c, 0x27, 0x45, 0xaa, 0x92, 0x48, 0x84, 0x1d, 0xfb, 0xa8, + 0xd2, 0x6b, 0x0c, 0xde, 0x3e, 0x26, 0xe4, 0xd3, 0x1f, 0x1b, 0x15, 0x2a, 0x29, 0xbc, 0xfb, 0x41, + 0x87, 0x1f, 0x00, 0xfd, 0x2b, 0xc0, 0x08, 0x2a, 0x2b, 0x5e, 0x98, 0xa2, 0xfb, 0x9e, 0x86, 0xb8, + 0x0d, 0xd5, 0xdc, 0x5f, 0x67, 0xbc, 0x63, 0x9b, 0x59, 0x49, 0x4e, 0xec, 0x77, 0x56, 0x37, 0x04, + 0x47, 0xb7, 0xc4, 0x7b, 0xe0, 0x4c, 0xa6, 0x13, 0x8a, 0x9e, 0xe0, 0x3a, 0x54, 0xce, 0x28, 0x43, + 0x96, 0x1e, 0x9d, 0xd3, 0xe1, 0x18, 0xd9, 0x1a, 0xcd, 0xa6, 0x57, 0x0c, 0x55, 0xf4, 0xe3, 0xec, + 0x33, 0x43, 0x0e, 0x06, 0xa8, 0x8d, 0xe9, 0x25, 0x65, 0x14, 0x55, 0x71, 0x03, 0xea, 0xa3, 0xe9, + 0x64, 0x42, 0x47, 0x0c, 0xd5, 0x34, 0x99, 0xce, 0xd8, 0xc5, 0x74, 0x72, 0x85, 0xea, 0x78, 0x1f, + 0xaa, 0xcc, 0x1b, 0x8e, 0x28, 0xda, 0xeb, 0x5e, 0xc2, 0xd3, 0xb1, 0xaf, 0xfc, 0x2f, 0x91, 0x5a, + 0x8e, 0xa4, 0x50, 0x5c, 0x28, 0x56, 0xc4, 0x1c, 0x1f, 0xc3, 0xc1, 0xbc, 0xa4, 0x37, 0xaa, 0x88, + 0xf9, 0xb6, 0x74, 0x63, 0x7e, 0x4f, 0x82, 0xc1, 0x09, 0xe4, 0xa2, 0x30, 0xdd, 0x0f, 0x3c, 0x83, + 0xbb, 0x3f, 0x2c, 0x68, 0x5e, 0x88, 0x5c, 0xae, 0xb8, 0xc7, 0x6f, 0x33, 0x9e, 0x2a, 0xfc, 0x0c, + 0x6a, 0x1b, 0xae, 0x96, 0x72, 0xb1, 0x8d, 0xd8, 0x32, 0xdc, 0x03, 0x67, 0xe1, 0x2b, 0xdf, 0xb8, + 0x1b, 0x83, 0x36, 0x29, 0x57, 0x4e, 0x76, 0x2b, 0x27, 0x43, 0x51, 0x78, 0x46, 0x81, 0x3f, 0x42, + 0x6b, 0xa9, 0x54, 0x7c, 0xc3, 0x77, 0xbf, 0xbe, 0x53, 0x31, 0x9e, 0x97, 0x8f, 0xd8, 0x92, 0xd7, + 0xd4, 0xd6, 0x3b, 0xda, 0x3d, 0x81, 0xd6, 0xae, 0x5e, 0x1a, 0x4b, 0x91, 0xf2, 0xbb, 0x1e, 0xd6, + 0xff, 0x7a, 0x9c, 0xce, 0x01, 0x22, 0x59, 0x7e, 0x33, 0xef, 0x9f, 0xc2, 0xd8, 0x8f, 0x93, 0x99, + 0x56, 0xa5, 0x5f, 0x5f, 0x85, 0x91, 0x5a, 0x66, 0x81, 0x2e, 0xe1, 0x9a, 0x9b, 0x0f, 0xe5, 0xeb, + 0x74, 0xb1, 0x72, 0x1f, 0xba, 0xff, 0x9f, 0xf6, 0x0b, 0xed, 0x24, 0xa3, 0x75, 0xc4, 0x85, 0x22, + 0xc3, 0x4c, 0xc9, 0x90, 0x0b, 0x72, 0x96, 0xc4, 0x73, 0x92, 0xf7, 0x83, 0x9a, 0x91, 0xbf, 0xf9, + 0x1d, 0x00, 0x00, 0xff, 0xff, 0x50, 0x77, 0x3e, 0x01, 0x3c, 0x03, 0x00, 0x00, +} diff --git a/dapr/dapr.pb.go b/dapr/proto/dapr/v1/dapr.pb.go similarity index 63% rename from dapr/dapr.pb.go rename to dapr/proto/dapr/v1/dapr.pb.go index 9e230532..9244fba5 100644 --- a/dapr/dapr.pb.go +++ b/dapr/proto/dapr/v1/dapr.pb.go @@ -1,13 +1,12 @@ // Code generated by protoc-gen-go. DO NOT EDIT. -// source: dapr/dapr.proto +// source: dapr/proto/dapr/v1/dapr.proto -package dapr +package v1 import ( context "context" fmt "fmt" - math "math" - + v1 "github.com/dapr/go-sdk/dapr/proto/common/v1" proto "github.com/golang/protobuf/proto" any "github.com/golang/protobuf/ptypes/any" duration "github.com/golang/protobuf/ptypes/duration" @@ -15,6 +14,7 @@ import ( grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" + math "math" ) // Reference imports to suppress errors if they are not otherwise used. @@ -28,55 +28,62 @@ var _ = math.Inf // proto package needs to be updated. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package -type InvokeServiceResponseEnvelope struct { - Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` - Metadata map[string]string `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` +// InvokeServiceRequest represents the request message for Service invocation. +type InvokeServiceRequest struct { + // id specifies callee's app id. + // + // This field is required. + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` + // message which will be delivered to callee. + // + // This field is required. + Message *v1.InvokeRequest `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } -func (m *InvokeServiceResponseEnvelope) Reset() { *m = InvokeServiceResponseEnvelope{} } -func (m *InvokeServiceResponseEnvelope) String() string { return proto.CompactTextString(m) } -func (*InvokeServiceResponseEnvelope) ProtoMessage() {} -func (*InvokeServiceResponseEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{0} +func (m *InvokeServiceRequest) Reset() { *m = InvokeServiceRequest{} } +func (m *InvokeServiceRequest) String() string { return proto.CompactTextString(m) } +func (*InvokeServiceRequest) ProtoMessage() {} +func (*InvokeServiceRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_0f3c232bd8a4c7dd, []int{0} } -func (m *InvokeServiceResponseEnvelope) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_InvokeServiceResponseEnvelope.Unmarshal(m, b) +func (m *InvokeServiceRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_InvokeServiceRequest.Unmarshal(m, b) } -func (m *InvokeServiceResponseEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_InvokeServiceResponseEnvelope.Marshal(b, m, deterministic) +func (m *InvokeServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_InvokeServiceRequest.Marshal(b, m, deterministic) } -func (m *InvokeServiceResponseEnvelope) XXX_Merge(src proto.Message) { - xxx_messageInfo_InvokeServiceResponseEnvelope.Merge(m, src) +func (m *InvokeServiceRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_InvokeServiceRequest.Merge(m, src) } -func (m *InvokeServiceResponseEnvelope) XXX_Size() int { - return xxx_messageInfo_InvokeServiceResponseEnvelope.Size(m) +func (m *InvokeServiceRequest) XXX_Size() int { + return xxx_messageInfo_InvokeServiceRequest.Size(m) } -func (m *InvokeServiceResponseEnvelope) XXX_DiscardUnknown() { - xxx_messageInfo_InvokeServiceResponseEnvelope.DiscardUnknown(m) +func (m *InvokeServiceRequest) XXX_DiscardUnknown() { + xxx_messageInfo_InvokeServiceRequest.DiscardUnknown(m) } -var xxx_messageInfo_InvokeServiceResponseEnvelope proto.InternalMessageInfo +var xxx_messageInfo_InvokeServiceRequest proto.InternalMessageInfo -func (m *InvokeServiceResponseEnvelope) GetData() *any.Any { +func (m *InvokeServiceRequest) GetId() string { if m != nil { - return m.Data + return m.Id } - return nil + return "" } -func (m *InvokeServiceResponseEnvelope) GetMetadata() map[string]string { +func (m *InvokeServiceRequest) GetMessage() *v1.InvokeRequest { if m != nil { - return m.Metadata + return m.Message } return nil } type DeleteStateEnvelope struct { - StoreName string `protobuf:"bytes,1,opt,name=storeName,proto3" json:"storeName,omitempty"` + StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"` Options *StateOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"` @@ -89,7 +96,7 @@ func (m *DeleteStateEnvelope) Reset() { *m = DeleteStateEnvelope{} } func (m *DeleteStateEnvelope) String() string { return proto.CompactTextString(m) } func (*DeleteStateEnvelope) ProtoMessage() {} func (*DeleteStateEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{1} + return fileDescriptor_0f3c232bd8a4c7dd, []int{1} } func (m *DeleteStateEnvelope) XXX_Unmarshal(b []byte) error { @@ -139,7 +146,7 @@ func (m *DeleteStateEnvelope) GetOptions() *StateOptions { } type SaveStateEnvelope struct { - StoreName string `protobuf:"bytes,1,opt,name=storeName,proto3" json:"storeName,omitempty"` + StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"` Requests []*StateRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -150,7 +157,7 @@ func (m *SaveStateEnvelope) Reset() { *m = SaveStateEnvelope{} } func (m *SaveStateEnvelope) String() string { return proto.CompactTextString(m) } func (*SaveStateEnvelope) ProtoMessage() {} func (*SaveStateEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{2} + return fileDescriptor_0f3c232bd8a4c7dd, []int{2} } func (m *SaveStateEnvelope) XXX_Unmarshal(b []byte) error { @@ -186,7 +193,7 @@ func (m *SaveStateEnvelope) GetRequests() []*StateRequest { } type GetStateEnvelope struct { - StoreName string `protobuf:"bytes,1,opt,name=storeName,proto3" json:"storeName,omitempty"` + StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Consistency string `protobuf:"bytes,3,opt,name=consistency,proto3" json:"consistency,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -198,7 +205,7 @@ func (m *GetStateEnvelope) Reset() { *m = GetStateEnvelope{} } func (m *GetStateEnvelope) String() string { return proto.CompactTextString(m) } func (*GetStateEnvelope) ProtoMessage() {} func (*GetStateEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{3} + return fileDescriptor_0f3c232bd8a4c7dd, []int{3} } func (m *GetStateEnvelope) XXX_Unmarshal(b []byte) error { @@ -252,7 +259,7 @@ func (m *GetStateResponseEnvelope) Reset() { *m = GetStateResponseEnvelo func (m *GetStateResponseEnvelope) String() string { return proto.CompactTextString(m) } func (*GetStateResponseEnvelope) ProtoMessage() {} func (*GetStateResponseEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{4} + return fileDescriptor_0f3c232bd8a4c7dd, []int{4} } func (m *GetStateResponseEnvelope) XXX_Unmarshal(b []byte) error { @@ -288,7 +295,7 @@ func (m *GetStateResponseEnvelope) GetEtag() string { } type GetSecretEnvelope struct { - StoreName string `protobuf:"bytes,1,opt,name=storeName,proto3" json:"storeName,omitempty"` + StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Metadata map[string]string `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -300,7 +307,7 @@ func (m *GetSecretEnvelope) Reset() { *m = GetSecretEnvelope{} } func (m *GetSecretEnvelope) String() string { return proto.CompactTextString(m) } func (*GetSecretEnvelope) ProtoMessage() {} func (*GetSecretEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{5} + return fileDescriptor_0f3c232bd8a4c7dd, []int{5} } func (m *GetSecretEnvelope) XXX_Unmarshal(b []byte) error { @@ -353,7 +360,7 @@ func (m *GetSecretResponseEnvelope) Reset() { *m = GetSecretResponseEnve func (m *GetSecretResponseEnvelope) String() string { return proto.CompactTextString(m) } func (*GetSecretResponseEnvelope) ProtoMessage() {} func (*GetSecretResponseEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{6} + return fileDescriptor_0f3c232bd8a4c7dd, []int{6} } func (m *GetSecretResponseEnvelope) XXX_Unmarshal(b []byte) error { @@ -394,7 +401,7 @@ func (m *InvokeBindingEnvelope) Reset() { *m = InvokeBindingEnvelope{} } func (m *InvokeBindingEnvelope) String() string { return proto.CompactTextString(m) } func (*InvokeBindingEnvelope) ProtoMessage() {} func (*InvokeBindingEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{7} + return fileDescriptor_0f3c232bd8a4c7dd, []int{7} } func (m *InvokeBindingEnvelope) XXX_Unmarshal(b []byte) error { @@ -436,69 +443,6 @@ func (m *InvokeBindingEnvelope) GetMetadata() map[string]string { return nil } -type InvokeServiceEnvelope struct { - Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` - Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` - Data *any.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` - Metadata map[string]string `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *InvokeServiceEnvelope) Reset() { *m = InvokeServiceEnvelope{} } -func (m *InvokeServiceEnvelope) String() string { return proto.CompactTextString(m) } -func (*InvokeServiceEnvelope) ProtoMessage() {} -func (*InvokeServiceEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{8} -} - -func (m *InvokeServiceEnvelope) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_InvokeServiceEnvelope.Unmarshal(m, b) -} -func (m *InvokeServiceEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_InvokeServiceEnvelope.Marshal(b, m, deterministic) -} -func (m *InvokeServiceEnvelope) XXX_Merge(src proto.Message) { - xxx_messageInfo_InvokeServiceEnvelope.Merge(m, src) -} -func (m *InvokeServiceEnvelope) XXX_Size() int { - return xxx_messageInfo_InvokeServiceEnvelope.Size(m) -} -func (m *InvokeServiceEnvelope) XXX_DiscardUnknown() { - xxx_messageInfo_InvokeServiceEnvelope.DiscardUnknown(m) -} - -var xxx_messageInfo_InvokeServiceEnvelope proto.InternalMessageInfo - -func (m *InvokeServiceEnvelope) GetId() string { - if m != nil { - return m.Id - } - return "" -} - -func (m *InvokeServiceEnvelope) GetMethod() string { - if m != nil { - return m.Method - } - return "" -} - -func (m *InvokeServiceEnvelope) GetData() *any.Any { - if m != nil { - return m.Data - } - return nil -} - -func (m *InvokeServiceEnvelope) GetMetadata() map[string]string { - if m != nil { - return m.Metadata - } - return nil -} - type PublishEventEnvelope struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Data *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` @@ -511,7 +455,7 @@ func (m *PublishEventEnvelope) Reset() { *m = PublishEventEnvelope{} } func (m *PublishEventEnvelope) String() string { return proto.CompactTextString(m) } func (*PublishEventEnvelope) ProtoMessage() {} func (*PublishEventEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{9} + return fileDescriptor_0f3c232bd8a4c7dd, []int{8} } func (m *PublishEventEnvelope) XXX_Unmarshal(b []byte) error { @@ -561,7 +505,7 @@ func (m *State) Reset() { *m = State{} } func (m *State) String() string { return proto.CompactTextString(m) } func (*State) ProtoMessage() {} func (*State) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{10} + return fileDescriptor_0f3c232bd8a4c7dd, []int{9} } func (m *State) XXX_Unmarshal(b []byte) error { @@ -620,7 +564,7 @@ func (m *State) GetOptions() *StateOptions { type StateOptions struct { Concurrency string `protobuf:"bytes,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"` Consistency string `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"` - RetryPolicy *RetryPolicy `protobuf:"bytes,3,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"` + RetryPolicy *RetryPolicy `protobuf:"bytes,3,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -630,7 +574,7 @@ func (m *StateOptions) Reset() { *m = StateOptions{} } func (m *StateOptions) String() string { return proto.CompactTextString(m) } func (*StateOptions) ProtoMessage() {} func (*StateOptions) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{11} + return fileDescriptor_0f3c232bd8a4c7dd, []int{10} } func (m *StateOptions) XXX_Unmarshal(b []byte) error { @@ -685,7 +629,7 @@ func (m *RetryPolicy) Reset() { *m = RetryPolicy{} } func (m *RetryPolicy) String() string { return proto.CompactTextString(m) } func (*RetryPolicy) ProtoMessage() {} func (*RetryPolicy) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{12} + return fileDescriptor_0f3c232bd8a4c7dd, []int{11} } func (m *RetryPolicy) XXX_Unmarshal(b []byte) error { @@ -728,21 +672,21 @@ func (m *RetryPolicy) GetInterval() *duration.Duration { } type StateRequest struct { - Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` - Value *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` - Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"` - Metadata map[string]string `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` - Options *StateRequestOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` + Value *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` + Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"` + Metadata map[string]string `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + Options *StateOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } func (m *StateRequest) Reset() { *m = StateRequest{} } func (m *StateRequest) String() string { return proto.CompactTextString(m) } func (*StateRequest) ProtoMessage() {} func (*StateRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{13} + return fileDescriptor_0f3c232bd8a4c7dd, []int{12} } func (m *StateRequest) XXX_Unmarshal(b []byte) error { @@ -791,208 +735,94 @@ func (m *StateRequest) GetMetadata() map[string]string { return nil } -func (m *StateRequest) GetOptions() *StateRequestOptions { +func (m *StateRequest) GetOptions() *StateOptions { if m != nil { return m.Options } return nil } -type StateRequestOptions struct { - Concurrency string `protobuf:"bytes,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"` - Consistency string `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"` - RetryPolicy *StateRetryPolicy `protobuf:"bytes,3,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *StateRequestOptions) Reset() { *m = StateRequestOptions{} } -func (m *StateRequestOptions) String() string { return proto.CompactTextString(m) } -func (*StateRequestOptions) ProtoMessage() {} -func (*StateRequestOptions) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{14} -} - -func (m *StateRequestOptions) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_StateRequestOptions.Unmarshal(m, b) -} -func (m *StateRequestOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_StateRequestOptions.Marshal(b, m, deterministic) -} -func (m *StateRequestOptions) XXX_Merge(src proto.Message) { - xxx_messageInfo_StateRequestOptions.Merge(m, src) -} -func (m *StateRequestOptions) XXX_Size() int { - return xxx_messageInfo_StateRequestOptions.Size(m) -} -func (m *StateRequestOptions) XXX_DiscardUnknown() { - xxx_messageInfo_StateRequestOptions.DiscardUnknown(m) -} - -var xxx_messageInfo_StateRequestOptions proto.InternalMessageInfo - -func (m *StateRequestOptions) GetConcurrency() string { - if m != nil { - return m.Concurrency - } - return "" -} - -func (m *StateRequestOptions) GetConsistency() string { - if m != nil { - return m.Consistency - } - return "" -} - -func (m *StateRequestOptions) GetRetryPolicy() *StateRetryPolicy { - if m != nil { - return m.RetryPolicy - } - return nil -} - -type StateRetryPolicy struct { - Threshold int32 `protobuf:"varint,1,opt,name=threshold,proto3" json:"threshold,omitempty"` - Pattern string `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"` - Interval *duration.Duration `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *StateRetryPolicy) Reset() { *m = StateRetryPolicy{} } -func (m *StateRetryPolicy) String() string { return proto.CompactTextString(m) } -func (*StateRetryPolicy) ProtoMessage() {} -func (*StateRetryPolicy) Descriptor() ([]byte, []int) { - return fileDescriptor_221b5d054bffffd8, []int{15} -} - -func (m *StateRetryPolicy) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_StateRetryPolicy.Unmarshal(m, b) -} -func (m *StateRetryPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_StateRetryPolicy.Marshal(b, m, deterministic) -} -func (m *StateRetryPolicy) XXX_Merge(src proto.Message) { - xxx_messageInfo_StateRetryPolicy.Merge(m, src) -} -func (m *StateRetryPolicy) XXX_Size() int { - return xxx_messageInfo_StateRetryPolicy.Size(m) -} -func (m *StateRetryPolicy) XXX_DiscardUnknown() { - xxx_messageInfo_StateRetryPolicy.DiscardUnknown(m) -} - -var xxx_messageInfo_StateRetryPolicy proto.InternalMessageInfo - -func (m *StateRetryPolicy) GetThreshold() int32 { - if m != nil { - return m.Threshold - } - return 0 -} - -func (m *StateRetryPolicy) GetPattern() string { - if m != nil { - return m.Pattern - } - return "" -} - -func (m *StateRetryPolicy) GetInterval() *duration.Duration { - if m != nil { - return m.Interval - } - return nil -} - func init() { - proto.RegisterType((*InvokeServiceResponseEnvelope)(nil), "dapr.InvokeServiceResponseEnvelope") - proto.RegisterMapType((map[string]string)(nil), "dapr.InvokeServiceResponseEnvelope.MetadataEntry") - proto.RegisterType((*DeleteStateEnvelope)(nil), "dapr.DeleteStateEnvelope") - proto.RegisterType((*SaveStateEnvelope)(nil), "dapr.SaveStateEnvelope") - proto.RegisterType((*GetStateEnvelope)(nil), "dapr.GetStateEnvelope") - proto.RegisterType((*GetStateResponseEnvelope)(nil), "dapr.GetStateResponseEnvelope") - proto.RegisterType((*GetSecretEnvelope)(nil), "dapr.GetSecretEnvelope") - proto.RegisterMapType((map[string]string)(nil), "dapr.GetSecretEnvelope.MetadataEntry") - proto.RegisterType((*GetSecretResponseEnvelope)(nil), "dapr.GetSecretResponseEnvelope") - proto.RegisterMapType((map[string]string)(nil), "dapr.GetSecretResponseEnvelope.DataEntry") - proto.RegisterType((*InvokeBindingEnvelope)(nil), "dapr.InvokeBindingEnvelope") - proto.RegisterMapType((map[string]string)(nil), "dapr.InvokeBindingEnvelope.MetadataEntry") - proto.RegisterType((*InvokeServiceEnvelope)(nil), "dapr.InvokeServiceEnvelope") - proto.RegisterMapType((map[string]string)(nil), "dapr.InvokeServiceEnvelope.MetadataEntry") - proto.RegisterType((*PublishEventEnvelope)(nil), "dapr.PublishEventEnvelope") - proto.RegisterType((*State)(nil), "dapr.State") - proto.RegisterMapType((map[string]string)(nil), "dapr.State.MetadataEntry") - proto.RegisterType((*StateOptions)(nil), "dapr.StateOptions") - proto.RegisterType((*RetryPolicy)(nil), "dapr.RetryPolicy") - proto.RegisterType((*StateRequest)(nil), "dapr.StateRequest") - proto.RegisterMapType((map[string]string)(nil), "dapr.StateRequest.MetadataEntry") - proto.RegisterType((*StateRequestOptions)(nil), "dapr.StateRequestOptions") - proto.RegisterType((*StateRetryPolicy)(nil), "dapr.StateRetryPolicy") -} - -func init() { proto.RegisterFile("dapr/dapr.proto", fileDescriptor_221b5d054bffffd8) } - -var fileDescriptor_221b5d054bffffd8 = []byte{ - // 876 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xbc, 0x56, 0xdd, 0x6e, 0xd3, 0x48, - 0x14, 0x5e, 0x3b, 0x49, 0xdb, 0x9c, 0xb4, 0xbb, 0xe9, 0xb4, 0x9b, 0x4d, 0xdc, 0xdd, 0x6e, 0xe4, - 0xd5, 0x4a, 0x2d, 0x42, 0xae, 0x68, 0x85, 0xa8, 0xf8, 0x93, 0x1a, 0x12, 0x2a, 0x2e, 0x0a, 0x95, - 0x23, 0x21, 0x6e, 0xdd, 0x64, 0x48, 0xac, 0xba, 0x1e, 0x63, 0x4f, 0x22, 0x45, 0xe2, 0x86, 0x2b, - 0x6e, 0x91, 0x78, 0x0b, 0x5e, 0x83, 0x67, 0xe0, 0x82, 0x87, 0xe0, 0x09, 0xe0, 0x82, 0xf1, 0x78, - 0xfc, 0x13, 0x3b, 0x49, 0x7f, 0xc3, 0x8d, 0x35, 0x9e, 0x39, 0xf3, 0x9d, 0xf3, 0x9d, 0x39, 0xf3, - 0xcd, 0x81, 0x3f, 0xba, 0x86, 0xe3, 0xee, 0xf8, 0x1f, 0xcd, 0x71, 0x09, 0x25, 0x28, 0xef, 0x8f, - 0x95, 0x5a, 0x8f, 0x90, 0x9e, 0x85, 0x77, 0xf8, 0xdc, 0xc9, 0xe0, 0xf5, 0x8e, 0x61, 0x8f, 0x02, - 0x03, 0x65, 0x23, 0xbd, 0x84, 0xcf, 0x1c, 0x1a, 0x2e, 0x6e, 0xa6, 0x17, 0xbb, 0x03, 0xd7, 0xa0, - 0x26, 0xb1, 0x83, 0x75, 0xf5, 0x8b, 0x04, 0xff, 0x3c, 0xb3, 0x87, 0xe4, 0x14, 0xb7, 0xb1, 0x3b, - 0x34, 0x3b, 0x58, 0xc7, 0x9e, 0x43, 0x6c, 0x0f, 0xb7, 0xec, 0x21, 0xb6, 0x88, 0x83, 0xd1, 0x16, - 0xb0, 0x08, 0xa8, 0x51, 0x95, 0xea, 0xd2, 0x56, 0x69, 0x77, 0x5d, 0x0b, 0x00, 0xb5, 0x10, 0x50, - 0x3b, 0xb0, 0x47, 0x3a, 0xb7, 0x40, 0x47, 0xb0, 0x74, 0x86, 0xa9, 0xc1, 0xad, 0xe5, 0x7a, 0x8e, - 0x59, 0xdf, 0xd1, 0x38, 0x91, 0x99, 0x0e, 0xb4, 0x23, 0xb1, 0xa7, 0x65, 0x53, 0x77, 0xa4, 0x47, - 0x10, 0xca, 0x03, 0x58, 0x19, 0x5b, 0x42, 0x65, 0xc8, 0x9d, 0xe2, 0x11, 0x0f, 0xa4, 0xa8, 0xfb, - 0x43, 0xb4, 0x0e, 0x85, 0xa1, 0x61, 0x0d, 0x30, 0x73, 0xe7, 0xcf, 0x05, 0x3f, 0xf7, 0xe5, 0x7d, - 0x49, 0x7d, 0x2f, 0xc1, 0x5a, 0x13, 0x5b, 0x98, 0xe2, 0x36, 0x35, 0x68, 0xcc, 0xe6, 0x6f, 0x28, - 0x7a, 0x94, 0xb8, 0xf8, 0xb9, 0x71, 0x86, 0x05, 0x52, 0x3c, 0x11, 0x7a, 0x90, 0x63, 0x0f, 0x08, - 0xf2, 0x2c, 0x86, 0x5e, 0x35, 0xc7, 0xa7, 0xf8, 0x18, 0xdd, 0x86, 0x45, 0xe2, 0xf8, 0x39, 0xf4, - 0xaa, 0x79, 0x9e, 0x14, 0x14, 0xd0, 0xe4, 0x9e, 0x5e, 0x04, 0x2b, 0x7a, 0x68, 0xa2, 0x1a, 0xb0, - 0xda, 0x36, 0x86, 0x97, 0x0a, 0x43, 0x83, 0x25, 0x17, 0xbf, 0x19, 0x60, 0x8f, 0x7a, 0x22, 0x91, - 0x49, 0x0f, 0x7a, 0xb0, 0xa4, 0x47, 0x36, 0x6a, 0x17, 0xca, 0x87, 0x98, 0x5e, 0x8f, 0x68, 0x1d, - 0x4a, 0x1d, 0x16, 0xae, 0xe9, 0x51, 0x6c, 0x77, 0x46, 0x82, 0x6f, 0x72, 0x4a, 0x7d, 0x05, 0xd5, - 0xd0, 0xcb, 0x35, 0x8a, 0x24, 0x4c, 0xa8, 0x1c, 0x27, 0x54, 0xfd, 0x2c, 0xc1, 0xaa, 0x0f, 0x8d, - 0x3b, 0x2e, 0xa6, 0x57, 0x66, 0x70, 0x90, 0x28, 0xbf, 0x1c, 0xcf, 0xda, 0xff, 0x41, 0xd6, 0x32, - 0xd0, 0xf3, 0x29, 0xb9, 0x8f, 0x12, 0xd4, 0x22, 0x57, 0x99, 0x0c, 0x3d, 0x8a, 0x32, 0xe4, 0x47, - 0xb6, 0x9d, 0x8a, 0x2c, 0x73, 0x29, 0x9a, 0x51, 0x74, 0x7c, 0x9b, 0x72, 0x0f, 0x8a, 0xcd, 0x2b, - 0x45, 0xf5, 0x55, 0x82, 0x3f, 0x83, 0xfb, 0xd7, 0x30, 0xed, 0xae, 0x69, 0xf7, 0xa2, 0x88, 0xd8, - 0x49, 0xd8, 0x71, 0x6a, 0xf9, 0x38, 0x3a, 0x47, 0xf9, 0xdc, 0x73, 0x6c, 0x65, 0xb2, 0xbd, 0x9d, - 0xbc, 0xec, 0x29, 0x67, 0xf3, 0xc9, 0xf8, 0xb7, 0x88, 0x9b, 0xd0, 0x96, 0x88, 0xdb, 0xef, 0x20, - 0x9b, 0x5d, 0x01, 0xc2, 0x46, 0xa8, 0x02, 0x0b, 0xcc, 0x65, 0x9f, 0x74, 0x05, 0x88, 0xf8, 0x8b, - 0xf8, 0xe6, 0x2e, 0xc5, 0x37, 0x9f, 0xe5, 0x9b, 0x0a, 0x60, 0x3e, 0x7c, 0x5f, 0xc2, 0xfa, 0xf1, - 0xe0, 0xc4, 0x32, 0xbd, 0x7e, 0x6b, 0x88, 0xed, 0xf8, 0xa6, 0xb0, 0x1d, 0x94, 0x38, 0x66, 0x47, - 0xa0, 0x04, 0x3f, 0x17, 0x3f, 0x4b, 0xf5, 0xbb, 0x04, 0x05, 0x7e, 0xaf, 0x27, 0x44, 0x73, 0x2b, - 0x19, 0xcd, 0x34, 0x98, 0xc0, 0x64, 0xa2, 0x58, 0xde, 0xcd, 0xe4, 0xad, 0x96, 0xd0, 0xb2, 0x69, - 0x79, 0x4a, 0x6a, 0x6c, 0xe1, 0x5c, 0x8d, 0xbd, 0xf6, 0x53, 0xb1, 0x9c, 0x84, 0x15, 0x52, 0xd8, - 0x19, 0xb8, 0x2e, 0x97, 0x42, 0x29, 0x92, 0xc2, 0x70, 0x2a, 0x2d, 0x96, 0x72, 0x46, 0x2c, 0xd1, - 0x1e, 0x94, 0xd8, 0xb5, 0x76, 0x47, 0xc7, 0xc4, 0x32, 0x85, 0x9c, 0x96, 0x76, 0x57, 0x03, 0x0e, - 0x7a, 0xbc, 0xa0, 0x27, 0xad, 0xd4, 0xb7, 0x50, 0x4a, 0xac, 0xf9, 0x02, 0x48, 0xfb, 0x2e, 0xf6, - 0xfa, 0xc4, 0x0a, 0x6a, 0xb9, 0xa0, 0xc7, 0x13, 0xa8, 0x0a, 0x8b, 0x8e, 0x41, 0x29, 0x76, 0x6d, - 0xe1, 0x3f, 0xfc, 0xf5, 0x53, 0x6e, 0xda, 0x6c, 0xc4, 0x28, 0x0a, 0xc7, 0xb5, 0xcc, 0xa9, 0x35, - 0x45, 0x1b, 0xa0, 0x47, 0xa6, 0xea, 0x07, 0x59, 0xe4, 0x41, 0x3c, 0x30, 0x73, 0x28, 0x86, 0x87, - 0x99, 0x62, 0xa8, 0x67, 0x1f, 0xb6, 0xa9, 0x35, 0xb1, 0x97, 0xae, 0x89, 0x5a, 0x76, 0xf3, 0xcd, - 0x96, 0x06, 0x93, 0xf4, 0xb5, 0x09, 0xe8, 0x37, 0x52, 0x21, 0xfb, 0x93, 0x2a, 0xa4, 0x32, 0xc6, - 0x68, 0x4a, 0x99, 0xbc, 0x93, 0xa0, 0x9c, 0xb6, 0xf8, 0xc5, 0xc5, 0xb2, 0xfb, 0x23, 0x07, 0xf9, - 0x26, 0x0b, 0x15, 0x35, 0x61, 0x39, 0xa9, 0x49, 0x48, 0x09, 0x18, 0x4c, 0xd2, 0x29, 0xa5, 0x92, - 0x41, 0x6e, 0xf9, 0xad, 0xaa, 0xfa, 0x1b, 0x6a, 0xc3, 0xca, 0x98, 0x8e, 0xa2, 0x8d, 0x19, 0xe2, - 0xaa, 0xfc, 0x77, 0x81, 0xb6, 0x92, 0x81, 0x3e, 0x0d, 0x41, 0xc5, 0x63, 0x34, 0x0e, 0x9a, 0x7a, - 0xa1, 0x66, 0x04, 0xd7, 0x84, 0xa5, 0xb0, 0xf1, 0x41, 0x95, 0xf8, 0xe1, 0x4e, 0xb6, 0x5b, 0xca, - 0xe6, 0xf8, 0xfc, 0x84, 0x68, 0x0e, 0xa1, 0x18, 0x3d, 0xf7, 0xe8, 0xaf, 0x29, 0x9d, 0x89, 0xf2, - 0xef, 0x39, 0x8d, 0x01, 0x03, 0x7a, 0x0c, 0xc5, 0xa8, 0xa1, 0x0c, 0x81, 0x32, 0x1d, 0xe6, 0x0c, - 0x3a, 0x0d, 0x28, 0x25, 0x3a, 0x63, 0x24, 0x2e, 0xd1, 0x84, 0x66, 0x79, 0x3a, 0x46, 0x63, 0x0b, - 0x16, 0x4d, 0xc2, 0x37, 0x36, 0xc0, 0x2f, 0x83, 0x63, 0xdf, 0xc0, 0xfb, 0x24, 0x97, 0xfd, 0x1f, - 0xed, 0x89, 0x65, 0xb2, 0x63, 0xd7, 0x0e, 0x5d, 0xa7, 0x73, 0xb2, 0xc0, 0xf7, 0xee, 0xfd, 0x0c, - 0x00, 0x00, 0xff, 0xff, 0x85, 0xaa, 0x15, 0x82, 0xd8, 0x0c, 0x00, 0x00, + proto.RegisterType((*InvokeServiceRequest)(nil), "dapr.proto.dapr.v1.InvokeServiceRequest") + proto.RegisterType((*DeleteStateEnvelope)(nil), "dapr.proto.dapr.v1.DeleteStateEnvelope") + proto.RegisterType((*SaveStateEnvelope)(nil), "dapr.proto.dapr.v1.SaveStateEnvelope") + proto.RegisterType((*GetStateEnvelope)(nil), "dapr.proto.dapr.v1.GetStateEnvelope") + proto.RegisterType((*GetStateResponseEnvelope)(nil), "dapr.proto.dapr.v1.GetStateResponseEnvelope") + proto.RegisterType((*GetSecretEnvelope)(nil), "dapr.proto.dapr.v1.GetSecretEnvelope") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.dapr.v1.GetSecretEnvelope.MetadataEntry") + proto.RegisterType((*GetSecretResponseEnvelope)(nil), "dapr.proto.dapr.v1.GetSecretResponseEnvelope") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.dapr.v1.GetSecretResponseEnvelope.DataEntry") + proto.RegisterType((*InvokeBindingEnvelope)(nil), "dapr.proto.dapr.v1.InvokeBindingEnvelope") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.dapr.v1.InvokeBindingEnvelope.MetadataEntry") + proto.RegisterType((*PublishEventEnvelope)(nil), "dapr.proto.dapr.v1.PublishEventEnvelope") + proto.RegisterType((*State)(nil), "dapr.proto.dapr.v1.State") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.dapr.v1.State.MetadataEntry") + proto.RegisterType((*StateOptions)(nil), "dapr.proto.dapr.v1.StateOptions") + proto.RegisterType((*RetryPolicy)(nil), "dapr.proto.dapr.v1.RetryPolicy") + proto.RegisterType((*StateRequest)(nil), "dapr.proto.dapr.v1.StateRequest") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.dapr.v1.StateRequest.MetadataEntry") +} + +func init() { proto.RegisterFile("dapr/proto/dapr/v1/dapr.proto", fileDescriptor_0f3c232bd8a4c7dd) } + +var fileDescriptor_0f3c232bd8a4c7dd = []byte{ + // 896 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x56, 0xdd, 0x8e, 0xdb, 0x44, + 0x14, 0x5e, 0x7b, 0x13, 0x76, 0x73, 0xb2, 0x45, 0xed, 0x10, 0x50, 0xd6, 0xa5, 0x10, 0x4c, 0x11, + 0x5b, 0x44, 0x67, 0xb5, 0x5b, 0xa1, 0xa2, 0x02, 0x17, 0xdd, 0x26, 0xaa, 0xf8, 0x6d, 0xe4, 0x20, + 0x84, 0xb8, 0x29, 0x13, 0xe7, 0xe0, 0x58, 0xeb, 0xcc, 0x98, 0xf1, 0xd8, 0x52, 0x24, 0x9e, 0xa3, + 0x5c, 0x73, 0xc1, 0x0d, 0x8f, 0xc3, 0x4b, 0xf0, 0x0e, 0x5c, 0x21, 0x8f, 0x7f, 0xe2, 0xc6, 0x4e, + 0xba, 0xdb, 0x05, 0x89, 0x2b, 0x8f, 0x67, 0xce, 0xcf, 0x37, 0xdf, 0xcc, 0x7c, 0xe7, 0xc0, 0xad, + 0x19, 0x0b, 0xe5, 0x71, 0x28, 0x85, 0x12, 0xc7, 0x7a, 0x98, 0x9c, 0xe8, 0x2f, 0xd5, 0x53, 0x84, + 0xac, 0xc6, 0x54, 0x0f, 0x93, 0x13, 0xeb, 0xd0, 0x13, 0xc2, 0x0b, 0x30, 0x73, 0x9a, 0xc6, 0x3f, + 0x1d, 0x33, 0xbe, 0xcc, 0x4c, 0xac, 0x9b, 0xeb, 0x4b, 0xb8, 0x08, 0x55, 0xb1, 0xf8, 0xd6, 0xfa, + 0xe2, 0x2c, 0x96, 0x4c, 0xf9, 0x82, 0xe7, 0xeb, 0xef, 0x54, 0xa0, 0xb8, 0x62, 0xb1, 0x10, 0x3c, + 0x05, 0x93, 0x8d, 0x32, 0x13, 0x1b, 0xa1, 0xf7, 0x39, 0x4f, 0xc4, 0x39, 0x4e, 0x50, 0x26, 0xbe, + 0x8b, 0x0e, 0xfe, 0x1c, 0x63, 0xa4, 0xc8, 0xab, 0x60, 0xfa, 0xb3, 0xbe, 0x31, 0x30, 0x8e, 0x3a, + 0x8e, 0xe9, 0xcf, 0xc8, 0x67, 0xb0, 0xb7, 0xc0, 0x28, 0x62, 0x1e, 0xf6, 0x77, 0x07, 0xc6, 0x51, + 0xf7, 0xf4, 0x5d, 0x5a, 0xd9, 0x48, 0x1e, 0x32, 0x39, 0xa1, 0x59, 0xb0, 0x3c, 0x8a, 0x53, 0xf8, + 0xd8, 0xcf, 0x0c, 0x78, 0x6d, 0x88, 0x01, 0x2a, 0x9c, 0x28, 0xa6, 0x70, 0xc4, 0x13, 0x0c, 0x44, + 0x88, 0xe4, 0x16, 0x40, 0xa4, 0x84, 0xc4, 0xa7, 0x9c, 0x2d, 0x30, 0x4f, 0xd7, 0xd1, 0x33, 0xdf, + 0xb0, 0x05, 0x92, 0xeb, 0xb0, 0x7b, 0x8e, 0xcb, 0xbe, 0xa9, 0xe7, 0xd3, 0x21, 0x21, 0xd0, 0x42, + 0xc5, 0x3c, 0x0d, 0xa2, 0xe3, 0xe8, 0x31, 0x79, 0x00, 0x7b, 0x22, 0x4c, 0xb7, 0x1d, 0xf5, 0x5b, + 0x1a, 0xdb, 0x80, 0xd6, 0x49, 0xa6, 0x3a, 0xf1, 0x93, 0xcc, 0xce, 0x29, 0x1c, 0xec, 0x10, 0x6e, + 0x4c, 0x58, 0x72, 0x39, 0x54, 0x9f, 0xc2, 0xbe, 0xcc, 0x36, 0x18, 0xf5, 0xcd, 0xc1, 0xee, 0xd6, + 0x84, 0x05, 0x13, 0xa5, 0x87, 0x8d, 0x70, 0xfd, 0x31, 0xaa, 0x2b, 0xd2, 0x30, 0x80, 0xae, 0x2b, + 0x78, 0xe4, 0x47, 0x0a, 0xb9, 0xbb, 0xcc, 0xd9, 0xa8, 0x4e, 0xd9, 0xdf, 0x43, 0xbf, 0x48, 0xe3, + 0x60, 0x14, 0x0a, 0x1e, 0xad, 0xd2, 0x1d, 0x41, 0x6b, 0xc6, 0x14, 0xd3, 0x89, 0xba, 0xa7, 0x3d, + 0x9a, 0x5d, 0x23, 0x5a, 0x5c, 0x23, 0xfa, 0x90, 0x2f, 0x1d, 0x6d, 0x51, 0xd2, 0x6d, 0xae, 0xe8, + 0xb6, 0xff, 0x34, 0xe0, 0x46, 0x1a, 0x1a, 0x5d, 0x89, 0xea, 0xe5, 0xb7, 0xf0, 0x04, 0xf6, 0x17, + 0xa8, 0x98, 0x06, 0xb2, 0xab, 0x59, 0xbc, 0xd7, 0xc4, 0x62, 0x2d, 0x13, 0xfd, 0x3a, 0xf7, 0x1a, + 0x71, 0x25, 0x97, 0x4e, 0x19, 0xc4, 0xfa, 0x04, 0xae, 0x3d, 0xb7, 0x54, 0xe4, 0x34, 0x56, 0x39, + 0x7b, 0xd0, 0x4e, 0x58, 0x10, 0x63, 0x8e, 0x23, 0xfb, 0x79, 0x60, 0x7e, 0x6c, 0xd8, 0xbf, 0x19, + 0x70, 0x58, 0xa6, 0xaa, 0x11, 0xf6, 0x65, 0x49, 0x58, 0x8a, 0xf3, 0xfe, 0x56, 0x9c, 0xeb, 0xce, + 0x74, 0x58, 0x62, 0xd5, 0x41, 0xac, 0xfb, 0xd0, 0x19, 0xbe, 0x14, 0xc6, 0xbf, 0x0c, 0x78, 0x3d, + 0x7b, 0x5f, 0x67, 0x3e, 0x9f, 0xf9, 0xdc, 0x2b, 0xf1, 0x11, 0x68, 0x55, 0x68, 0xd7, 0xe3, 0xf2, + 0x90, 0xcd, 0x17, 0x1e, 0xf2, 0xa4, 0x76, 0x12, 0x8d, 0x3b, 0x6c, 0x4c, 0xfd, 0xdf, 0x9c, 0xc6, + 0x77, 0xd0, 0x1b, 0xc7, 0xd3, 0xc0, 0x8f, 0xe6, 0xa3, 0x04, 0xf9, 0xea, 0x92, 0xf5, 0xa0, 0xad, + 0x44, 0xe8, 0xbb, 0x79, 0x94, 0xec, 0xe7, 0xe2, 0x3b, 0xb5, 0x7f, 0x35, 0xa1, 0xad, 0x9f, 0x44, + 0x03, 0x9a, 0x0f, 0xaa, 0x68, 0x36, 0x85, 0xc9, 0x4c, 0x1a, 0x55, 0xe8, 0x51, 0x85, 0xc5, 0x96, + 0x66, 0xf1, 0xfd, 0x8d, 0xaa, 0xb0, 0x89, 0xb5, 0xaa, 0x94, 0xb5, 0x2f, 0x29, 0x65, 0x57, 0x63, + 0xfc, 0x99, 0x01, 0x07, 0xd5, 0xb0, 0xb9, 0xc2, 0xb8, 0xb1, 0x94, 0x5a, 0x61, 0x8c, 0x52, 0x61, + 0x8a, 0xa9, 0x75, 0x0d, 0x32, 0x6b, 0x1a, 0x44, 0xce, 0xe0, 0x40, 0xa2, 0x92, 0xcb, 0xa7, 0xa1, + 0x08, 0xfc, 0x5c, 0xa6, 0xba, 0xa7, 0x6f, 0x37, 0x6d, 0xc9, 0x49, 0xed, 0xc6, 0xda, 0xcc, 0xe9, + 0xca, 0xd5, 0x8f, 0xfd, 0x0b, 0x74, 0x2b, 0x6b, 0xe4, 0x4d, 0xe8, 0xa8, 0xb9, 0xc4, 0x68, 0x2e, + 0x82, 0xac, 0x3c, 0xb5, 0x9d, 0xd5, 0x04, 0xe9, 0xc3, 0x5e, 0xc8, 0x94, 0x42, 0xc9, 0x73, 0x38, + 0xc5, 0x2f, 0xf9, 0x08, 0xf6, 0x7d, 0xae, 0x50, 0x26, 0x2c, 0xc8, 0x61, 0x1c, 0xd6, 0x0e, 0x78, + 0x98, 0x57, 0x4f, 0xa7, 0x34, 0xb5, 0x7f, 0x37, 0x73, 0x5a, 0x8a, 0xba, 0xf8, 0xef, 0xdf, 0x9b, + 0x2f, 0x6a, 0xf7, 0x86, 0xbe, 0xa8, 0x9a, 0xfc, 0xef, 0xae, 0xcf, 0xe9, 0xdf, 0x2d, 0x68, 0x0d, + 0x59, 0x28, 0x89, 0x03, 0x07, 0xd5, 0x97, 0x4b, 0x8e, 0x9a, 0x00, 0x34, 0xbd, 0x6d, 0xeb, 0x8d, + 0x1a, 0x71, 0xa3, 0xb4, 0xd5, 0xb1, 0x77, 0x08, 0x83, 0x6b, 0xcf, 0xf5, 0x28, 0xcd, 0x41, 0x9b, + 0xda, 0x18, 0xeb, 0xf6, 0xf6, 0x2e, 0x25, 0x53, 0x6a, 0x7b, 0x87, 0x7c, 0x5b, 0xa4, 0xc8, 0xe5, + 0x8d, 0xdc, 0xb9, 0xb0, 0x02, 0x6e, 0x01, 0xfe, 0x23, 0xec, 0x17, 0x35, 0x98, 0xdc, 0xde, 0x54, + 0x34, 0xaa, 0x8d, 0x80, 0xf5, 0xe1, 0x36, 0xab, 0xf5, 0xca, 0x62, 0xef, 0x10, 0x17, 0x3a, 0x65, + 0xe1, 0x21, 0xef, 0x5d, 0xa8, 0x7e, 0x5a, 0x77, 0x2f, 0x55, 0xbe, 0xec, 0x1d, 0xf2, 0x15, 0x74, + 0xca, 0x1e, 0xa9, 0x39, 0x49, 0xad, 0x85, 0xda, 0x42, 0xca, 0x18, 0xba, 0x95, 0x4e, 0x90, 0x34, + 0x8a, 0x64, 0x43, 0xab, 0xb8, 0x39, 0xe2, 0x19, 0x03, 0xf0, 0x4b, 0xdf, 0x33, 0x48, 0xef, 0xe1, + 0x38, 0xb5, 0x89, 0x7e, 0xb8, 0xe3, 0xf9, 0x6a, 0x1e, 0x4f, 0xd3, 0x93, 0xcf, 0x7a, 0x71, 0x4f, + 0xdc, 0x8d, 0x66, 0xe7, 0xc7, 0xf5, 0x16, 0xfd, 0x0f, 0xf3, 0x66, 0xea, 0x47, 0x1f, 0x05, 0x3e, + 0x72, 0x45, 0x1f, 0xc6, 0x4a, 0x78, 0xc8, 0xe9, 0x63, 0x19, 0xba, 0x34, 0x39, 0x99, 0xbe, 0xa2, + 0x8d, 0xef, 0xfd, 0x13, 0x00, 0x00, 0xff, 0xff, 0x14, 0xc2, 0x84, 0x30, 0xdd, 0x0b, 0x00, 0x00, } // Reference imports to suppress errors if they are not otherwise used. @@ -1008,7 +838,7 @@ const _ = grpc.SupportPackageIsVersion4 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type DaprClient interface { PublishEvent(ctx context.Context, in *PublishEventEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) - InvokeService(ctx context.Context, in *InvokeServiceEnvelope, opts ...grpc.CallOption) (*InvokeServiceResponseEnvelope, error) + InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error) InvokeBinding(ctx context.Context, in *InvokeBindingEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) GetState(ctx context.Context, in *GetStateEnvelope, opts ...grpc.CallOption) (*GetStateResponseEnvelope, error) GetSecret(ctx context.Context, in *GetSecretEnvelope, opts ...grpc.CallOption) (*GetSecretResponseEnvelope, error) @@ -1026,16 +856,16 @@ func NewDaprClient(cc *grpc.ClientConn) DaprClient { func (c *daprClient) PublishEvent(ctx context.Context, in *PublishEventEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) { out := new(empty.Empty) - err := c.cc.Invoke(ctx, "/dapr.Dapr/PublishEvent", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/PublishEvent", in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *daprClient) InvokeService(ctx context.Context, in *InvokeServiceEnvelope, opts ...grpc.CallOption) (*InvokeServiceResponseEnvelope, error) { - out := new(InvokeServiceResponseEnvelope) - err := c.cc.Invoke(ctx, "/dapr.Dapr/InvokeService", in, out, opts...) +func (c *daprClient) InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error) { + out := new(v1.InvokeResponse) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/InvokeService", in, out, opts...) if err != nil { return nil, err } @@ -1044,7 +874,7 @@ func (c *daprClient) InvokeService(ctx context.Context, in *InvokeServiceEnvelop func (c *daprClient) InvokeBinding(ctx context.Context, in *InvokeBindingEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) { out := new(empty.Empty) - err := c.cc.Invoke(ctx, "/dapr.Dapr/InvokeBinding", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/InvokeBinding", in, out, opts...) if err != nil { return nil, err } @@ -1053,7 +883,7 @@ func (c *daprClient) InvokeBinding(ctx context.Context, in *InvokeBindingEnvelop func (c *daprClient) GetState(ctx context.Context, in *GetStateEnvelope, opts ...grpc.CallOption) (*GetStateResponseEnvelope, error) { out := new(GetStateResponseEnvelope) - err := c.cc.Invoke(ctx, "/dapr.Dapr/GetState", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/GetState", in, out, opts...) if err != nil { return nil, err } @@ -1062,7 +892,7 @@ func (c *daprClient) GetState(ctx context.Context, in *GetStateEnvelope, opts .. func (c *daprClient) GetSecret(ctx context.Context, in *GetSecretEnvelope, opts ...grpc.CallOption) (*GetSecretResponseEnvelope, error) { out := new(GetSecretResponseEnvelope) - err := c.cc.Invoke(ctx, "/dapr.Dapr/GetSecret", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/GetSecret", in, out, opts...) if err != nil { return nil, err } @@ -1071,7 +901,7 @@ func (c *daprClient) GetSecret(ctx context.Context, in *GetSecretEnvelope, opts func (c *daprClient) SaveState(ctx context.Context, in *SaveStateEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) { out := new(empty.Empty) - err := c.cc.Invoke(ctx, "/dapr.Dapr/SaveState", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/SaveState", in, out, opts...) if err != nil { return nil, err } @@ -1080,7 +910,7 @@ func (c *daprClient) SaveState(ctx context.Context, in *SaveStateEnvelope, opts func (c *daprClient) DeleteState(ctx context.Context, in *DeleteStateEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) { out := new(empty.Empty) - err := c.cc.Invoke(ctx, "/dapr.Dapr/DeleteState", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.dapr.v1.Dapr/DeleteState", in, out, opts...) if err != nil { return nil, err } @@ -1090,7 +920,7 @@ func (c *daprClient) DeleteState(ctx context.Context, in *DeleteStateEnvelope, o // DaprServer is the server API for Dapr service. type DaprServer interface { PublishEvent(context.Context, *PublishEventEnvelope) (*empty.Empty, error) - InvokeService(context.Context, *InvokeServiceEnvelope) (*InvokeServiceResponseEnvelope, error) + InvokeService(context.Context, *InvokeServiceRequest) (*v1.InvokeResponse, error) InvokeBinding(context.Context, *InvokeBindingEnvelope) (*empty.Empty, error) GetState(context.Context, *GetStateEnvelope) (*GetStateResponseEnvelope, error) GetSecret(context.Context, *GetSecretEnvelope) (*GetSecretResponseEnvelope, error) @@ -1105,7 +935,7 @@ type UnimplementedDaprServer struct { func (*UnimplementedDaprServer) PublishEvent(ctx context.Context, req *PublishEventEnvelope) (*empty.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method PublishEvent not implemented") } -func (*UnimplementedDaprServer) InvokeService(ctx context.Context, req *InvokeServiceEnvelope) (*InvokeServiceResponseEnvelope, error) { +func (*UnimplementedDaprServer) InvokeService(ctx context.Context, req *InvokeServiceRequest) (*v1.InvokeResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method InvokeService not implemented") } func (*UnimplementedDaprServer) InvokeBinding(ctx context.Context, req *InvokeBindingEnvelope) (*empty.Empty, error) { @@ -1138,7 +968,7 @@ func _Dapr_PublishEvent_Handler(srv interface{}, ctx context.Context, dec func(i } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/PublishEvent", + FullMethod: "/dapr.proto.dapr.v1.Dapr/PublishEvent", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprServer).PublishEvent(ctx, req.(*PublishEventEnvelope)) @@ -1147,7 +977,7 @@ func _Dapr_PublishEvent_Handler(srv interface{}, ctx context.Context, dec func(i } func _Dapr_InvokeService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(InvokeServiceEnvelope) + in := new(InvokeServiceRequest) if err := dec(in); err != nil { return nil, err } @@ -1156,10 +986,10 @@ func _Dapr_InvokeService_Handler(srv interface{}, ctx context.Context, dec func( } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/InvokeService", + FullMethod: "/dapr.proto.dapr.v1.Dapr/InvokeService", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DaprServer).InvokeService(ctx, req.(*InvokeServiceEnvelope)) + return srv.(DaprServer).InvokeService(ctx, req.(*InvokeServiceRequest)) } return interceptor(ctx, in, info, handler) } @@ -1174,7 +1004,7 @@ func _Dapr_InvokeBinding_Handler(srv interface{}, ctx context.Context, dec func( } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/InvokeBinding", + FullMethod: "/dapr.proto.dapr.v1.Dapr/InvokeBinding", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprServer).InvokeBinding(ctx, req.(*InvokeBindingEnvelope)) @@ -1192,7 +1022,7 @@ func _Dapr_GetState_Handler(srv interface{}, ctx context.Context, dec func(inter } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/GetState", + FullMethod: "/dapr.proto.dapr.v1.Dapr/GetState", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprServer).GetState(ctx, req.(*GetStateEnvelope)) @@ -1210,7 +1040,7 @@ func _Dapr_GetSecret_Handler(srv interface{}, ctx context.Context, dec func(inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/GetSecret", + FullMethod: "/dapr.proto.dapr.v1.Dapr/GetSecret", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprServer).GetSecret(ctx, req.(*GetSecretEnvelope)) @@ -1228,7 +1058,7 @@ func _Dapr_SaveState_Handler(srv interface{}, ctx context.Context, dec func(inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/SaveState", + FullMethod: "/dapr.proto.dapr.v1.Dapr/SaveState", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprServer).SaveState(ctx, req.(*SaveStateEnvelope)) @@ -1246,7 +1076,7 @@ func _Dapr_DeleteState_Handler(srv interface{}, ctx context.Context, dec func(in } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/dapr.Dapr/DeleteState", + FullMethod: "/dapr.proto.dapr.v1.Dapr/DeleteState", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprServer).DeleteState(ctx, req.(*DeleteStateEnvelope)) @@ -1255,7 +1085,7 @@ func _Dapr_DeleteState_Handler(srv interface{}, ctx context.Context, dec func(in } var _Dapr_serviceDesc = grpc.ServiceDesc{ - ServiceName: "dapr.Dapr", + ServiceName: "dapr.proto.dapr.v1.Dapr", HandlerType: (*DaprServer)(nil), Methods: []grpc.MethodDesc{ { @@ -1288,5 +1118,5 @@ var _Dapr_serviceDesc = grpc.ServiceDesc{ }, }, Streams: []grpc.StreamDesc{}, - Metadata: "dapr/dapr.proto", + Metadata: "dapr/proto/dapr/v1/dapr.proto", } diff --git a/daprclient/daprclient.pb.go b/dapr/proto/daprclient/v1/daprclient.pb.go similarity index 69% rename from daprclient/daprclient.pb.go rename to dapr/proto/daprclient/v1/daprclient.pb.go index 9f0ae6e9..6e2f9f9a 100644 --- a/daprclient/daprclient.pb.go +++ b/dapr/proto/daprclient/v1/daprclient.pb.go @@ -1,18 +1,20 @@ // Code generated by protoc-gen-go. DO NOT EDIT. -// source: daprclient.proto +// source: dapr/proto/daprclient/v1/daprclient.proto -package daprclient +package v1 import ( context "context" fmt "fmt" - math "math" - + v1 "github.com/dapr/go-sdk/dapr/proto/common/v1" proto "github.com/golang/protobuf/proto" any "github.com/golang/protobuf/ptypes/any" duration "github.com/golang/protobuf/ptypes/duration" empty "github.com/golang/protobuf/ptypes/empty" grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" + math "math" ) // Reference imports to suppress errors if they are not otherwise used. @@ -31,7 +33,7 @@ type CloudEventEnvelope struct { Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` SpecVersion string `protobuf:"bytes,4,opt,name=specVersion,proto3" json:"specVersion,omitempty"` - DataContentType string `protobuf:"bytes,5,opt,name=dataContentType,proto3" json:"dataContentType,omitempty"` + DataContentType string `protobuf:"bytes,5,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"` Topic string `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"` Data *any.Any `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -43,7 +45,7 @@ func (m *CloudEventEnvelope) Reset() { *m = CloudEventEnvelope{} } func (m *CloudEventEnvelope) String() string { return proto.CompactTextString(m) } func (*CloudEventEnvelope) ProtoMessage() {} func (*CloudEventEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{0} + return fileDescriptor_bb919fe08a3c35cb, []int{0} } func (m *CloudEventEnvelope) XXX_Unmarshal(b []byte) error { @@ -126,7 +128,7 @@ func (m *BindingEventEnvelope) Reset() { *m = BindingEventEnvelope{} } func (m *BindingEventEnvelope) String() string { return proto.CompactTextString(m) } func (*BindingEventEnvelope) ProtoMessage() {} func (*BindingEventEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{1} + return fileDescriptor_bb919fe08a3c35cb, []int{1} } func (m *BindingEventEnvelope) XXX_Unmarshal(b []byte) error { @@ -182,7 +184,7 @@ func (m *BindingResponseEnvelope) Reset() { *m = BindingResponseEnvelope func (m *BindingResponseEnvelope) String() string { return proto.CompactTextString(m) } func (*BindingResponseEnvelope) ProtoMessage() {} func (*BindingResponseEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{2} + return fileDescriptor_bb919fe08a3c35cb, []int{2} } func (m *BindingResponseEnvelope) XXX_Unmarshal(b []byte) error { @@ -231,61 +233,6 @@ func (m *BindingResponseEnvelope) GetConcurrency() string { return "" } -type InvokeEnvelope struct { - Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` - Data *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` - Metadata map[string]string `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *InvokeEnvelope) Reset() { *m = InvokeEnvelope{} } -func (m *InvokeEnvelope) String() string { return proto.CompactTextString(m) } -func (*InvokeEnvelope) ProtoMessage() {} -func (*InvokeEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{3} -} - -func (m *InvokeEnvelope) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_InvokeEnvelope.Unmarshal(m, b) -} -func (m *InvokeEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_InvokeEnvelope.Marshal(b, m, deterministic) -} -func (m *InvokeEnvelope) XXX_Merge(src proto.Message) { - xxx_messageInfo_InvokeEnvelope.Merge(m, src) -} -func (m *InvokeEnvelope) XXX_Size() int { - return xxx_messageInfo_InvokeEnvelope.Size(m) -} -func (m *InvokeEnvelope) XXX_DiscardUnknown() { - xxx_messageInfo_InvokeEnvelope.DiscardUnknown(m) -} - -var xxx_messageInfo_InvokeEnvelope proto.InternalMessageInfo - -func (m *InvokeEnvelope) GetMethod() string { - if m != nil { - return m.Method - } - return "" -} - -func (m *InvokeEnvelope) GetData() *any.Any { - if m != nil { - return m.Data - } - return nil -} - -func (m *InvokeEnvelope) GetMetadata() map[string]string { - if m != nil { - return m.Metadata - } - return nil -} - type GetTopicSubscriptionsEnvelope struct { Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -297,7 +244,7 @@ func (m *GetTopicSubscriptionsEnvelope) Reset() { *m = GetTopicSubscript func (m *GetTopicSubscriptionsEnvelope) String() string { return proto.CompactTextString(m) } func (*GetTopicSubscriptionsEnvelope) ProtoMessage() {} func (*GetTopicSubscriptionsEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{4} + return fileDescriptor_bb919fe08a3c35cb, []int{3} } func (m *GetTopicSubscriptionsEnvelope) XXX_Unmarshal(b []byte) error { @@ -336,7 +283,7 @@ func (m *GetBindingsSubscriptionsEnvelope) Reset() { *m = GetBindingsSub func (m *GetBindingsSubscriptionsEnvelope) String() string { return proto.CompactTextString(m) } func (*GetBindingsSubscriptionsEnvelope) ProtoMessage() {} func (*GetBindingsSubscriptionsEnvelope) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{5} + return fileDescriptor_bb919fe08a3c35cb, []int{4} } func (m *GetBindingsSubscriptionsEnvelope) XXX_Unmarshal(b []byte) error { @@ -379,7 +326,7 @@ func (m *State) Reset() { *m = State{} } func (m *State) String() string { return proto.CompactTextString(m) } func (*State) ProtoMessage() {} func (*State) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{6} + return fileDescriptor_bb919fe08a3c35cb, []int{5} } func (m *State) XXX_Unmarshal(b []byte) error { @@ -438,7 +385,7 @@ func (m *State) GetOptions() *StateOptions { type StateOptions struct { Concurrency string `protobuf:"bytes,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"` Consistency string `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"` - RetryPolicy *RetryPolicy `protobuf:"bytes,3,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"` + RetryPolicy *RetryPolicy `protobuf:"bytes,3,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -448,7 +395,7 @@ func (m *StateOptions) Reset() { *m = StateOptions{} } func (m *StateOptions) String() string { return proto.CompactTextString(m) } func (*StateOptions) ProtoMessage() {} func (*StateOptions) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{7} + return fileDescriptor_bb919fe08a3c35cb, []int{6} } func (m *StateOptions) XXX_Unmarshal(b []byte) error { @@ -503,7 +450,7 @@ func (m *RetryPolicy) Reset() { *m = RetryPolicy{} } func (m *RetryPolicy) String() string { return proto.CompactTextString(m) } func (*RetryPolicy) ProtoMessage() {} func (*RetryPolicy) Descriptor() ([]byte, []int) { - return fileDescriptor_127d5244029ccc8f, []int{8} + return fileDescriptor_bb919fe08a3c35cb, []int{7} } func (m *RetryPolicy) XXX_Unmarshal(b []byte) error { @@ -546,71 +493,77 @@ func (m *RetryPolicy) GetInterval() *duration.Duration { } func init() { - proto.RegisterType((*CloudEventEnvelope)(nil), "daprclient.CloudEventEnvelope") - proto.RegisterType((*BindingEventEnvelope)(nil), "daprclient.BindingEventEnvelope") - proto.RegisterMapType((map[string]string)(nil), "daprclient.BindingEventEnvelope.MetadataEntry") - proto.RegisterType((*BindingResponseEnvelope)(nil), "daprclient.BindingResponseEnvelope") - proto.RegisterType((*InvokeEnvelope)(nil), "daprclient.InvokeEnvelope") - proto.RegisterMapType((map[string]string)(nil), "daprclient.InvokeEnvelope.MetadataEntry") - proto.RegisterType((*GetTopicSubscriptionsEnvelope)(nil), "daprclient.GetTopicSubscriptionsEnvelope") - proto.RegisterType((*GetBindingsSubscriptionsEnvelope)(nil), "daprclient.GetBindingsSubscriptionsEnvelope") - proto.RegisterType((*State)(nil), "daprclient.State") - proto.RegisterMapType((map[string]string)(nil), "daprclient.State.MetadataEntry") - proto.RegisterType((*StateOptions)(nil), "daprclient.StateOptions") - proto.RegisterType((*RetryPolicy)(nil), "daprclient.RetryPolicy") -} - -func init() { proto.RegisterFile("daprclient.proto", fileDescriptor_127d5244029ccc8f) } - -var fileDescriptor_127d5244029ccc8f = []byte{ - // 745 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0xdd, 0x6e, 0xd3, 0x4a, - 0x10, 0x8e, 0x9d, 0x9f, 0xa6, 0x93, 0x9e, 0x9c, 0x9e, 0x51, 0x4f, 0xeb, 0x1a, 0x28, 0x91, 0xb9, - 0x20, 0x20, 0x94, 0x4a, 0x41, 0x88, 0x9f, 0x4a, 0x95, 0xa0, 0x8d, 0x0a, 0x48, 0x28, 0xc8, 0xad, - 0x90, 0x90, 0xb8, 0x71, 0x9c, 0x25, 0xb5, 0xea, 0xec, 0x5a, 0xeb, 0x4d, 0x24, 0x4b, 0xdc, 0x73, - 0xc5, 0x2b, 0xf0, 0x12, 0x3c, 0x0b, 0x77, 0xf0, 0x2e, 0xc8, 0xeb, 0x75, 0xb2, 0x8d, 0x93, 0x56, - 0x08, 0x71, 0xe7, 0x9d, 0xef, 0x9b, 0x9d, 0xf9, 0xe6, 0x67, 0x0d, 0x9b, 0x43, 0x2f, 0xe2, 0x7e, - 0x18, 0x10, 0x2a, 0x3a, 0x11, 0x67, 0x82, 0x21, 0xcc, 0x2d, 0xf6, 0xee, 0x88, 0xb1, 0x51, 0x48, - 0xf6, 0x25, 0x32, 0x98, 0x7c, 0xdc, 0xf7, 0x68, 0x92, 0xd1, 0xec, 0x1b, 0x8b, 0x10, 0x19, 0x47, - 0x22, 0x07, 0xf7, 0x16, 0xc1, 0xe1, 0x84, 0x7b, 0x22, 0x60, 0x34, 0xc3, 0x9d, 0x1f, 0x06, 0xe0, - 0x51, 0xc8, 0x26, 0xc3, 0xde, 0x94, 0x50, 0xd1, 0xa3, 0x53, 0x12, 0xb2, 0x88, 0x60, 0x13, 0xcc, - 0x60, 0x68, 0x19, 0x2d, 0xa3, 0xbd, 0xee, 0x9a, 0xc1, 0x10, 0xb7, 0xa1, 0x16, 0xb3, 0x09, 0xf7, - 0x89, 0x65, 0x4a, 0x9b, 0x3a, 0x21, 0x42, 0x45, 0x24, 0x11, 0xb1, 0xca, 0xd2, 0x2a, 0xbf, 0xb1, - 0x05, 0x8d, 0x38, 0x22, 0xfe, 0x3b, 0xc2, 0xe3, 0x80, 0x51, 0xab, 0x22, 0x21, 0xdd, 0x84, 0x6d, - 0xf8, 0x77, 0xe8, 0x09, 0xef, 0x88, 0x51, 0x41, 0xa8, 0x38, 0x4b, 0x2f, 0xa8, 0x4a, 0xd6, 0xa2, - 0x19, 0xb7, 0xa0, 0x2a, 0x58, 0x14, 0xf8, 0x56, 0x4d, 0xe2, 0xd9, 0x01, 0xdb, 0x50, 0x49, 0x89, - 0xd6, 0x5a, 0xcb, 0x68, 0x37, 0xba, 0x5b, 0x9d, 0x4c, 0x63, 0x27, 0xd7, 0xd8, 0x79, 0x4e, 0x13, - 0x57, 0x32, 0x9c, 0x9f, 0x06, 0x6c, 0xbd, 0x08, 0xe8, 0x30, 0xa0, 0xa3, 0xcb, 0x02, 0x11, 0x2a, - 0xd4, 0x1b, 0x13, 0x25, 0x51, 0x7e, 0xcf, 0xae, 0x35, 0xaf, 0xbb, 0x16, 0x5f, 0x43, 0x7d, 0x4c, - 0x84, 0x27, 0xd9, 0xe5, 0x56, 0xb9, 0xdd, 0xe8, 0x76, 0x3a, 0x5a, 0xfb, 0x96, 0x45, 0xec, 0xbc, - 0x51, 0x0e, 0x3d, 0x2a, 0x78, 0xe2, 0xce, 0xfc, 0xed, 0x03, 0xf8, 0xe7, 0x12, 0x84, 0x9b, 0x50, - 0xbe, 0x20, 0x89, 0xca, 0x2c, 0xfd, 0x4c, 0xab, 0x30, 0xf5, 0xc2, 0x49, 0x5e, 0xfc, 0xec, 0xf0, - 0xcc, 0x7c, 0x62, 0x38, 0x5f, 0x0d, 0xd8, 0x51, 0xd1, 0x5c, 0x12, 0x47, 0x8c, 0xc6, 0x64, 0x26, - 0x31, 0x97, 0x63, 0x5c, 0x2b, 0xa7, 0x09, 0xa6, 0x60, 0x96, 0xd9, 0x2a, 0xa7, 0xdd, 0x16, 0x0c, - 0xef, 0x42, 0x35, 0x16, 0x9e, 0x20, 0x4a, 0xdb, 0x7f, 0xba, 0xb6, 0xd3, 0x14, 0x70, 0x33, 0x3c, - 0x6d, 0xb5, 0xcf, 0xa8, 0x3f, 0xe1, 0x9c, 0x50, 0x3f, 0xc9, 0x5b, 0xad, 0x99, 0x9c, 0xef, 0x06, - 0x34, 0x5f, 0xd1, 0x29, 0xbb, 0x98, 0xe7, 0xb5, 0x0d, 0xb5, 0x31, 0x11, 0xe7, 0x2c, 0x9f, 0x2f, - 0x75, 0xfa, 0x8d, 0xf2, 0x1f, 0x17, 0xca, 0xdf, 0xd6, 0x53, 0xbc, 0x1c, 0xef, 0xef, 0x14, 0xfe, - 0x31, 0xdc, 0x3a, 0x21, 0xe2, 0x2c, 0x1d, 0xc7, 0xd3, 0xc9, 0x20, 0xf6, 0x79, 0x10, 0xa5, 0x5b, - 0x15, 0xeb, 0x2a, 0xe5, 0xb0, 0xc6, 0x96, 0x21, 0xeb, 0xaa, 0x4e, 0xce, 0x21, 0xb4, 0x4e, 0x88, - 0x50, 0x3d, 0x8b, 0x97, 0xfb, 0xda, 0x50, 0x1f, 0x28, 0x82, 0xf2, 0x9e, 0x9d, 0x9d, 0xcf, 0x26, - 0x54, 0x65, 0x0f, 0x96, 0xa4, 0x7b, 0x5f, 0x4f, 0x77, 0x55, 0x09, 0x33, 0x4a, 0xba, 0x00, 0x44, - 0x78, 0xa3, 0x7c, 0x73, 0xd3, 0x6f, 0x3c, 0xd0, 0xea, 0x5a, 0x91, 0x75, 0xbd, 0x5d, 0x68, 0xfd, - 0xaa, 0x72, 0x62, 0x17, 0xd6, 0x58, 0xa6, 0x43, 0x2e, 0x73, 0xa3, 0x6b, 0x15, 0x7c, 0xfb, 0x19, - 0xee, 0xe6, 0xc4, 0x3f, 0x6b, 0xc1, 0x17, 0x03, 0x36, 0xf4, 0x6b, 0x17, 0xa7, 0xd1, 0x28, 0x4c, - 0xa3, 0x62, 0xc4, 0x41, 0x2c, 0x24, 0xc3, 0x9c, 0x31, 0x72, 0x13, 0x3e, 0x85, 0x06, 0x27, 0x82, - 0x27, 0x6f, 0x59, 0x18, 0xf8, 0x89, 0xac, 0x4e, 0xa3, 0xbb, 0xa3, 0x2b, 0x71, 0xe7, 0xb0, 0xab, - 0x73, 0x9d, 0x4f, 0xd0, 0xd0, 0x30, 0xbc, 0x09, 0xeb, 0xe2, 0x9c, 0x93, 0xf8, 0x9c, 0x85, 0xd9, - 0xa4, 0x57, 0xdd, 0xb9, 0x01, 0x2d, 0x58, 0x8b, 0x3c, 0x21, 0x08, 0xa7, 0x2a, 0x8b, 0xfc, 0x88, - 0x8f, 0xa0, 0x1e, 0x50, 0x41, 0xf8, 0xd4, 0x0b, 0x55, 0xf8, 0xdd, 0x42, 0x1f, 0x8f, 0xd5, 0x23, - 0xee, 0xce, 0xa8, 0xdd, 0x6f, 0x65, 0x80, 0x63, 0x2f, 0xe2, 0x47, 0x32, 0x4b, 0x3c, 0x84, 0x7a, - 0x9f, 0x66, 0x8b, 0x80, 0xf6, 0xea, 0xe5, 0xb0, 0x97, 0xce, 0x88, 0x53, 0xc2, 0x0f, 0xf0, 0xff, - 0xd2, 0xf9, 0xc6, 0xed, 0x82, 0x43, 0x2f, 0xfd, 0xdd, 0xd8, 0xf7, 0xf4, 0x20, 0x57, 0xae, 0x86, - 0x53, 0xc2, 0x01, 0x58, 0xab, 0x96, 0x60, 0x65, 0x80, 0x07, 0x0b, 0x01, 0xae, 0x5c, 0x21, 0xa7, - 0x84, 0xef, 0xa1, 0xd9, 0xa7, 0xfa, 0x4b, 0x8c, 0xad, 0xeb, 0xde, 0x68, 0xfb, 0xce, 0x12, 0xc6, - 0xe2, 0xbb, 0xea, 0x94, 0xf0, 0x25, 0x6c, 0xf4, 0xa9, 0x14, 0x98, 0x5d, 0xbc, 0xa7, 0xbb, 0x15, - 0xff, 0xa6, 0xf6, 0x0a, 0x49, 0x4e, 0x69, 0x50, 0x93, 0x96, 0x87, 0xbf, 0x02, 0x00, 0x00, 0xff, - 0xff, 0x08, 0x99, 0x1b, 0xe5, 0xfd, 0x07, 0x00, 0x00, + proto.RegisterType((*CloudEventEnvelope)(nil), "dapr.proto.daprclient.v1.CloudEventEnvelope") + proto.RegisterType((*BindingEventEnvelope)(nil), "dapr.proto.daprclient.v1.BindingEventEnvelope") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.daprclient.v1.BindingEventEnvelope.MetadataEntry") + proto.RegisterType((*BindingResponseEnvelope)(nil), "dapr.proto.daprclient.v1.BindingResponseEnvelope") + proto.RegisterType((*GetTopicSubscriptionsEnvelope)(nil), "dapr.proto.daprclient.v1.GetTopicSubscriptionsEnvelope") + proto.RegisterType((*GetBindingsSubscriptionsEnvelope)(nil), "dapr.proto.daprclient.v1.GetBindingsSubscriptionsEnvelope") + proto.RegisterType((*State)(nil), "dapr.proto.daprclient.v1.State") + proto.RegisterMapType((map[string]string)(nil), "dapr.proto.daprclient.v1.State.MetadataEntry") + proto.RegisterType((*StateOptions)(nil), "dapr.proto.daprclient.v1.StateOptions") + proto.RegisterType((*RetryPolicy)(nil), "dapr.proto.daprclient.v1.RetryPolicy") +} + +func init() { + proto.RegisterFile("dapr/proto/daprclient/v1/daprclient.proto", fileDescriptor_bb919fe08a3c35cb) +} + +var fileDescriptor_bb919fe08a3c35cb = []byte{ + // 835 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xdd, 0x8e, 0xdb, 0x44, + 0x14, 0x8e, 0x9d, 0x64, 0x37, 0x3d, 0x59, 0x96, 0x32, 0x5a, 0x16, 0xd7, 0xe5, 0x27, 0x98, 0x1f, + 0x85, 0x8a, 0x3a, 0x4a, 0x50, 0x55, 0x54, 0x10, 0xa2, 0xbb, 0x8d, 0x96, 0x5e, 0xa0, 0x54, 0x6e, + 0x55, 0x10, 0x37, 0x2b, 0xc7, 0x1e, 0xb2, 0x66, 0x9d, 0x19, 0x33, 0x33, 0xb6, 0x64, 0x89, 0xa7, + 0xe0, 0x9a, 0x3b, 0xee, 0x10, 0xcf, 0xc4, 0x0b, 0xf0, 0x12, 0x68, 0x7e, 0x9c, 0x75, 0x93, 0x38, + 0x11, 0xea, 0xdd, 0xf9, 0xf9, 0xe6, 0xcc, 0x39, 0xdf, 0x39, 0x73, 0x6c, 0xf8, 0x2c, 0x0e, 0x33, + 0x36, 0xca, 0x18, 0x15, 0x74, 0x24, 0xc5, 0x28, 0x4d, 0x30, 0x11, 0xa3, 0x62, 0x5c, 0xd3, 0x7c, + 0xe5, 0x46, 0x8e, 0xb4, 0x68, 0xd9, 0xaf, 0x39, 0x8b, 0xb1, 0x7b, 0x67, 0x41, 0xe9, 0x22, 0xc5, + 0x3a, 0xcc, 0x3c, 0xff, 0x79, 0x14, 0x92, 0x52, 0x03, 0xdd, 0xbb, 0xeb, 0x2e, 0xbc, 0xcc, 0x44, + 0xe5, 0x7c, 0x7f, 0xdd, 0x19, 0xe7, 0x2c, 0x14, 0x09, 0x25, 0xc6, 0xff, 0x61, 0x2d, 0xb9, 0x88, + 0x2e, 0x97, 0x94, 0xc8, 0xc4, 0xb4, 0xa4, 0x21, 0xde, 0x3f, 0x16, 0xa0, 0xf3, 0x94, 0xe6, 0xf1, + 0xb4, 0xc0, 0x44, 0x4c, 0x49, 0x81, 0x53, 0x9a, 0x61, 0x74, 0x0c, 0x76, 0x12, 0x3b, 0xd6, 0xc0, + 0x1a, 0xde, 0x0a, 0xec, 0x24, 0x46, 0xa7, 0x70, 0xc0, 0x69, 0xce, 0x22, 0xec, 0xd8, 0xca, 0x66, + 0x34, 0x84, 0xa0, 0x23, 0xca, 0x0c, 0x3b, 0x6d, 0x65, 0x55, 0x32, 0x1a, 0x40, 0x9f, 0x67, 0x38, + 0x7a, 0x89, 0x19, 0x4f, 0x28, 0x71, 0x3a, 0xca, 0x55, 0x37, 0xa1, 0x7b, 0xf0, 0x56, 0x1c, 0x8a, + 0xf0, 0x32, 0xa2, 0x44, 0x60, 0x22, 0x2e, 0x55, 0x88, 0xae, 0xc2, 0xbd, 0x29, 0x1d, 0xe7, 0xda, + 0xfe, 0x42, 0x46, 0x3b, 0x81, 0xae, 0xa0, 0x59, 0x12, 0x39, 0x07, 0xca, 0xaf, 0x15, 0x34, 0x84, + 0x8e, 0x04, 0x3a, 0x87, 0x03, 0x6b, 0xd8, 0x9f, 0x9c, 0xf8, 0x9a, 0x08, 0xbf, 0x22, 0xc2, 0x7f, + 0x4c, 0xca, 0x40, 0x21, 0xbc, 0x7f, 0x2d, 0x38, 0x39, 0x4b, 0x48, 0x9c, 0x90, 0xc5, 0xab, 0x25, + 0x22, 0xe8, 0x90, 0x70, 0x89, 0x4d, 0x91, 0x4a, 0x5e, 0x85, 0xb5, 0xf7, 0x85, 0x45, 0x3f, 0x42, + 0x6f, 0x89, 0x45, 0xa8, 0xd0, 0xed, 0x41, 0x7b, 0xd8, 0x9f, 0x7c, 0xed, 0x37, 0xf5, 0xd7, 0xdf, + 0x76, 0xbf, 0xff, 0xbd, 0x39, 0x3e, 0x25, 0x82, 0x95, 0xc1, 0x2a, 0x9a, 0xfb, 0x15, 0xbc, 0xf1, + 0x8a, 0x0b, 0xdd, 0x86, 0xf6, 0x35, 0x2e, 0x4d, 0x9e, 0x52, 0x94, 0x9c, 0x14, 0x61, 0x9a, 0x57, + 0xcd, 0xd0, 0xca, 0x23, 0xfb, 0x4b, 0xcb, 0xfb, 0xdb, 0x82, 0x77, 0xcc, 0x6d, 0x01, 0xe6, 0x19, + 0x25, 0x1c, 0xaf, 0x0a, 0xae, 0x8a, 0xb3, 0xf6, 0x16, 0x77, 0x0c, 0xb6, 0xa0, 0x8e, 0x3d, 0x68, + 0xcb, 0xee, 0x0b, 0x8a, 0x1e, 0x40, 0x97, 0x8b, 0x50, 0x60, 0x53, 0xe9, 0x07, 0xcd, 0x95, 0x3e, + 0x97, 0xb0, 0x40, 0xa3, 0xe5, 0x20, 0x44, 0x94, 0x44, 0x39, 0x63, 0x98, 0x44, 0x65, 0x35, 0x08, + 0x35, 0x93, 0xf7, 0x10, 0xde, 0xbb, 0xc0, 0xe2, 0x85, 0x6c, 0xe9, 0xf3, 0x7c, 0xce, 0x23, 0x96, + 0x64, 0x72, 0x7c, 0xf9, 0x2a, 0xe7, 0x53, 0x38, 0x50, 0x0d, 0xe7, 0x8e, 0xa5, 0xb2, 0x31, 0x9a, + 0xf7, 0x0d, 0x0c, 0x2e, 0xb0, 0x30, 0x95, 0xf2, 0xed, 0x67, 0x5d, 0xe8, 0xcd, 0x0d, 0xc0, 0x9c, + 0x5e, 0xe9, 0xde, 0x9f, 0x36, 0x74, 0x55, 0xae, 0x5b, 0xd8, 0xbd, 0x57, 0x67, 0xb7, 0x89, 0x28, + 0x0d, 0x91, 0x43, 0x84, 0x45, 0xb8, 0xa8, 0xe6, 0x5f, 0xca, 0xe8, 0x69, 0x6d, 0x34, 0x3a, 0x8a, + 0xb0, 0xfb, 0x7b, 0x08, 0x6b, 0x9a, 0x05, 0xf4, 0x2d, 0x1c, 0x52, 0x5d, 0x95, 0x7a, 0x1e, 0xfd, + 0xc9, 0xa7, 0x7b, 0x22, 0xcd, 0x34, 0x3a, 0xa8, 0x8e, 0xbd, 0xde, 0x34, 0xfd, 0x61, 0xc1, 0x51, + 0x3d, 0xec, 0x7a, 0x47, 0xad, 0x8d, 0x8e, 0x1a, 0x04, 0x4f, 0xb8, 0x50, 0x08, 0x7b, 0x85, 0xa8, + 0x4c, 0xe8, 0x3b, 0x38, 0x62, 0x58, 0xb0, 0xf2, 0x32, 0xa3, 0x69, 0x12, 0x95, 0x8a, 0xba, 0xfe, + 0xe4, 0x93, 0xe6, 0xc2, 0x02, 0x89, 0x7e, 0xa6, 0xc0, 0x41, 0x9f, 0xdd, 0x28, 0xde, 0x6f, 0xd0, + 0xaf, 0xf9, 0xd0, 0xbb, 0x70, 0x4b, 0x5c, 0x31, 0xcc, 0xaf, 0x68, 0xaa, 0x57, 0x57, 0x37, 0xb8, + 0x31, 0x20, 0x07, 0x0e, 0xb3, 0x50, 0x08, 0xcc, 0x88, 0x49, 0xaa, 0x52, 0xd1, 0x03, 0xe8, 0x25, + 0x44, 0x60, 0x56, 0x84, 0xa9, 0x49, 0xe6, 0xce, 0x46, 0xcb, 0x9f, 0x98, 0xc5, 0x1a, 0xac, 0xa0, + 0x93, 0xdf, 0x3b, 0x00, 0x4f, 0xc2, 0x8c, 0x9d, 0xab, 0x44, 0xd1, 0x0f, 0xd0, 0x9b, 0x91, 0xa7, + 0xa4, 0xa0, 0xd7, 0x18, 0x7d, 0x54, 0x2f, 0xc6, 0xac, 0xdb, 0x62, 0xec, 0x6b, 0x6f, 0x80, 0x7f, + 0xcd, 0x31, 0x17, 0xee, 0xc7, 0xbb, 0x41, 0xfa, 0xf1, 0x7a, 0x2d, 0xf4, 0x0b, 0xbc, 0xbd, 0xf5, + 0x8d, 0xa0, 0xd3, 0x8d, 0x2c, 0xa7, 0xf2, 0xdb, 0xe0, 0x3e, 0x6c, 0xa6, 0x72, 0xe7, 0x63, 0xf3, + 0x5a, 0x28, 0x03, 0xa7, 0xe9, 0x59, 0x35, 0x5e, 0xf7, 0x68, 0xe7, 0x75, 0x3b, 0x9f, 0xa8, 0xd7, + 0x42, 0x39, 0x1c, 0xcf, 0x48, 0x7d, 0x3f, 0x22, 0xff, 0xff, 0xed, 0x51, 0x77, 0xbc, 0x17, 0xbf, + 0xbe, 0x09, 0xbd, 0x16, 0x7a, 0x09, 0x47, 0x33, 0xa2, 0xa8, 0xd0, 0x97, 0x7e, 0xde, 0x1c, 0x64, + 0xf3, 0xeb, 0xe8, 0x36, 0x50, 0xe1, 0xb5, 0xce, 0x96, 0x00, 0x89, 0x0e, 0xe0, 0x17, 0xe3, 0xb3, + 0xdb, 0x37, 0xf3, 0xf1, 0x4c, 0x22, 0xf9, 0x4f, 0xa3, 0x45, 0x22, 0xae, 0xf2, 0xb9, 0xec, 0xb7, + 0xfa, 0x41, 0x18, 0x2d, 0xe8, 0x7d, 0x1e, 0x5f, 0x8f, 0x9a, 0xfe, 0x22, 0xfe, 0xb2, 0xef, 0xca, + 0x18, 0xbe, 0x0e, 0xe2, 0x3f, 0xce, 0x05, 0x5d, 0x60, 0xe2, 0x5f, 0xb0, 0x2c, 0xf2, 0x8b, 0xf1, + 0xfc, 0x40, 0x1d, 0xf9, 0xe2, 0xbf, 0x00, 0x00, 0x00, 0xff, 0xff, 0xb6, 0x1d, 0x8a, 0x4e, 0x86, + 0x08, 0x00, 0x00, } // Reference imports to suppress errors if they are not otherwise used. @@ -625,7 +578,7 @@ const _ = grpc.SupportPackageIsVersion4 // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type DaprClientClient interface { - OnInvoke(ctx context.Context, in *InvokeEnvelope, opts ...grpc.CallOption) (*any.Any, error) + OnInvoke(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error) GetTopicSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetTopicSubscriptionsEnvelope, error) GetBindingsSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetBindingsSubscriptionsEnvelope, error) OnBindingEvent(ctx context.Context, in *BindingEventEnvelope, opts ...grpc.CallOption) (*BindingResponseEnvelope, error) @@ -640,9 +593,9 @@ func NewDaprClientClient(cc *grpc.ClientConn) DaprClientClient { return &daprClientClient{cc} } -func (c *daprClientClient) OnInvoke(ctx context.Context, in *InvokeEnvelope, opts ...grpc.CallOption) (*any.Any, error) { - out := new(any.Any) - err := c.cc.Invoke(ctx, "/daprclient.DaprClient/OnInvoke", in, out, opts...) +func (c *daprClientClient) OnInvoke(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error) { + out := new(v1.InvokeResponse) + err := c.cc.Invoke(ctx, "/dapr.proto.daprclient.v1.DaprClient/OnInvoke", in, out, opts...) if err != nil { return nil, err } @@ -651,7 +604,7 @@ func (c *daprClientClient) OnInvoke(ctx context.Context, in *InvokeEnvelope, opt func (c *daprClientClient) GetTopicSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetTopicSubscriptionsEnvelope, error) { out := new(GetTopicSubscriptionsEnvelope) - err := c.cc.Invoke(ctx, "/daprclient.DaprClient/GetTopicSubscriptions", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.daprclient.v1.DaprClient/GetTopicSubscriptions", in, out, opts...) if err != nil { return nil, err } @@ -660,7 +613,7 @@ func (c *daprClientClient) GetTopicSubscriptions(ctx context.Context, in *empty. func (c *daprClientClient) GetBindingsSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetBindingsSubscriptionsEnvelope, error) { out := new(GetBindingsSubscriptionsEnvelope) - err := c.cc.Invoke(ctx, "/daprclient.DaprClient/GetBindingsSubscriptions", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.daprclient.v1.DaprClient/GetBindingsSubscriptions", in, out, opts...) if err != nil { return nil, err } @@ -669,7 +622,7 @@ func (c *daprClientClient) GetBindingsSubscriptions(ctx context.Context, in *emp func (c *daprClientClient) OnBindingEvent(ctx context.Context, in *BindingEventEnvelope, opts ...grpc.CallOption) (*BindingResponseEnvelope, error) { out := new(BindingResponseEnvelope) - err := c.cc.Invoke(ctx, "/daprclient.DaprClient/OnBindingEvent", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.daprclient.v1.DaprClient/OnBindingEvent", in, out, opts...) if err != nil { return nil, err } @@ -678,7 +631,7 @@ func (c *daprClientClient) OnBindingEvent(ctx context.Context, in *BindingEventE func (c *daprClientClient) OnTopicEvent(ctx context.Context, in *CloudEventEnvelope, opts ...grpc.CallOption) (*empty.Empty, error) { out := new(empty.Empty) - err := c.cc.Invoke(ctx, "/daprclient.DaprClient/OnTopicEvent", in, out, opts...) + err := c.cc.Invoke(ctx, "/dapr.proto.daprclient.v1.DaprClient/OnTopicEvent", in, out, opts...) if err != nil { return nil, err } @@ -687,19 +640,39 @@ func (c *daprClientClient) OnTopicEvent(ctx context.Context, in *CloudEventEnvel // DaprClientServer is the server API for DaprClient service. type DaprClientServer interface { - OnInvoke(context.Context, *InvokeEnvelope) (*any.Any, error) + OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error) GetTopicSubscriptions(context.Context, *empty.Empty) (*GetTopicSubscriptionsEnvelope, error) GetBindingsSubscriptions(context.Context, *empty.Empty) (*GetBindingsSubscriptionsEnvelope, error) OnBindingEvent(context.Context, *BindingEventEnvelope) (*BindingResponseEnvelope, error) OnTopicEvent(context.Context, *CloudEventEnvelope) (*empty.Empty, error) } +// UnimplementedDaprClientServer can be embedded to have forward compatible implementations. +type UnimplementedDaprClientServer struct { +} + +func (*UnimplementedDaprClientServer) OnInvoke(ctx context.Context, req *v1.InvokeRequest) (*v1.InvokeResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method OnInvoke not implemented") +} +func (*UnimplementedDaprClientServer) GetTopicSubscriptions(ctx context.Context, req *empty.Empty) (*GetTopicSubscriptionsEnvelope, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetTopicSubscriptions not implemented") +} +func (*UnimplementedDaprClientServer) GetBindingsSubscriptions(ctx context.Context, req *empty.Empty) (*GetBindingsSubscriptionsEnvelope, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetBindingsSubscriptions not implemented") +} +func (*UnimplementedDaprClientServer) OnBindingEvent(ctx context.Context, req *BindingEventEnvelope) (*BindingResponseEnvelope, error) { + return nil, status.Errorf(codes.Unimplemented, "method OnBindingEvent not implemented") +} +func (*UnimplementedDaprClientServer) OnTopicEvent(ctx context.Context, req *CloudEventEnvelope) (*empty.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method OnTopicEvent not implemented") +} + func RegisterDaprClientServer(s *grpc.Server, srv DaprClientServer) { s.RegisterService(&_DaprClient_serviceDesc, srv) } func _DaprClient_OnInvoke_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(InvokeEnvelope) + in := new(v1.InvokeRequest) if err := dec(in); err != nil { return nil, err } @@ -708,10 +681,10 @@ func _DaprClient_OnInvoke_Handler(srv interface{}, ctx context.Context, dec func } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/daprclient.DaprClient/OnInvoke", + FullMethod: "/dapr.proto.daprclient.v1.DaprClient/OnInvoke", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DaprClientServer).OnInvoke(ctx, req.(*InvokeEnvelope)) + return srv.(DaprClientServer).OnInvoke(ctx, req.(*v1.InvokeRequest)) } return interceptor(ctx, in, info, handler) } @@ -726,7 +699,7 @@ func _DaprClient_GetTopicSubscriptions_Handler(srv interface{}, ctx context.Cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/daprclient.DaprClient/GetTopicSubscriptions", + FullMethod: "/dapr.proto.daprclient.v1.DaprClient/GetTopicSubscriptions", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprClientServer).GetTopicSubscriptions(ctx, req.(*empty.Empty)) @@ -744,7 +717,7 @@ func _DaprClient_GetBindingsSubscriptions_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/daprclient.DaprClient/GetBindingsSubscriptions", + FullMethod: "/dapr.proto.daprclient.v1.DaprClient/GetBindingsSubscriptions", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprClientServer).GetBindingsSubscriptions(ctx, req.(*empty.Empty)) @@ -762,7 +735,7 @@ func _DaprClient_OnBindingEvent_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/daprclient.DaprClient/OnBindingEvent", + FullMethod: "/dapr.proto.daprclient.v1.DaprClient/OnBindingEvent", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprClientServer).OnBindingEvent(ctx, req.(*BindingEventEnvelope)) @@ -780,7 +753,7 @@ func _DaprClient_OnTopicEvent_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/daprclient.DaprClient/OnTopicEvent", + FullMethod: "/dapr.proto.daprclient.v1.DaprClient/OnTopicEvent", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DaprClientServer).OnTopicEvent(ctx, req.(*CloudEventEnvelope)) @@ -789,7 +762,7 @@ func _DaprClient_OnTopicEvent_Handler(srv interface{}, ctx context.Context, dec } var _DaprClient_serviceDesc = grpc.ServiceDesc{ - ServiceName: "daprclient.DaprClient", + ServiceName: "dapr.proto.daprclient.v1.DaprClient", HandlerType: (*DaprClientServer)(nil), Methods: []grpc.MethodDesc{ { @@ -814,5 +787,5 @@ var _DaprClient_serviceDesc = grpc.ServiceDesc{ }, }, Streams: []grpc.StreamDesc{}, - Metadata: "daprclient.proto", + Metadata: "dapr/proto/daprclient/v1/daprclient.proto", } diff --git a/example/caller/main.go b/example/caller/main.go index 938199e0..03cd33aa 100644 --- a/example/caller/main.go +++ b/example/caller/main.go @@ -5,7 +5,9 @@ import ( "fmt" "os" - pb "github.com/dapr/go-sdk/dapr" + commonv1pb "github.com/dapr/go-sdk/dapr/proto/common/v1" + pb "github.com/dapr/go-sdk/dapr/proto/dapr/v1" + "github.com/golang/protobuf/ptypes" "github.com/golang/protobuf/ptypes/any" "google.golang.org/grpc" ) @@ -24,17 +26,32 @@ func main() { // Create the client client := pb.NewDaprClient(conn) + d, err := ptypes.MarshalAny(&commonv1pb.DataWithContentType{ + ContentType: "text/plain; charset=UTF-8", + Body: []byte("Hello"), + }) + if err != nil { + panic(err) + } + // Invoke a method called MyMethod on another Dapr enabled service with id client - resp, err := client.InvokeService(context.Background(), &pb.InvokeServiceEnvelope{ - Id: "client", - Data: &any.Any{Value: []byte("Hello")}, - Method: "MyMethod", + resp, err := client.InvokeService(context.Background(), &pb.InvokeServiceRequest{ + Id: "client", + Message: &commonv1pb.InvokeRequest{ + Method: "MyMethod", + Data: d, + }, }) if err != nil { - fmt.Println(err) - } else { - fmt.Println(string(resp.Data.Value)) + panic(err) } + var value = &commonv1pb.DataWithContentType{} + ptypes.UnmarshalAny(resp.Data, value) + if value.GetContentType() != "text/plain; charset=UTF-8" { + fmt.Printf("wrong content type: %s", value.GetContentType()) + } + + fmt.Println(string(value.Body)) // Publish a message to the topic TopicA _, err = client.PublishEvent(context.Background(), &pb.PublishEventEnvelope{ diff --git a/example/client/main.go b/example/client/main.go index 1d11c7fd..aa357117 100644 --- a/example/client/main.go +++ b/example/client/main.go @@ -6,10 +6,11 @@ import ( "log" "net" - "github.com/golang/protobuf/ptypes/any" + "github.com/golang/protobuf/ptypes" "github.com/golang/protobuf/ptypes/empty" - pb "github.com/dapr/go-sdk/daprclient" + commonv1pb "github.com/dapr/go-sdk/dapr/proto/common/v1" + pb "github.com/dapr/go-sdk/dapr/proto/daprclient/v1" "google.golang.org/grpc" ) @@ -43,7 +44,7 @@ func (s *server) MyMethod() string { // This method gets invoked when a remote service has called the app through Dapr // The payload carries a Method to identify the method, a set of metadata properties and an optional payload -func (s *server) OnInvoke(ctx context.Context, in *pb.InvokeEnvelope) (*any.Any, error) { +func (s *server) OnInvoke(ctx context.Context, in *commonv1pb.InvokeRequest) (*commonv1pb.InvokeResponse, error) { var response string fmt.Println(fmt.Sprintf("Got invoked with: %s", string(in.Data.Value))) @@ -52,9 +53,13 @@ func (s *server) OnInvoke(ctx context.Context, in *pb.InvokeEnvelope) (*any.Any, case "MyMethod": response = s.MyMethod() } - return &any.Any{ - Value: []byte(response), - }, nil + + d := &commonv1pb.DataWithContentType{ + ContentType: "text/plain; charset=UTF-8", + Body: []byte(response), + } + resp, err := ptypes.MarshalAny(d) + return &commonv1pb.InvokeResponse{Data: resp}, err } // Dapr will call this method to get the list of topics the app wants to subscribe to. In this example, we are telling Dapr