Documentation ¶
Index ¶
- Variables
- func RegisterServiceInvocationServer(s grpc.ServiceRegistrar, srv ServiceInvocationServer)
- type APIVersion
- type Actor
- type InternalInvokeRequest
- func (*InternalInvokeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InternalInvokeRequest) GetActor() *Actor
- func (x *InternalInvokeRequest) GetMessage() *v1.InvokeRequest
- func (x *InternalInvokeRequest) GetMetadata() map[string]*ListStringValue
- func (x *InternalInvokeRequest) GetVer() APIVersion
- func (*InternalInvokeRequest) ProtoMessage()
- func (x *InternalInvokeRequest) ProtoReflect() protoreflect.Message
- func (x *InternalInvokeRequest) Reset()
- func (x *InternalInvokeRequest) String() string
- type InternalInvokeRequestStream
- func (*InternalInvokeRequestStream) Descriptor() ([]byte, []int)deprecated
- func (x *InternalInvokeRequestStream) GetPayload() *v1.StreamPayload
- func (x *InternalInvokeRequestStream) GetRequest() *InternalInvokeRequest
- func (*InternalInvokeRequestStream) ProtoMessage()
- func (x *InternalInvokeRequestStream) ProtoReflect() protoreflect.Message
- func (x *InternalInvokeRequestStream) Reset()
- func (x *InternalInvokeRequestStream) String() string
- type InternalInvokeResponse
- func (*InternalInvokeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InternalInvokeResponse) GetHeaders() map[string]*ListStringValue
- func (x *InternalInvokeResponse) GetMessage() *v1.InvokeResponse
- func (x *InternalInvokeResponse) GetStatus() *Status
- func (x *InternalInvokeResponse) GetTrailers() map[string]*ListStringValue
- func (*InternalInvokeResponse) ProtoMessage()
- func (x *InternalInvokeResponse) ProtoReflect() protoreflect.Message
- func (x *InternalInvokeResponse) Reset()
- func (x *InternalInvokeResponse) String() string
- type InternalInvokeResponseStream
- func (*InternalInvokeResponseStream) Descriptor() ([]byte, []int)deprecated
- func (x *InternalInvokeResponseStream) GetPayload() *v1.StreamPayload
- func (x *InternalInvokeResponseStream) GetResponse() *InternalInvokeResponse
- func (*InternalInvokeResponseStream) ProtoMessage()
- func (x *InternalInvokeResponseStream) ProtoReflect() protoreflect.Message
- func (x *InternalInvokeResponseStream) Reset()
- func (x *InternalInvokeResponseStream) String() string
- type ListStringValue
- type ServiceInvocationClient
- type ServiceInvocationServer
- type ServiceInvocation_CallLocalStreamClient
- type ServiceInvocation_CallLocalStreamServer
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetCode() int32
- func (x *Status) GetDetails() []*anypb.Any
- func (x *Status) GetMessage() string
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type UnimplementedServiceInvocationServer
- func (UnimplementedServiceInvocationServer) CallActor(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error)
- func (UnimplementedServiceInvocationServer) CallLocal(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error)
- func (UnimplementedServiceInvocationServer) CallLocalStream(ServiceInvocation_CallLocalStreamServer) error
- type UnsafeServiceInvocationServer
Constants ¶
This section is empty.
Variables ¶
var ( APIVersion_name = map[int32]string{ 0: "APIVERSION_UNSPECIFIED", 1: "V1", } APIVersion_value = map[string]int32{ "APIVERSION_UNSPECIFIED": 0, "V1": 1, } )
Enum value maps for APIVersion.
var File_dapr_proto_internals_v1_apiversion_proto protoreflect.FileDescriptor
var File_dapr_proto_internals_v1_service_invocation_proto protoreflect.FileDescriptor
var File_dapr_proto_internals_v1_status_proto protoreflect.FileDescriptor
var ServiceInvocation_ServiceDesc = grpc.ServiceDesc{ ServiceName: "dapr.proto.internals.v1.ServiceInvocation", HandlerType: (*ServiceInvocationServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CallActor", Handler: _ServiceInvocation_CallActor_Handler, }, { MethodName: "CallLocal", Handler: _ServiceInvocation_CallLocal_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "CallLocalStream", Handler: _ServiceInvocation_CallLocalStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "dapr/proto/internals/v1/service_invocation.proto", }
ServiceInvocation_ServiceDesc is the grpc.ServiceDesc for ServiceInvocation service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServiceInvocationServer ¶
func RegisterServiceInvocationServer(s grpc.ServiceRegistrar, srv ServiceInvocationServer)
Types ¶
type APIVersion ¶
type APIVersion int32
APIVersion represents the version of Dapr Runtime API.
const ( // unspecified apiversion APIVersion_APIVERSION_UNSPECIFIED APIVersion = 0 // Dapr API v1 APIVersion_V1 APIVersion = 1 )
func (APIVersion) Descriptor ¶ added in v1.0.0
func (APIVersion) Descriptor() protoreflect.EnumDescriptor
func (APIVersion) Enum ¶ added in v1.0.0
func (x APIVersion) Enum() *APIVersion
func (APIVersion) EnumDescriptor
deprecated
func (APIVersion) EnumDescriptor() ([]byte, []int)
Deprecated: Use APIVersion.Descriptor instead.
func (APIVersion) Number ¶ added in v1.0.0
func (x APIVersion) Number() protoreflect.EnumNumber
func (APIVersion) String ¶
func (x APIVersion) String() string
func (APIVersion) Type ¶ added in v1.0.0
func (APIVersion) Type() protoreflect.EnumType
type Actor ¶
type Actor struct { // Required. The type of actor. ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"` // Required. The ID of actor type (actor_type) ActorId string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"` // contains filtered or unexported fields }
Actor represents actor using actor_type and actor_id
func (*Actor) Descriptor
deprecated
func (*Actor) GetActorId ¶
func (*Actor) GetActorType ¶
func (*Actor) ProtoMessage ¶
func (*Actor) ProtoMessage()
func (*Actor) ProtoReflect ¶ added in v1.0.0
func (x *Actor) ProtoReflect() protoreflect.Message
type InternalInvokeRequest ¶
type InternalInvokeRequest struct { // Required. The version of Dapr runtime API. Ver APIVersion `protobuf:"varint,1,opt,name=ver,proto3,enum=dapr.proto.internals.v1.APIVersion" json:"ver,omitempty"` // Required. metadata holds caller's HTTP headers or gRPC metadata. Metadata map[string]*ListStringValue `` /* 157-byte string literal not displayed */ // Required. message including caller's invocation request. Message *v1.InvokeRequest `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // Actor type and id. This field is used only for // actor service invocation. Actor *Actor `protobuf:"bytes,4,opt,name=actor,proto3" json:"actor,omitempty"` // contains filtered or unexported fields }
InternalInvokeRequest is the message to transfer caller's data to callee for service invocation. This includes callee's app id and caller's request data.
func (*InternalInvokeRequest) Descriptor
deprecated
func (*InternalInvokeRequest) Descriptor() ([]byte, []int)
Deprecated: Use InternalInvokeRequest.ProtoReflect.Descriptor instead.
func (*InternalInvokeRequest) GetActor ¶
func (x *InternalInvokeRequest) GetActor() *Actor
func (*InternalInvokeRequest) GetMessage ¶
func (x *InternalInvokeRequest) GetMessage() *v1.InvokeRequest
func (*InternalInvokeRequest) GetMetadata ¶
func (x *InternalInvokeRequest) GetMetadata() map[string]*ListStringValue
func (*InternalInvokeRequest) GetVer ¶
func (x *InternalInvokeRequest) GetVer() APIVersion
func (*InternalInvokeRequest) ProtoMessage ¶
func (*InternalInvokeRequest) ProtoMessage()
func (*InternalInvokeRequest) ProtoReflect ¶ added in v1.0.0
func (x *InternalInvokeRequest) ProtoReflect() protoreflect.Message
func (*InternalInvokeRequest) Reset ¶
func (x *InternalInvokeRequest) Reset()
func (*InternalInvokeRequest) String ¶
func (x *InternalInvokeRequest) String() string
type InternalInvokeRequestStream ¶ added in v1.10.0
type InternalInvokeRequestStream struct { // Request details. // This does not contain any data in message.data. Request *InternalInvokeRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` // Chunk of data. Payload *v1.StreamPayload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
InternalInvokeRequestStream is a variant of InternalInvokeRequest used in streaming RPCs.
func (*InternalInvokeRequestStream) Descriptor
deprecated
added in
v1.10.0
func (*InternalInvokeRequestStream) Descriptor() ([]byte, []int)
Deprecated: Use InternalInvokeRequestStream.ProtoReflect.Descriptor instead.
func (*InternalInvokeRequestStream) GetPayload ¶ added in v1.10.0
func (x *InternalInvokeRequestStream) GetPayload() *v1.StreamPayload
func (*InternalInvokeRequestStream) GetRequest ¶ added in v1.10.0
func (x *InternalInvokeRequestStream) GetRequest() *InternalInvokeRequest
func (*InternalInvokeRequestStream) ProtoMessage ¶ added in v1.10.0
func (*InternalInvokeRequestStream) ProtoMessage()
func (*InternalInvokeRequestStream) ProtoReflect ¶ added in v1.10.0
func (x *InternalInvokeRequestStream) ProtoReflect() protoreflect.Message
func (*InternalInvokeRequestStream) Reset ¶ added in v1.10.0
func (x *InternalInvokeRequestStream) Reset()
func (*InternalInvokeRequestStream) String ¶ added in v1.10.0
func (x *InternalInvokeRequestStream) String() string
type InternalInvokeResponse ¶
type InternalInvokeResponse struct { // Required. HTTP/gRPC status. Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // Required. The app callback response headers. Headers map[string]*ListStringValue `` /* 155-byte string literal not displayed */ // App callback response trailers. // This will be used only for gRPC app callback Trailers map[string]*ListStringValue `` /* 157-byte string literal not displayed */ // Callee's invocation response message. Message *v1.InvokeResponse `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
InternalInvokeResponse is the message to transfer callee's response to caller for service invocation.
func (*InternalInvokeResponse) Descriptor
deprecated
func (*InternalInvokeResponse) Descriptor() ([]byte, []int)
Deprecated: Use InternalInvokeResponse.ProtoReflect.Descriptor instead.
func (*InternalInvokeResponse) GetHeaders ¶
func (x *InternalInvokeResponse) GetHeaders() map[string]*ListStringValue
func (*InternalInvokeResponse) GetMessage ¶
func (x *InternalInvokeResponse) GetMessage() *v1.InvokeResponse
func (*InternalInvokeResponse) GetStatus ¶
func (x *InternalInvokeResponse) GetStatus() *Status
func (*InternalInvokeResponse) GetTrailers ¶
func (x *InternalInvokeResponse) GetTrailers() map[string]*ListStringValue
func (*InternalInvokeResponse) ProtoMessage ¶
func (*InternalInvokeResponse) ProtoMessage()
func (*InternalInvokeResponse) ProtoReflect ¶ added in v1.0.0
func (x *InternalInvokeResponse) ProtoReflect() protoreflect.Message
func (*InternalInvokeResponse) Reset ¶
func (x *InternalInvokeResponse) Reset()
func (*InternalInvokeResponse) String ¶
func (x *InternalInvokeResponse) String() string
type InternalInvokeResponseStream ¶ added in v1.10.0
type InternalInvokeResponseStream struct { // Response details. // This does not contain any data in message.data. Response *InternalInvokeResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` // Chunk of data. Payload *v1.StreamPayload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
InternalInvokeResponseStream is a variant of InternalInvokeResponse used in streaming RPCs.
func (*InternalInvokeResponseStream) Descriptor
deprecated
added in
v1.10.0
func (*InternalInvokeResponseStream) Descriptor() ([]byte, []int)
Deprecated: Use InternalInvokeResponseStream.ProtoReflect.Descriptor instead.
func (*InternalInvokeResponseStream) GetPayload ¶ added in v1.10.0
func (x *InternalInvokeResponseStream) GetPayload() *v1.StreamPayload
func (*InternalInvokeResponseStream) GetResponse ¶ added in v1.10.0
func (x *InternalInvokeResponseStream) GetResponse() *InternalInvokeResponse
func (*InternalInvokeResponseStream) ProtoMessage ¶ added in v1.10.0
func (*InternalInvokeResponseStream) ProtoMessage()
func (*InternalInvokeResponseStream) ProtoReflect ¶ added in v1.10.0
func (x *InternalInvokeResponseStream) ProtoReflect() protoreflect.Message
func (*InternalInvokeResponseStream) Reset ¶ added in v1.10.0
func (x *InternalInvokeResponseStream) Reset()
func (*InternalInvokeResponseStream) String ¶ added in v1.10.0
func (x *InternalInvokeResponseStream) String() string
type ListStringValue ¶
type ListStringValue struct { // The array of string. Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
ListStringValue represents string value array
func (*ListStringValue) Descriptor
deprecated
func (*ListStringValue) Descriptor() ([]byte, []int)
Deprecated: Use ListStringValue.ProtoReflect.Descriptor instead.
func (*ListStringValue) GetValues ¶
func (x *ListStringValue) GetValues() []string
func (*ListStringValue) ProtoMessage ¶
func (*ListStringValue) ProtoMessage()
func (*ListStringValue) ProtoReflect ¶ added in v1.0.0
func (x *ListStringValue) ProtoReflect() protoreflect.Message
func (*ListStringValue) Reset ¶
func (x *ListStringValue) Reset()
func (*ListStringValue) String ¶
func (x *ListStringValue) String() string
type ServiceInvocationClient ¶
type ServiceInvocationClient interface { // Invokes a method of the specific actor. CallActor(ctx context.Context, in *InternalInvokeRequest, opts ...grpc.CallOption) (*InternalInvokeResponse, error) // Invokes a method of the specific service. CallLocal(ctx context.Context, in *InternalInvokeRequest, opts ...grpc.CallOption) (*InternalInvokeResponse, error) // Invokes a method of the specific service using a stream of data. // Although this uses a bi-directional stream, it behaves as a "simple RPC" in which the caller sends the full request (chunked in multiple messages in the stream), then reads the full response (chunked in the stream). // Each message in the stream contains a `InternalInvokeRequestStream` (for caller) or `InternalInvokeResponseStream` (for callee): // - The first message in the stream MUST contain a `request` (caller) or `response` (callee) message with all required properties present. // - The first message in the stream MAY contain a `payload`, which is not required and may be empty. // - Subsequent messages (any message except the first one in the stream) MUST contain a `payload` and MUST NOT contain any other property (like `request` or `response`). // - Each message with a `payload` MUST contain a sequence number in `seq`, which is a counter that starts from 0 and MUST be incremented by 1 in each chunk. The `seq` counter MUST NOT be included if the message does not have a `payload`. // - When the sender has completed sending the data, it MUST call `CloseSend` on the stream. // The caller and callee must send at least one message in the stream. If only 1 message is sent in each direction, that message must contain both a `request`/`response` (the `payload` may be empty). CallLocalStream(ctx context.Context, opts ...grpc.CallOption) (ServiceInvocation_CallLocalStreamClient, error) }
ServiceInvocationClient is the client API for ServiceInvocation service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewServiceInvocationClient ¶
func NewServiceInvocationClient(cc grpc.ClientConnInterface) ServiceInvocationClient
type ServiceInvocationServer ¶
type ServiceInvocationServer interface { // Invokes a method of the specific actor. CallActor(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error) // Invokes a method of the specific service. CallLocal(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error) // Invokes a method of the specific service using a stream of data. // Although this uses a bi-directional stream, it behaves as a "simple RPC" in which the caller sends the full request (chunked in multiple messages in the stream), then reads the full response (chunked in the stream). // Each message in the stream contains a `InternalInvokeRequestStream` (for caller) or `InternalInvokeResponseStream` (for callee): // - The first message in the stream MUST contain a `request` (caller) or `response` (callee) message with all required properties present. // - The first message in the stream MAY contain a `payload`, which is not required and may be empty. // - Subsequent messages (any message except the first one in the stream) MUST contain a `payload` and MUST NOT contain any other property (like `request` or `response`). // - Each message with a `payload` MUST contain a sequence number in `seq`, which is a counter that starts from 0 and MUST be incremented by 1 in each chunk. The `seq` counter MUST NOT be included if the message does not have a `payload`. // - When the sender has completed sending the data, it MUST call `CloseSend` on the stream. // The caller and callee must send at least one message in the stream. If only 1 message is sent in each direction, that message must contain both a `request`/`response` (the `payload` may be empty). CallLocalStream(ServiceInvocation_CallLocalStreamServer) error }
ServiceInvocationServer is the server API for ServiceInvocation service. All implementations should embed UnimplementedServiceInvocationServer for forward compatibility
type ServiceInvocation_CallLocalStreamClient ¶ added in v1.10.0
type ServiceInvocation_CallLocalStreamClient interface { Send(*InternalInvokeRequestStream) error Recv() (*InternalInvokeResponseStream, error) grpc.ClientStream }
type ServiceInvocation_CallLocalStreamServer ¶ added in v1.10.0
type ServiceInvocation_CallLocalStreamServer interface { Send(*InternalInvokeResponseStream) error Recv() (*InternalInvokeRequestStream, error) grpc.ServerStream }
type Status ¶
type Status struct { // Required. The status code Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // Error message Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // A list of messages that carry the error details Details []*anypb.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"` // contains filtered or unexported fields }
Status represents the response status for HTTP and gRPC app channel.
func (*Status) Descriptor
deprecated
func (*Status) GetDetails ¶
func (*Status) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶ added in v1.0.0
func (x *Status) ProtoReflect() protoreflect.Message
type UnimplementedServiceInvocationServer ¶
type UnimplementedServiceInvocationServer struct { }
UnimplementedServiceInvocationServer should be embedded to have forward compatible implementations.
func (UnimplementedServiceInvocationServer) CallActor ¶
func (UnimplementedServiceInvocationServer) CallActor(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error)
func (UnimplementedServiceInvocationServer) CallLocal ¶
func (UnimplementedServiceInvocationServer) CallLocal(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error)
func (UnimplementedServiceInvocationServer) CallLocalStream ¶ added in v1.10.0
func (UnimplementedServiceInvocationServer) CallLocalStream(ServiceInvocation_CallLocalStreamServer) error
type UnsafeServiceInvocationServer ¶ added in v1.0.0
type UnsafeServiceInvocationServer interface {
// contains filtered or unexported methods
}
UnsafeServiceInvocationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceInvocationServer will result in compilation errors.