v1

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: May 12, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterDaprInternalServer 

func RegisterDaprInternalServer(s *grpc.Server, srv DaprInternalServer)

Types

type APIVersion 

type APIVersion int32

APIVersion represents the version of Dapr API. Dapr and DaprClient service versions follows Dapr API version. DaprInternal service version is maintained separately. 

const (
	APIVersion_UNKNOWN APIVersion = 0
	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 {
	// actor_type is the type of actor.
	//
	// This field is required.
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	// actor_id is the id of actor type (actor_type)
	//
	// This field is required.
	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 DaprInternalClient 

type DaprInternalClient interface {
	CallActor(ctx context.Context, in *InternalInvokeRequest, opts ...grpc.CallOption) (*InternalInvokeResponse, error)
	CallLocal(ctx context.Context, in *InternalInvokeRequest, opts ...grpc.CallOption) (*InternalInvokeResponse, error)
}

DaprInternalClient is the client API for DaprInternal service.

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

func NewDaprInternalClient 

func NewDaprInternalClient(cc *grpc.ClientConn) DaprInternalClient

type DaprInternalServer 

type DaprInternalServer interface {
	CallActor(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error)
	CallLocal(context.Context, *InternalInvokeRequest) (*InternalInvokeResponse, error)
}

DaprInternalServer is the server API for DaprInternal service.

type InternalInvokeRequest 

type InternalInvokeRequest struct {
	// ver is the version of Dapr API.
	//
	// This field is required.
	Ver APIVersion `protobuf:"varint,1,opt,name=ver,proto3,enum=dapr.proto.daprinternal.v1.APIVersion" json:"ver,omitempty"`
	// metadata holds caller's HTTP headers or gRPC metadata.
	//
	// This field is required.
	Metadata map[string]*_struct.ListValue `` /* 157-byte string literal not displayed */
	// message includes caller's invocation request message.
	//
	// This field is required.
	Message *any.Any `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// actor includes actor type and id. This field is used only for
	// actor service invocation.
	//
	// This field is optional.
	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 invocaton. 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() *any.Any

func (*InternalInvokeRequest) GetMetadata 

func (m *InternalInvokeRequest) GetMetadata() map[string]*_struct.ListValue

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 {
	// status is http/grpc status.
	//
	// This field is required.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// headers holds app channel response headers.
	//
	// This field is required.
	Headers map[string]*_struct.ListValue `` /* 155-byte string literal not displayed */
	// trailer holds app channel response trailers.
	// this will be used only for gRPC app channel
	//
	// This field is optional.
	Trailers map[string]*_struct.ListValue `` /* 157-byte string literal not displayed */
	// message includes callee's invocation response message.
	//
	// This field is required.
	Message              *any.Any `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 invocaton.

func (*InternalInvokeResponse) Descriptor 

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

func (*InternalInvokeResponse) GetHeaders 

func (m *InternalInvokeResponse) GetHeaders() map[string]*_struct.ListValue

func (*InternalInvokeResponse) GetMessage 

func (m *InternalInvokeResponse) GetMessage() *any.Any

func (*InternalInvokeResponse) GetStatus 

func (m *InternalInvokeResponse) GetStatus() *Status

func (*InternalInvokeResponse) GetTrailers 

func (m *InternalInvokeResponse) GetTrailers() map[string]*_struct.ListValue

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 Status 

type Status struct {
	// The status code
	//
	// This field is required.
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Error message
	//
	// This field is optional.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// A list of messages that carry the error details
	//
	// This field is optional.
	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 UnimplementedDaprInternalServer 

type UnimplementedDaprInternalServer struct {
}

UnimplementedDaprInternalServer can be embedded to have forward compatible implementations.

func (*UnimplementedDaprInternalServer) CallActor 

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

func (*UnimplementedDaprInternalServer) CallLocal 

func (*UnimplementedDaprInternalServer) 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.