internals

package
v0.11.0-rc.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2020 License: MIT Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var APIVersion_name = map[int32]string{
	0: "APIVERSION_UNSPECIFIED",
	1: "V1",
}
View Source 
var APIVersion_value = map[string]int32{
	"APIVERSION_UNSPECIFIED": 0,
	"V1":                     1,
}

Functions

func RegisterServiceInvocationServer 

func RegisterServiceInvocationServer(s *grpc.Server, 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) EnumDescriptor 

func (APIVersion) EnumDescriptor() ([]byte, []int)

func (APIVersion) String 

func (x APIVersion) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Actor represents actor using actor_type and actor_id

func (*Actor) Descriptor 

func (*Actor) Descriptor() ([]byte, []int)

func (*Actor) GetActorId 

func (m *Actor) GetActorId() string

func (*Actor) GetActorType 

func (m *Actor) GetActorType() string

func (*Actor) ProtoMessage 

func (*Actor) ProtoMessage()

func (*Actor) Reset 

func (m *Actor) Reset()

func (*Actor) String 

func (m *Actor) String() string

func (*Actor) XXX_DiscardUnknown 

func (m *Actor) XXX_DiscardUnknown()

func (*Actor) XXX_Marshal 

func (m *Actor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Actor) XXX_Merge 

func (m *Actor) XXX_Merge(src proto.Message)

func (*Actor) XXX_Size 

func (m *Actor) XXX_Size() int

func (*Actor) XXX_Unmarshal 

func (m *Actor) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

func (*InternalInvokeRequest) Descriptor() ([]byte, []int)

func (*InternalInvokeRequest) GetActor 

func (m *InternalInvokeRequest) GetActor() *Actor

func (*InternalInvokeRequest) GetMessage 

func (m *InternalInvokeRequest) GetMessage() *v1.InvokeRequest

func (*InternalInvokeRequest) GetMetadata 

func (m *InternalInvokeRequest) GetMetadata() map[string]*ListStringValue

func (*InternalInvokeRequest) GetVer 

func (m *InternalInvokeRequest) GetVer() APIVersion

func (*InternalInvokeRequest) ProtoMessage 

func (*InternalInvokeRequest) ProtoMessage()

func (*InternalInvokeRequest) Reset 

func (m *InternalInvokeRequest) Reset()

func (*InternalInvokeRequest) String 

func (m *InternalInvokeRequest) String() string

func (*InternalInvokeRequest) XXX_DiscardUnknown 

func (m *InternalInvokeRequest) XXX_DiscardUnknown()

func (*InternalInvokeRequest) XXX_Marshal 

func (m *InternalInvokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InternalInvokeRequest) XXX_Merge 

func (m *InternalInvokeRequest) XXX_Merge(src proto.Message)

func (*InternalInvokeRequest) XXX_Size 

func (m *InternalInvokeRequest) XXX_Size() int

func (*InternalInvokeRequest) XXX_Unmarshal 

func (m *InternalInvokeRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

InternalInvokeResponse is the message to transfer callee's response to caller for service invocation.

func (*InternalInvokeResponse) Descriptor 

func (*InternalInvokeResponse) Descriptor() ([]byte, []int)

func (*InternalInvokeResponse) GetHeaders 

func (m *InternalInvokeResponse) GetHeaders() map[string]*ListStringValue

func (*InternalInvokeResponse) GetMessage 

func (m *InternalInvokeResponse) GetMessage() *v1.InvokeResponse

func (*InternalInvokeResponse) GetStatus 

func (m *InternalInvokeResponse) GetStatus() *Status

func (*InternalInvokeResponse) GetTrailers 

func (m *InternalInvokeResponse) GetTrailers() map[string]*ListStringValue

func (*InternalInvokeResponse) ProtoMessage 

func (*InternalInvokeResponse) ProtoMessage()

func (*InternalInvokeResponse) Reset 

func (m *InternalInvokeResponse) Reset()

func (*InternalInvokeResponse) String 

func (m *InternalInvokeResponse) String() string

func (*InternalInvokeResponse) XXX_DiscardUnknown 

func (m *InternalInvokeResponse) XXX_DiscardUnknown()

func (*InternalInvokeResponse) XXX_Marshal 

func (m *InternalInvokeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InternalInvokeResponse) XXX_Merge 

func (m *InternalInvokeResponse) XXX_Merge(src proto.Message)

func (*InternalInvokeResponse) XXX_Size 

func (m *InternalInvokeResponse) XXX_Size() int

func (*InternalInvokeResponse) XXX_Unmarshal 

func (m *InternalInvokeResponse) XXX_Unmarshal(b []byte) error

type ListStringValue 

type ListStringValue struct {
	// The array of string.
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListStringValue represents string value array

func (*ListStringValue) Descriptor 

func (*ListStringValue) Descriptor() ([]byte, []int)

func (*ListStringValue) GetValues 

func (m *ListStringValue) GetValues() []string

func (*ListStringValue) ProtoMessage 

func (*ListStringValue) ProtoMessage()

func (*ListStringValue) Reset 

func (m *ListStringValue) Reset()

func (*ListStringValue) String 

func (m *ListStringValue) String() string

func (*ListStringValue) XXX_DiscardUnknown 

func (m *ListStringValue) XXX_DiscardUnknown()

func (*ListStringValue) XXX_Marshal 

func (m *ListStringValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListStringValue) XXX_Merge 

func (m *ListStringValue) XXX_Merge(src proto.Message)

func (*ListStringValue) XXX_Size 

func (m *ListStringValue) XXX_Size() int

func (*ListStringValue) XXX_Unmarshal 

func (m *ListStringValue) XXX_Unmarshal(b []byte) error

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)
}

ServiceInvocationClient is the client API for ServiceInvocation service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServiceInvocationClient 

func NewServiceInvocationClient(cc *grpc.ClientConn) 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)
}

ServiceInvocationServer is the server API for ServiceInvocation service.

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              []*any.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Status represents the response status for HTTP and gRPC app channel.

func (*Status) Descriptor 

func (*Status) Descriptor() ([]byte, []int)

func (*Status) GetCode 

func (m *Status) GetCode() int32

func (*Status) GetDetails 

func (m *Status) GetDetails() []*any.Any

func (*Status) GetMessage 

func (m *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

type UnimplementedServiceInvocationServer 

type UnimplementedServiceInvocationServer struct {
}

UnimplementedServiceInvocationServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceInvocationServer) CallActor 

func (*UnimplementedServiceInvocationServer) CallActor(ctx context.Context, req *InternalInvokeRequest) (*InternalInvokeResponse, error)

func (*UnimplementedServiceInvocationServer) CallLocal 

func (*UnimplementedServiceInvocationServer) CallLocal(ctx context.Context, req *InternalInvokeRequest) (*InternalInvokeResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.