runtime

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2021 License: MIT Imports: 12 Imported by: 28

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TopicEventResponse_TopicEventResponseStatus_name = map[int32]string{
		0: "SUCCESS",
		1: "RETRY",
		2: "DROP",
	}
	TopicEventResponse_TopicEventResponseStatus_value = map[string]int32{
		"SUCCESS": 0,
		"RETRY":   1,
		"DROP":    2,
	}
)

Enum value maps for TopicEventResponse_TopicEventResponseStatus.

View Source 
var (
	BindingEventResponse_BindingEventConcurrency_name = map[int32]string{
		0: "SEQUENTIAL",
		1: "PARALLEL",
	}
	BindingEventResponse_BindingEventConcurrency_value = map[string]int32{
		"SEQUENTIAL": 0,
		"PARALLEL":   1,
	}
)

Enum value maps for BindingEventResponse_BindingEventConcurrency.

View Source 
var AppCallback_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.runtime.v1.AppCallback",
	HandlerType: (*AppCallbackServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OnInvoke",
			Handler:    _AppCallback_OnInvoke_Handler,
		},
		{
			MethodName: "ListTopicSubscriptions",
			Handler:    _AppCallback_ListTopicSubscriptions_Handler,
		},
		{
			MethodName: "OnTopicEvent",
			Handler:    _AppCallback_OnTopicEvent_Handler,
		},
		{
			MethodName: "ListInputBindings",
			Handler:    _AppCallback_ListInputBindings_Handler,
		},
		{
			MethodName: "OnBindingEvent",
			Handler:    _AppCallback_OnBindingEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/runtime/v1/appcallback.proto",
}

AppCallback_ServiceDesc is the grpc.ServiceDesc for AppCallback service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Dapr_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.runtime.v1.Dapr",
	HandlerType: (*DaprServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InvokeService",
			Handler:    _Dapr_InvokeService_Handler,
		},
		{
			MethodName: "GetState",
			Handler:    _Dapr_GetState_Handler,
		},
		{
			MethodName: "GetBulkState",
			Handler:    _Dapr_GetBulkState_Handler,
		},
		{
			MethodName: "SaveState",
			Handler:    _Dapr_SaveState_Handler,
		},
		{
			MethodName: "DeleteState",
			Handler:    _Dapr_DeleteState_Handler,
		},
		{
			MethodName: "DeleteBulkState",
			Handler:    _Dapr_DeleteBulkState_Handler,
		},
		{
			MethodName: "ExecuteStateTransaction",
			Handler:    _Dapr_ExecuteStateTransaction_Handler,
		},
		{
			MethodName: "PublishEvent",
			Handler:    _Dapr_PublishEvent_Handler,
		},
		{
			MethodName: "InvokeBinding",
			Handler:    _Dapr_InvokeBinding_Handler,
		},
		{
			MethodName: "GetSecret",
			Handler:    _Dapr_GetSecret_Handler,
		},
		{
			MethodName: "GetBulkSecret",
			Handler:    _Dapr_GetBulkSecret_Handler,
		},
		{
			MethodName: "RegisterActorTimer",
			Handler:    _Dapr_RegisterActorTimer_Handler,
		},
		{
			MethodName: "UnregisterActorTimer",
			Handler:    _Dapr_UnregisterActorTimer_Handler,
		},
		{
			MethodName: "RegisterActorReminder",
			Handler:    _Dapr_RegisterActorReminder_Handler,
		},
		{
			MethodName: "UnregisterActorReminder",
			Handler:    _Dapr_UnregisterActorReminder_Handler,
		},
		{
			MethodName: "GetActorState",
			Handler:    _Dapr_GetActorState_Handler,
		},
		{
			MethodName: "ExecuteActorStateTransaction",
			Handler:    _Dapr_ExecuteActorStateTransaction_Handler,
		},
		{
			MethodName: "InvokeActor",
			Handler:    _Dapr_InvokeActor_Handler,
		},
		{
			MethodName: "GetMetadata",
			Handler:    _Dapr_GetMetadata_Handler,
		},
		{
			MethodName: "SetMetadata",
			Handler:    _Dapr_SetMetadata_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Dapr_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/runtime/v1/dapr.proto",
}

Dapr_ServiceDesc is the grpc.ServiceDesc for Dapr service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_dapr_proto_runtime_v1_appcallback_proto protoreflect.FileDescriptor
View Source 
var File_dapr_proto_runtime_v1_dapr_proto protoreflect.FileDescriptor

Functions

func RegisterAppCallbackServer 

func RegisterAppCallbackServer(s grpc.ServiceRegistrar, srv AppCallbackServer)

func RegisterDaprServer 

func RegisterDaprServer(s grpc.ServiceRegistrar, srv DaprServer)

Types

type ActiveActorsCount added in v1.0.0 

type ActiveActorsCount struct {
	Type  string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Count int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ActiveActorsCount) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use ActiveActorsCount.ProtoReflect.Descriptor instead.

func (*ActiveActorsCount) GetCount added in v1.0.0 

func (x *ActiveActorsCount) GetCount() int32

func (*ActiveActorsCount) GetType added in v1.0.0 

func (x *ActiveActorsCount) GetType() string

func (*ActiveActorsCount) ProtoMessage added in v1.0.0 

func (*ActiveActorsCount) ProtoMessage()

func (*ActiveActorsCount) ProtoReflect added in v1.0.0 

func (x *ActiveActorsCount) ProtoReflect() protoreflect.Message

func (*ActiveActorsCount) Reset added in v1.0.0 

func (x *ActiveActorsCount) Reset()

func (*ActiveActorsCount) String added in v1.0.0 

func (x *ActiveActorsCount) String() string

type AppCallbackClient 

type AppCallbackClient interface {
	// Invokes service method with InvokeRequest.
	OnInvoke(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error)
	// Listens events from the input bindings
	//
	// User application can save the states or send the events to the output
	// bindings optionally by returning BindingEventResponse.
	OnBindingEvent(ctx context.Context, in *BindingEventRequest, opts ...grpc.CallOption) (*BindingEventResponse, error)
}

AppCallbackClient is the client API for AppCallback 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 NewAppCallbackClient 

func NewAppCallbackClient(cc grpc.ClientConnInterface) AppCallbackClient

type AppCallbackServer 

type AppCallbackServer interface {
	// Invokes service method with InvokeRequest.
	OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error)
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(context.Context, *emptypb.Empty) (*ListInputBindingsResponse, error)
	// Listens events from the input bindings
	//
	// User application can save the states or send the events to the output
	// bindings optionally by returning BindingEventResponse.
	OnBindingEvent(context.Context, *BindingEventRequest) (*BindingEventResponse, error)
}

AppCallbackServer is the server API for AppCallback service. All implementations should embed UnimplementedAppCallbackServer for forward compatibility

type BindingEventRequest 

type BindingEventRequest struct {

	// Required. The name of the input binding component.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The payload that the input bindings sent
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata set by the input binging components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

BindingEventRequest represents input bindings event.

func (*BindingEventRequest) Descriptor deprecated 

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

Deprecated: Use BindingEventRequest.ProtoReflect.Descriptor instead.

func (*BindingEventRequest) GetData 

func (x *BindingEventRequest) GetData() []byte

func (*BindingEventRequest) GetMetadata 

func (x *BindingEventRequest) GetMetadata() map[string]string

func (*BindingEventRequest) GetName 

func (x *BindingEventRequest) GetName() string

func (*BindingEventRequest) ProtoMessage 

func (*BindingEventRequest) ProtoMessage()

func (*BindingEventRequest) ProtoReflect added in v1.0.0 

func (x *BindingEventRequest) ProtoReflect() protoreflect.Message

func (*BindingEventRequest) Reset 

func (x *BindingEventRequest) Reset()

func (*BindingEventRequest) String 

func (x *BindingEventRequest) String() string

type BindingEventResponse 

type BindingEventResponse struct {

	// The name of state store where states are saved.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The state key values which will be stored in store_name.
	States []*v1.StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// The list of output bindings.
	To []string `protobuf:"bytes,3,rep,name=to,proto3" json:"to,omitempty"`
	// The content which will be sent to "to" output bindings.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// The concurrency of output bindings to send data to
	// "to" output bindings list. The default is SEQUENTIAL.
	Concurrency BindingEventResponse_BindingEventConcurrency `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

BindingEventResponse includes operations to save state or send data to output bindings optionally.

func (*BindingEventResponse) Descriptor deprecated 

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

Deprecated: Use BindingEventResponse.ProtoReflect.Descriptor instead.

func (*BindingEventResponse) GetConcurrency 

func (x *BindingEventResponse) GetConcurrency() BindingEventResponse_BindingEventConcurrency

func (*BindingEventResponse) GetData 

func (x *BindingEventResponse) GetData() []byte

func (*BindingEventResponse) GetStates 

func (x *BindingEventResponse) GetStates() []*v1.StateItem

func (*BindingEventResponse) GetStoreName 

func (x *BindingEventResponse) GetStoreName() string

func (*BindingEventResponse) GetTo 

func (x *BindingEventResponse) GetTo() []string

func (*BindingEventResponse) ProtoMessage 

func (*BindingEventResponse) ProtoMessage()

func (*BindingEventResponse) ProtoReflect added in v1.0.0 

func (x *BindingEventResponse) ProtoReflect() protoreflect.Message

func (*BindingEventResponse) Reset 

func (x *BindingEventResponse) Reset()

func (*BindingEventResponse) String 

func (x *BindingEventResponse) String() string

type BindingEventResponse_BindingEventConcurrency 

type BindingEventResponse_BindingEventConcurrency int32

BindingEventConcurrency is the kind of concurrency 

const (
	// SEQUENTIAL sends data to output bindings specified in "to" sequentially.
	BindingEventResponse_SEQUENTIAL BindingEventResponse_BindingEventConcurrency = 0
	// PARALLEL sends data to output bindings specified in "to" in parallel.
	BindingEventResponse_PARALLEL BindingEventResponse_BindingEventConcurrency = 1
)

func (BindingEventResponse_BindingEventConcurrency) Descriptor added in v1.0.0 

func (BindingEventResponse_BindingEventConcurrency) Descriptor() protoreflect.EnumDescriptor

func (BindingEventResponse_BindingEventConcurrency) Enum added in v1.0.0 

func (x BindingEventResponse_BindingEventConcurrency) Enum() *BindingEventResponse_BindingEventConcurrency

func (BindingEventResponse_BindingEventConcurrency) EnumDescriptor deprecated 

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

Deprecated: Use BindingEventResponse_BindingEventConcurrency.Descriptor instead.

func (BindingEventResponse_BindingEventConcurrency) Number added in v1.0.0 

func (x BindingEventResponse_BindingEventConcurrency) Number() protoreflect.EnumNumber

func (BindingEventResponse_BindingEventConcurrency) String 

func (x BindingEventResponse_BindingEventConcurrency) String() string

func (BindingEventResponse_BindingEventConcurrency) Type added in v1.0.0 

func (BindingEventResponse_BindingEventConcurrency) Type() protoreflect.EnumType

type BulkStateItem added in v0.10.0 

type BulkStateItem struct {

	// state item key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The byte array data
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The entity tag which represents the specific version of data.
	// ETag format is defined by the corresponding data store.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// The error that was returned from the state store in case of a failed get operation.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// The metadata which will be sent to app.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

BulkStateItem is the response item for a bulk get operation. Return values include the item key, data and etag.

func (*BulkStateItem) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use BulkStateItem.ProtoReflect.Descriptor instead.

func (*BulkStateItem) GetData added in v0.10.0 

func (x *BulkStateItem) GetData() []byte

func (*BulkStateItem) GetError added in v0.11.0 

func (x *BulkStateItem) GetError() string

func (*BulkStateItem) GetEtag added in v0.10.0 

func (x *BulkStateItem) GetEtag() string

func (*BulkStateItem) GetKey added in v0.10.0 

func (x *BulkStateItem) GetKey() string

func (*BulkStateItem) GetMetadata added in v1.0.0 

func (x *BulkStateItem) GetMetadata() map[string]string

func (*BulkStateItem) ProtoMessage added in v0.10.0 

func (*BulkStateItem) ProtoMessage()

func (*BulkStateItem) ProtoReflect added in v1.0.0 

func (x *BulkStateItem) ProtoReflect() protoreflect.Message

func (*BulkStateItem) Reset added in v0.10.0 

func (x *BulkStateItem) Reset()

func (*BulkStateItem) String added in v0.10.0 

func (x *BulkStateItem) String() string

type DaprClient 

type DaprClient interface {
	// Invokes a method on a remote Dapr app.
	InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)
	// Gets the state for a specific key.
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
	// Gets a bulk of state items for a list of keys
	GetBulkState(ctx context.Context, in *GetBulkStateRequest, opts ...grpc.CallOption) (*GetBulkStateResponse, error)
	// Saves the state for a specific key.
	SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Publishes events to the specific topic.
	PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(ctx context.Context, in *InvokeBindingRequest, opts ...grpc.CallOption) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// Gets a bulk of secrets
	GetBulkSecret(ctx context.Context, in *GetBulkSecretRequest, opts ...grpc.CallOption) (*GetBulkSecretResponse, error)
	// Register an actor timer.
	RegisterActorTimer(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Unregister an actor timer.
	UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Register an actor reminder.
	RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Unregister an actor reminder.
	UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Gets the state for a specific actor.
	GetActorState(ctx context.Context, in *GetActorStateRequest, opts ...grpc.CallOption) (*GetActorStateResponse, error)
	// Executes state transactions for a specified actor
	ExecuteActorStateTransaction(ctx context.Context, in *ExecuteActorStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// InvokeActor calls a method on an actor.
	InvokeActor(ctx context.Context, in *InvokeActorRequest, opts ...grpc.CallOption) (*InvokeActorResponse, error)
	// Gets metadata of the sidecar
	GetMetadata(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Shutdown the sidecar
	Shutdown(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DaprClient is the client API for Dapr 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 NewDaprClient 

func NewDaprClient(cc grpc.ClientConnInterface) DaprClient

type DaprServer 

type DaprServer interface {
	// Invokes a method on a remote Dapr app.
	InvokeService(context.Context, *InvokeServiceRequest) (*v1.InvokeResponse, error)
	// Gets the state for a specific key.
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	// Gets a bulk of state items for a list of keys
	GetBulkState(context.Context, *GetBulkStateRequest) (*GetBulkStateResponse, error)
	// Saves the state for a specific key.
	SaveState(context.Context, *SaveStateRequest) (*emptypb.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(context.Context, *DeleteStateRequest) (*emptypb.Empty, error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*emptypb.Empty, error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*emptypb.Empty, error)
	// Publishes events to the specific topic.
	PublishEvent(context.Context, *PublishEventRequest) (*emptypb.Empty, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// Gets a bulk of secrets
	GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error)
	// Register an actor timer.
	RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*emptypb.Empty, error)
	// Unregister an actor timer.
	UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*emptypb.Empty, error)
	// Register an actor reminder.
	RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*emptypb.Empty, error)
	// Unregister an actor reminder.
	UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*emptypb.Empty, error)
	// Gets the state for a specific actor.
	GetActorState(context.Context, *GetActorStateRequest) (*GetActorStateResponse, error)
	// Executes state transactions for a specified actor
	ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*emptypb.Empty, error)
	// InvokeActor calls a method on an actor.
	InvokeActor(context.Context, *InvokeActorRequest) (*InvokeActorResponse, error)
	// Gets metadata of the sidecar
	GetMetadata(context.Context, *emptypb.Empty) (*GetMetadataResponse, error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(context.Context, *SetMetadataRequest) (*emptypb.Empty, error)
	// Shutdown the sidecar
	Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
}

DaprServer is the server API for Dapr service. All implementations should embed UnimplementedDaprServer for forward compatibility

type DeleteBulkStateRequest added in v1.0.0 

type DeleteBulkStateRequest struct {

	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The array of the state key values.
	States []*v1.StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

DeleteBulkStateRequest is the message to delete a list of key-value states from specific state store.

func (*DeleteBulkStateRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use DeleteBulkStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteBulkStateRequest) GetStates added in v1.0.0 

func (x *DeleteBulkStateRequest) GetStates() []*v1.StateItem

func (*DeleteBulkStateRequest) GetStoreName added in v1.0.0 

func (x *DeleteBulkStateRequest) GetStoreName() string

func (*DeleteBulkStateRequest) ProtoMessage added in v1.0.0 

func (*DeleteBulkStateRequest) ProtoMessage()

func (*DeleteBulkStateRequest) ProtoReflect added in v1.0.0 

func (x *DeleteBulkStateRequest) ProtoReflect() protoreflect.Message

func (*DeleteBulkStateRequest) Reset added in v1.0.0 

func (x *DeleteBulkStateRequest) Reset()

func (*DeleteBulkStateRequest) String added in v1.0.0 

func (x *DeleteBulkStateRequest) String() string

type DeleteStateRequest 

type DeleteStateRequest struct {

	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The key of the desired state
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The entity tag which represents the specific version of data.
	// The exact ETag format is defined by the corresponding data store.
	Etag *v1.Etag `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// State operation options which includes concurrency/
	// consistency/retry_policy.
	Options *v1.StateOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// The metadata which will be sent to state store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

DeleteStateRequest is the message to delete key-value states in the specific state store.

func (*DeleteStateRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteStateRequest) GetEtag 

func (x *DeleteStateRequest) GetEtag() *v1.Etag

func (*DeleteStateRequest) GetKey 

func (x *DeleteStateRequest) GetKey() string

func (*DeleteStateRequest) GetMetadata added in v0.11.0 

func (x *DeleteStateRequest) GetMetadata() map[string]string

func (*DeleteStateRequest) GetOptions 

func (x *DeleteStateRequest) GetOptions() *v1.StateOptions

func (*DeleteStateRequest) GetStoreName 

func (x *DeleteStateRequest) GetStoreName() string

func (*DeleteStateRequest) ProtoMessage 

func (*DeleteStateRequest) ProtoMessage()

func (*DeleteStateRequest) ProtoReflect added in v1.0.0 

func (x *DeleteStateRequest) ProtoReflect() protoreflect.Message

func (*DeleteStateRequest) Reset 

func (x *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String 

func (x *DeleteStateRequest) String() string

type ExecuteActorStateTransactionRequest added in v1.0.0 

type ExecuteActorStateTransactionRequest struct {
	ActorType  string                              `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId    string                              `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Operations []*TransactionalActorStateOperation `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

ExecuteActorStateTransactionRequest is the message to execute multiple operations on a specified actor.

func (*ExecuteActorStateTransactionRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use ExecuteActorStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActorStateTransactionRequest) GetActorId added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) GetActorId() string

func (*ExecuteActorStateTransactionRequest) GetActorType added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) GetActorType() string

func (*ExecuteActorStateTransactionRequest) GetOperations added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) GetOperations() []*TransactionalActorStateOperation

func (*ExecuteActorStateTransactionRequest) ProtoMessage added in v1.0.0 

func (*ExecuteActorStateTransactionRequest) ProtoMessage()

func (*ExecuteActorStateTransactionRequest) ProtoReflect added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) ProtoReflect() protoreflect.Message

func (*ExecuteActorStateTransactionRequest) Reset added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) Reset()

func (*ExecuteActorStateTransactionRequest) String added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) String() string

type ExecuteStateTransactionRequest added in v0.10.0 

type ExecuteStateTransactionRequest struct {

	// Required. name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=storeName,proto3" json:"storeName,omitempty"`
	// Required. transactional operation list.
	Operations []*TransactionalStateOperation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// The metadata used for transactional operations.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

ExecuteStateTransactionRequest is the message to execute multiple operations on a specified store.

func (*ExecuteStateTransactionRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use ExecuteStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStateTransactionRequest) GetMetadata added in v0.10.0 

func (x *ExecuteStateTransactionRequest) GetMetadata() map[string]string

func (*ExecuteStateTransactionRequest) GetOperations added in v0.10.0 

func (x *ExecuteStateTransactionRequest) GetOperations() []*TransactionalStateOperation

func (*ExecuteStateTransactionRequest) GetStoreName added in v0.10.0 

func (x *ExecuteStateTransactionRequest) GetStoreName() string

func (*ExecuteStateTransactionRequest) ProtoMessage added in v0.10.0 

func (*ExecuteStateTransactionRequest) ProtoMessage()

func (*ExecuteStateTransactionRequest) ProtoReflect added in v1.0.0 

func (x *ExecuteStateTransactionRequest) ProtoReflect() protoreflect.Message

func (*ExecuteStateTransactionRequest) Reset added in v0.10.0 

func (x *ExecuteStateTransactionRequest) Reset()

func (*ExecuteStateTransactionRequest) String added in v0.10.0 

func (x *ExecuteStateTransactionRequest) String() string

type GetActorStateRequest added in v1.0.0 

type GetActorStateRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Key       string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

GetActorStateRequest is the message to get key-value states from specific actor.

func (*GetActorStateRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetActorStateRequest.ProtoReflect.Descriptor instead.

func (*GetActorStateRequest) GetActorId added in v1.0.0 

func (x *GetActorStateRequest) GetActorId() string

func (*GetActorStateRequest) GetActorType added in v1.0.0 

func (x *GetActorStateRequest) GetActorType() string

func (*GetActorStateRequest) GetKey added in v1.0.0 

func (x *GetActorStateRequest) GetKey() string

func (*GetActorStateRequest) ProtoMessage added in v1.0.0 

func (*GetActorStateRequest) ProtoMessage()

func (*GetActorStateRequest) ProtoReflect added in v1.0.0 

func (x *GetActorStateRequest) ProtoReflect() protoreflect.Message

func (*GetActorStateRequest) Reset added in v1.0.0 

func (x *GetActorStateRequest) Reset()

func (*GetActorStateRequest) String added in v1.0.0 

func (x *GetActorStateRequest) String() string

type GetActorStateResponse added in v1.0.0 

type GetActorStateResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

GetActorStateResponse is the response conveying the actor's state value.

func (*GetActorStateResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetActorStateResponse.ProtoReflect.Descriptor instead.

func (*GetActorStateResponse) GetData added in v1.0.0 

func (x *GetActorStateResponse) GetData() []byte

func (*GetActorStateResponse) ProtoMessage added in v1.0.0 

func (*GetActorStateResponse) ProtoMessage()

func (*GetActorStateResponse) ProtoReflect added in v1.0.0 

func (x *GetActorStateResponse) ProtoReflect() protoreflect.Message

func (*GetActorStateResponse) Reset added in v1.0.0 

func (x *GetActorStateResponse) Reset()

func (*GetActorStateResponse) String added in v1.0.0 

func (x *GetActorStateResponse) String() string

type GetBulkSecretRequest added in v1.0.0 

type GetBulkSecretRequest struct {

	// The name of secret store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The metadata which will be sent to secret store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetBulkSecretRequest is the message to get the secrets from secret store.

func (*GetBulkSecretRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetBulkSecretRequest.ProtoReflect.Descriptor instead.

func (*GetBulkSecretRequest) GetMetadata added in v1.0.0 

func (x *GetBulkSecretRequest) GetMetadata() map[string]string

func (*GetBulkSecretRequest) GetStoreName added in v1.0.0 

func (x *GetBulkSecretRequest) GetStoreName() string

func (*GetBulkSecretRequest) ProtoMessage added in v1.0.0 

func (*GetBulkSecretRequest) ProtoMessage()

func (*GetBulkSecretRequest) ProtoReflect added in v1.0.0 

func (x *GetBulkSecretRequest) ProtoReflect() protoreflect.Message

func (*GetBulkSecretRequest) Reset added in v1.0.0 

func (x *GetBulkSecretRequest) Reset()

func (*GetBulkSecretRequest) String added in v1.0.0 

func (x *GetBulkSecretRequest) String() string

type GetBulkSecretResponse added in v1.0.0 

type GetBulkSecretResponse struct {

	// data hold the secret values. Some secret store, such as kubernetes secret
	// store, can save multiple secrets for single secret key.
	Data map[string]*SecretResponse `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetBulkSecretResponse is the response message to convey the requested secrets.

func (*GetBulkSecretResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetBulkSecretResponse.ProtoReflect.Descriptor instead.

func (*GetBulkSecretResponse) GetData added in v1.0.0 

func (x *GetBulkSecretResponse) GetData() map[string]*SecretResponse

func (*GetBulkSecretResponse) ProtoMessage added in v1.0.0 

func (*GetBulkSecretResponse) ProtoMessage()

func (*GetBulkSecretResponse) ProtoReflect added in v1.0.0 

func (x *GetBulkSecretResponse) ProtoReflect() protoreflect.Message

func (*GetBulkSecretResponse) Reset added in v1.0.0 

func (x *GetBulkSecretResponse) Reset()

func (*GetBulkSecretResponse) String added in v1.0.0 

func (x *GetBulkSecretResponse) String() string

type GetBulkStateRequest added in v0.10.0 

type GetBulkStateRequest struct {

	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The keys to get.
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// The number of parallel operations executed on the state store for a get operation.
	Parallelism int32 `protobuf:"varint,3,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// The metadata which will be sent to state store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetBulkStateRequest is the message to get a list of key-value states from specific state store.

func (*GetBulkStateRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetBulkStateRequest.ProtoReflect.Descriptor instead.

func (*GetBulkStateRequest) GetKeys added in v0.10.0 

func (x *GetBulkStateRequest) GetKeys() []string

func (*GetBulkStateRequest) GetMetadata added in v0.11.0 

func (x *GetBulkStateRequest) GetMetadata() map[string]string

func (*GetBulkStateRequest) GetParallelism added in v0.10.0 

func (x *GetBulkStateRequest) GetParallelism() int32

func (*GetBulkStateRequest) GetStoreName added in v0.10.0 

func (x *GetBulkStateRequest) GetStoreName() string

func (*GetBulkStateRequest) ProtoMessage added in v0.10.0 

func (*GetBulkStateRequest) ProtoMessage()

func (*GetBulkStateRequest) ProtoReflect added in v1.0.0 

func (x *GetBulkStateRequest) ProtoReflect() protoreflect.Message

func (*GetBulkStateRequest) Reset added in v0.10.0 

func (x *GetBulkStateRequest) Reset()

func (*GetBulkStateRequest) String added in v0.10.0 

func (x *GetBulkStateRequest) String() string

type GetBulkStateResponse added in v0.10.0 

type GetBulkStateResponse struct {

	// The list of items containing the keys to get values for.
	Items []*BulkStateItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

GetBulkStateResponse is the response conveying the list of state values.

func (*GetBulkStateResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetBulkStateResponse.ProtoReflect.Descriptor instead.

func (*GetBulkStateResponse) GetItems added in v0.10.0 

func (x *GetBulkStateResponse) GetItems() []*BulkStateItem

func (*GetBulkStateResponse) ProtoMessage added in v0.10.0 

func (*GetBulkStateResponse) ProtoMessage()

func (*GetBulkStateResponse) ProtoReflect added in v1.0.0 

func (x *GetBulkStateResponse) ProtoReflect() protoreflect.Message

func (*GetBulkStateResponse) Reset added in v0.10.0 

func (x *GetBulkStateResponse) Reset()

func (*GetBulkStateResponse) String added in v0.10.0 

func (x *GetBulkStateResponse) String() string

type GetMetadataResponse added in v1.0.0 

type GetMetadataResponse struct {
	Id                   string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ActiveActorsCount    []*ActiveActorsCount    `protobuf:"bytes,2,rep,name=active_actors_count,json=activeActorsCount,proto3" json:"active_actors_count,omitempty"`
	RegisteredComponents []*RegisteredComponents `protobuf:"bytes,3,rep,name=registered_components,json=registeredComponents,proto3" json:"registered_components,omitempty"`
	ExtendedMetadata     map[string]string       `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetMetadataResponse is a message that is returned on GetMetadata rpc call

func (*GetMetadataResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetMetadataResponse) GetActiveActorsCount added in v1.0.0 

func (x *GetMetadataResponse) GetActiveActorsCount() []*ActiveActorsCount

func (*GetMetadataResponse) GetExtendedMetadata added in v1.0.0 

func (x *GetMetadataResponse) GetExtendedMetadata() map[string]string

func (*GetMetadataResponse) GetId added in v1.0.0 

func (x *GetMetadataResponse) GetId() string

func (*GetMetadataResponse) GetRegisteredComponents added in v1.0.0 

func (x *GetMetadataResponse) GetRegisteredComponents() []*RegisteredComponents

func (*GetMetadataResponse) ProtoMessage added in v1.0.0 

func (*GetMetadataResponse) ProtoMessage()

func (*GetMetadataResponse) ProtoReflect added in v1.0.0 

func (x *GetMetadataResponse) ProtoReflect() protoreflect.Message

func (*GetMetadataResponse) Reset added in v1.0.0 

func (x *GetMetadataResponse) Reset()

func (*GetMetadataResponse) String added in v1.0.0 

func (x *GetMetadataResponse) String() string

type GetSecretRequest 

type GetSecretRequest struct {

	// The name of secret store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The name of secret key.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The metadata which will be sent to secret store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetSecretRequest is the message to get secret from secret store.

func (*GetSecretRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetKey 

func (x *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetMetadata 

func (x *GetSecretRequest) GetMetadata() map[string]string

func (*GetSecretRequest) GetStoreName 

func (x *GetSecretRequest) GetStoreName() string

func (*GetSecretRequest) ProtoMessage 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect added in v1.0.0 

func (x *GetSecretRequest) ProtoReflect() protoreflect.Message

func (*GetSecretRequest) Reset 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String 

func (x *GetSecretRequest) String() string

type GetSecretResponse 

type GetSecretResponse struct {

	// data is the secret value. Some secret store, such as kubernetes secret
	// store, can save multiple secrets for single secret key.
	Data map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetSecretResponse is the response message to convey the requested secret.

func (*GetSecretResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetData 

func (x *GetSecretResponse) GetData() map[string]string

func (*GetSecretResponse) ProtoMessage 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect added in v1.0.0 

func (x *GetSecretResponse) ProtoReflect() protoreflect.Message

func (*GetSecretResponse) Reset 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String 

func (x *GetSecretResponse) String() string

type GetStateRequest 

type GetStateRequest struct {

	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The key of the desired state
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The read consistency of the state store.
	Consistency v1.StateOptions_StateConsistency `` /* 132-byte string literal not displayed */
	// The metadata which will be sent to state store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetStateRequest is the message to get key-value states from specific state store.

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) GetConsistency 

func (x *GetStateRequest) GetConsistency() v1.StateOptions_StateConsistency

func (*GetStateRequest) GetKey 

func (x *GetStateRequest) GetKey() string

func (*GetStateRequest) GetMetadata added in v0.11.0 

func (x *GetStateRequest) GetMetadata() map[string]string

func (*GetStateRequest) GetStoreName 

func (x *GetStateRequest) GetStoreName() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect added in v1.0.0 

func (x *GetStateRequest) ProtoReflect() protoreflect.Message

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {

	// The byte array data
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The entity tag which represents the specific version of data.
	// ETag format is defined by the corresponding data store.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// The metadata which will be sent to app.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetStateResponse is the response conveying the state value and etag.

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetData 

func (x *GetStateResponse) GetData() []byte

func (*GetStateResponse) GetEtag 

func (x *GetStateResponse) GetEtag() string

func (*GetStateResponse) GetMetadata added in v1.0.0 

func (x *GetStateResponse) GetMetadata() map[string]string

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect added in v1.0.0 

func (x *GetStateResponse) ProtoReflect() protoreflect.Message

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type InvokeActorRequest added in v1.0.0 

type InvokeActorRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Method    string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Data      []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

InvokeActorRequest is the message to call an actor.

func (*InvokeActorRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use InvokeActorRequest.ProtoReflect.Descriptor instead.

func (*InvokeActorRequest) GetActorId added in v1.0.0 

func (x *InvokeActorRequest) GetActorId() string

func (*InvokeActorRequest) GetActorType added in v1.0.0 

func (x *InvokeActorRequest) GetActorType() string

func (*InvokeActorRequest) GetData added in v1.0.0 

func (x *InvokeActorRequest) GetData() []byte

func (*InvokeActorRequest) GetMethod added in v1.0.0 

func (x *InvokeActorRequest) GetMethod() string

func (*InvokeActorRequest) ProtoMessage added in v1.0.0 

func (*InvokeActorRequest) ProtoMessage()

func (*InvokeActorRequest) ProtoReflect added in v1.0.0 

func (x *InvokeActorRequest) ProtoReflect() protoreflect.Message

func (*InvokeActorRequest) Reset added in v1.0.0 

func (x *InvokeActorRequest) Reset()

func (*InvokeActorRequest) String added in v1.0.0 

func (x *InvokeActorRequest) String() string

type InvokeActorResponse added in v1.0.0 

type InvokeActorResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

InvokeActorResponse is the method that returns an actor invocation response.

func (*InvokeActorResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use InvokeActorResponse.ProtoReflect.Descriptor instead.

func (*InvokeActorResponse) GetData added in v1.0.0 

func (x *InvokeActorResponse) GetData() []byte

func (*InvokeActorResponse) ProtoMessage added in v1.0.0 

func (*InvokeActorResponse) ProtoMessage()

func (*InvokeActorResponse) ProtoReflect added in v1.0.0 

func (x *InvokeActorResponse) ProtoReflect() protoreflect.Message

func (*InvokeActorResponse) Reset added in v1.0.0 

func (x *InvokeActorResponse) Reset()

func (*InvokeActorResponse) String added in v1.0.0 

func (x *InvokeActorResponse) String() string

type InvokeBindingRequest 

type InvokeBindingRequest struct {

	// The name of the output binding to invoke.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The data which will be sent to output binding.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata passing to output binding components
	//
	// Common metadata property:
	// - ttlInSeconds : the time to live in seconds for the message.
	// If set in the binding definition will cause all messages to
	// have a default time to live. The message ttl overrides any value
	// in the binding definition.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The name of the operation type for the binding to invoke
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

InvokeBindingRequest is the message to send data to output bindings

func (*InvokeBindingRequest) Descriptor deprecated 

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

Deprecated: Use InvokeBindingRequest.ProtoReflect.Descriptor instead.

func (*InvokeBindingRequest) GetData 

func (x *InvokeBindingRequest) GetData() []byte

func (*InvokeBindingRequest) GetMetadata 

func (x *InvokeBindingRequest) GetMetadata() map[string]string

func (*InvokeBindingRequest) GetName 

func (x *InvokeBindingRequest) GetName() string

func (*InvokeBindingRequest) GetOperation 

func (x *InvokeBindingRequest) GetOperation() string

func (*InvokeBindingRequest) ProtoMessage 

func (*InvokeBindingRequest) ProtoMessage()

func (*InvokeBindingRequest) ProtoReflect added in v1.0.0 

func (x *InvokeBindingRequest) ProtoReflect() protoreflect.Message

func (*InvokeBindingRequest) Reset 

func (x *InvokeBindingRequest) Reset()

func (*InvokeBindingRequest) String 

func (x *InvokeBindingRequest) String() string

type InvokeBindingResponse 

type InvokeBindingResponse struct {

	// The data which will be sent to output binding.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata returned from an external system
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

InvokeBindingResponse is the message returned from an output binding invocation

func (*InvokeBindingResponse) Descriptor deprecated 

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

Deprecated: Use InvokeBindingResponse.ProtoReflect.Descriptor instead.

func (*InvokeBindingResponse) GetData 

func (x *InvokeBindingResponse) GetData() []byte

func (*InvokeBindingResponse) GetMetadata 

func (x *InvokeBindingResponse) GetMetadata() map[string]string

func (*InvokeBindingResponse) ProtoMessage 

func (*InvokeBindingResponse) ProtoMessage()

func (*InvokeBindingResponse) ProtoReflect added in v1.0.0 

func (x *InvokeBindingResponse) ProtoReflect() protoreflect.Message

func (*InvokeBindingResponse) Reset 

func (x *InvokeBindingResponse) Reset()

func (*InvokeBindingResponse) String 

func (x *InvokeBindingResponse) String() string

type InvokeServiceRequest 

type InvokeServiceRequest struct {

	// Required. Callee's app id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required. message which will be delivered to callee.
	Message *v1.InvokeRequest `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

InvokeServiceRequest represents the request message for Service invocation.

func (*InvokeServiceRequest) Descriptor deprecated 

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

Deprecated: Use InvokeServiceRequest.ProtoReflect.Descriptor instead.

func (*InvokeServiceRequest) GetId 

func (x *InvokeServiceRequest) GetId() string

func (*InvokeServiceRequest) GetMessage 

func (x *InvokeServiceRequest) GetMessage() *v1.InvokeRequest

func (*InvokeServiceRequest) ProtoMessage 

func (*InvokeServiceRequest) ProtoMessage()

func (*InvokeServiceRequest) ProtoReflect added in v1.0.0 

func (x *InvokeServiceRequest) ProtoReflect() protoreflect.Message

func (*InvokeServiceRequest) Reset 

func (x *InvokeServiceRequest) Reset()

func (*InvokeServiceRequest) String 

func (x *InvokeServiceRequest) String() string

type ListInputBindingsResponse 

type ListInputBindingsResponse struct {

	// The list of input bindings.
	Bindings []string `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"`
	// contains filtered or unexported fields
}

ListInputBindingsResponse is the message including the list of input bindings.

func (*ListInputBindingsResponse) Descriptor deprecated 

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

Deprecated: Use ListInputBindingsResponse.ProtoReflect.Descriptor instead.

func (*ListInputBindingsResponse) GetBindings 

func (x *ListInputBindingsResponse) GetBindings() []string

func (*ListInputBindingsResponse) ProtoMessage 

func (*ListInputBindingsResponse) ProtoMessage()

func (*ListInputBindingsResponse) ProtoReflect added in v1.0.0 

func (x *ListInputBindingsResponse) ProtoReflect() protoreflect.Message

func (*ListInputBindingsResponse) Reset 

func (x *ListInputBindingsResponse) Reset()

func (*ListInputBindingsResponse) String 

func (x *ListInputBindingsResponse) String() string

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {

	// The list of topics.
	Subscriptions []*TopicSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ListTopicSubscriptionsResponse is the message including the list of the subscribing topics.

func (*ListTopicSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

func (x *ListTopicSubscriptionsResponse) GetSubscriptions() []*TopicSubscription

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect added in v1.0.0 

func (x *ListTopicSubscriptionsResponse) ProtoReflect() protoreflect.Message

func (*ListTopicSubscriptionsResponse) Reset 

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (x *ListTopicSubscriptionsResponse) String() string

type PublishEventRequest 

type PublishEventRequest struct {

	// The name of the pubsub component
	PubsubName string `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// The pubsub topic
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The data which will be published to topic.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// The content type for the data (optional).
	DataContentType string `protobuf:"bytes,4,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	// The metadata passing to pub components
	//
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

PublishEventRequest is the message to publish event data to pubsub topic

func (*PublishEventRequest) Descriptor deprecated 

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetData 

func (x *PublishEventRequest) GetData() []byte

func (*PublishEventRequest) GetDataContentType added in v1.0.0 

func (x *PublishEventRequest) GetDataContentType() string

func (*PublishEventRequest) GetMetadata added in v1.0.0 

func (x *PublishEventRequest) GetMetadata() map[string]string

func (*PublishEventRequest) GetPubsubName added in v0.10.0 

func (x *PublishEventRequest) GetPubsubName() string

func (*PublishEventRequest) GetTopic 

func (x *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect added in v1.0.0 

func (x *PublishEventRequest) ProtoReflect() protoreflect.Message

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type RegisterActorReminderRequest added in v1.0.0 

type RegisterActorReminderRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	DueTime   string `protobuf:"bytes,4,opt,name=due_time,json=dueTime,proto3" json:"due_time,omitempty"`
	Period    string `protobuf:"bytes,5,opt,name=period,proto3" json:"period,omitempty"`
	Data      []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

RegisterActorReminderRequest is the message to register a reminder for an actor of a given type and id.

func (*RegisterActorReminderRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RegisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorReminderRequest) GetActorId added in v1.0.0 

func (x *RegisterActorReminderRequest) GetActorId() string

func (*RegisterActorReminderRequest) GetActorType added in v1.0.0 

func (x *RegisterActorReminderRequest) GetActorType() string

func (*RegisterActorReminderRequest) GetData added in v1.0.0 

func (x *RegisterActorReminderRequest) GetData() []byte

func (*RegisterActorReminderRequest) GetDueTime added in v1.0.0 

func (x *RegisterActorReminderRequest) GetDueTime() string

func (*RegisterActorReminderRequest) GetName added in v1.0.0 

func (x *RegisterActorReminderRequest) GetName() string

func (*RegisterActorReminderRequest) GetPeriod added in v1.0.0 

func (x *RegisterActorReminderRequest) GetPeriod() string

func (*RegisterActorReminderRequest) ProtoMessage added in v1.0.0 

func (*RegisterActorReminderRequest) ProtoMessage()

func (*RegisterActorReminderRequest) ProtoReflect added in v1.0.0 

func (x *RegisterActorReminderRequest) ProtoReflect() protoreflect.Message

func (*RegisterActorReminderRequest) Reset added in v1.0.0 

func (x *RegisterActorReminderRequest) Reset()

func (*RegisterActorReminderRequest) String added in v1.0.0 

func (x *RegisterActorReminderRequest) String() string

type RegisterActorTimerRequest added in v1.0.0 

type RegisterActorTimerRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	DueTime   string `protobuf:"bytes,4,opt,name=due_time,json=dueTime,proto3" json:"due_time,omitempty"`
	Period    string `protobuf:"bytes,5,opt,name=period,proto3" json:"period,omitempty"`
	Callback  string `protobuf:"bytes,6,opt,name=callback,proto3" json:"callback,omitempty"`
	Data      []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

RegisterActorTimerRequest is the message to register a timer for an actor of a given type and id.

func (*RegisterActorTimerRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RegisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorTimerRequest) GetActorId added in v1.0.0 

func (x *RegisterActorTimerRequest) GetActorId() string

func (*RegisterActorTimerRequest) GetActorType added in v1.0.0 

func (x *RegisterActorTimerRequest) GetActorType() string

func (*RegisterActorTimerRequest) GetCallback added in v1.0.0 

func (x *RegisterActorTimerRequest) GetCallback() string

func (*RegisterActorTimerRequest) GetData added in v1.0.0 

func (x *RegisterActorTimerRequest) GetData() []byte

func (*RegisterActorTimerRequest) GetDueTime added in v1.0.0 

func (x *RegisterActorTimerRequest) GetDueTime() string

func (*RegisterActorTimerRequest) GetName added in v1.0.0 

func (x *RegisterActorTimerRequest) GetName() string

func (*RegisterActorTimerRequest) GetPeriod added in v1.0.0 

func (x *RegisterActorTimerRequest) GetPeriod() string

func (*RegisterActorTimerRequest) ProtoMessage added in v1.0.0 

func (*RegisterActorTimerRequest) ProtoMessage()

func (*RegisterActorTimerRequest) ProtoReflect added in v1.0.0 

func (x *RegisterActorTimerRequest) ProtoReflect() protoreflect.Message

func (*RegisterActorTimerRequest) Reset added in v1.0.0 

func (x *RegisterActorTimerRequest) Reset()

func (*RegisterActorTimerRequest) String added in v1.0.0 

func (x *RegisterActorTimerRequest) String() string

type RegisteredComponents added in v1.0.0 

type RegisteredComponents struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type    string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisteredComponents) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RegisteredComponents.ProtoReflect.Descriptor instead.

func (*RegisteredComponents) GetName added in v1.0.0 

func (x *RegisteredComponents) GetName() string

func (*RegisteredComponents) GetType added in v1.0.0 

func (x *RegisteredComponents) GetType() string

func (*RegisteredComponents) GetVersion added in v1.0.0 

func (x *RegisteredComponents) GetVersion() string

func (*RegisteredComponents) ProtoMessage added in v1.0.0 

func (*RegisteredComponents) ProtoMessage()

func (*RegisteredComponents) ProtoReflect added in v1.0.0 

func (x *RegisteredComponents) ProtoReflect() protoreflect.Message

func (*RegisteredComponents) Reset added in v1.0.0 

func (x *RegisteredComponents) Reset()

func (*RegisteredComponents) String added in v1.0.0 

func (x *RegisteredComponents) String() string

type SaveStateRequest 

type SaveStateRequest struct {

	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The array of the state key values.
	States []*v1.StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

SaveStateRequest is the message to save multiple states into state store.

func (*SaveStateRequest) Descriptor deprecated 

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

Deprecated: Use SaveStateRequest.ProtoReflect.Descriptor instead.

func (*SaveStateRequest) GetStates 

func (x *SaveStateRequest) GetStates() []*v1.StateItem

func (*SaveStateRequest) GetStoreName 

func (x *SaveStateRequest) GetStoreName() string

func (*SaveStateRequest) ProtoMessage 

func (*SaveStateRequest) ProtoMessage()

func (*SaveStateRequest) ProtoReflect added in v1.0.0 

func (x *SaveStateRequest) ProtoReflect() protoreflect.Message

func (*SaveStateRequest) Reset 

func (x *SaveStateRequest) Reset()

func (*SaveStateRequest) String 

func (x *SaveStateRequest) String() string

type SecretResponse added in v1.0.0 

type SecretResponse struct {
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

SecretResponse is a map of decrypted string/string values

func (*SecretResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SecretResponse.ProtoReflect.Descriptor instead.

func (*SecretResponse) GetSecrets added in v1.0.0 

func (x *SecretResponse) GetSecrets() map[string]string

func (*SecretResponse) ProtoMessage added in v1.0.0 

func (*SecretResponse) ProtoMessage()

func (*SecretResponse) ProtoReflect added in v1.0.0 

func (x *SecretResponse) ProtoReflect() protoreflect.Message

func (*SecretResponse) Reset added in v1.0.0 

func (x *SecretResponse) Reset()

func (*SecretResponse) String added in v1.0.0 

func (x *SecretResponse) String() string

type SetMetadataRequest added in v1.0.0 

type SetMetadataRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetMetadataRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SetMetadataRequest.ProtoReflect.Descriptor instead.

func (*SetMetadataRequest) GetKey added in v1.0.0 

func (x *SetMetadataRequest) GetKey() string

func (*SetMetadataRequest) GetValue added in v1.0.0 

func (x *SetMetadataRequest) GetValue() string

func (*SetMetadataRequest) ProtoMessage added in v1.0.0 

func (*SetMetadataRequest) ProtoMessage()

func (*SetMetadataRequest) ProtoReflect added in v1.0.0 

func (x *SetMetadataRequest) ProtoReflect() protoreflect.Message

func (*SetMetadataRequest) Reset added in v1.0.0 

func (x *SetMetadataRequest) Reset()

func (*SetMetadataRequest) String added in v1.0.0 

func (x *SetMetadataRequest) String() string

type TopicEventRequest 

type TopicEventRequest struct {

	// id identifies the event. Producers MUST ensure that source + id
	// is unique for each distinct event. If a duplicate event is re-sent
	// (e.g. due to a network error) it MAY have the same id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// source identifies the context in which an event happened.
	// Often this will include information such as the type of the
	// event source, the organization publishing the event or the process
	// that produced the event. The exact syntax and semantics behind
	// the data encoded in the URI is defined by the event producer.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// The type of event related to the originating occurrence.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The version of the CloudEvents specification.
	SpecVersion string `protobuf:"bytes,4,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	// The content type of data value.
	DataContentType string `protobuf:"bytes,5,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	// The content of the event.
	Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// The pubsub topic which publisher sent to.
	Topic string `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"`
	// The name of the pubsub the publisher sent to.
	PubsubName string `protobuf:"bytes,8,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// contains filtered or unexported fields
}

TopicEventRequest message is compatible with CloudEvent spec v1.0 https://github.com/cloudevents/spec/blob/v1.0/spec.md

func (*TopicEventRequest) Descriptor deprecated 

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

Deprecated: Use TopicEventRequest.ProtoReflect.Descriptor instead.

func (*TopicEventRequest) GetData 

func (x *TopicEventRequest) GetData() []byte

func (*TopicEventRequest) GetDataContentType 

func (x *TopicEventRequest) GetDataContentType() string

func (*TopicEventRequest) GetId 

func (x *TopicEventRequest) GetId() string

func (*TopicEventRequest) GetPubsubName added in v0.10.0 

func (x *TopicEventRequest) GetPubsubName() string

func (*TopicEventRequest) GetSource 

func (x *TopicEventRequest) GetSource() string

func (*TopicEventRequest) GetSpecVersion 

func (x *TopicEventRequest) GetSpecVersion() string

func (*TopicEventRequest) GetTopic 

func (x *TopicEventRequest) GetTopic() string

func (*TopicEventRequest) GetType 

func (x *TopicEventRequest) GetType() string

func (*TopicEventRequest) ProtoMessage 

func (*TopicEventRequest) ProtoMessage()

func (*TopicEventRequest) ProtoReflect added in v1.0.0 

func (x *TopicEventRequest) ProtoReflect() protoreflect.Message

func (*TopicEventRequest) Reset 

func (x *TopicEventRequest) Reset()

func (*TopicEventRequest) String 

func (x *TopicEventRequest) String() string

type TopicEventResponse added in v0.10.0 

type TopicEventResponse struct {

	// The list of output bindings.
	Status TopicEventResponse_TopicEventResponseStatus `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicEventResponse is response from app on published message

func (*TopicEventResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.

func (*TopicEventResponse) GetStatus added in v0.11.0 

func (x *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventResponse) ProtoMessage added in v0.10.0 

func (*TopicEventResponse) ProtoMessage()

func (*TopicEventResponse) ProtoReflect added in v1.0.0 

func (x *TopicEventResponse) ProtoReflect() protoreflect.Message

func (*TopicEventResponse) Reset added in v0.10.0 

func (x *TopicEventResponse) Reset()

func (*TopicEventResponse) String added in v0.10.0 

func (x *TopicEventResponse) String() string

type TopicEventResponse_TopicEventResponseStatus added in v0.11.0 

type TopicEventResponse_TopicEventResponseStatus int32

TopicEventResponseStatus allows apps to have finer control over handling of the message. 

const (
	// SUCCESS is the default behavior: message is acknowledged and not retried or logged.
	TopicEventResponse_SUCCESS TopicEventResponse_TopicEventResponseStatus = 0
	// RETRY status signals Dapr to retry the message as part of an expected scenario (no warning is logged).
	TopicEventResponse_RETRY TopicEventResponse_TopicEventResponseStatus = 1
	// DROP status signals Dapr to drop the message as part of an unexpected scenario (warning is logged).
	TopicEventResponse_DROP TopicEventResponse_TopicEventResponseStatus = 2
)

func (TopicEventResponse_TopicEventResponseStatus) Descriptor added in v1.0.0 

func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (TopicEventResponse_TopicEventResponseStatus) Enum added in v1.0.0 

func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

func (TopicEventResponse_TopicEventResponseStatus) EnumDescriptor deprecated added in v0.11.0 

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

Deprecated: Use TopicEventResponse_TopicEventResponseStatus.Descriptor instead.

func (TopicEventResponse_TopicEventResponseStatus) Number added in v1.0.0 

func (x TopicEventResponse_TopicEventResponseStatus) Number() protoreflect.EnumNumber

func (TopicEventResponse_TopicEventResponseStatus) String added in v0.11.0 

func (x TopicEventResponse_TopicEventResponseStatus) String() string

func (TopicEventResponse_TopicEventResponseStatus) Type added in v1.0.0 

func (TopicEventResponse_TopicEventResponseStatus) Type() protoreflect.EnumType

type TopicSubscription 

type TopicSubscription struct {

	// Required. The name of the pubsub containing the topic below to subscribe to.
	PubsubName string `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// Required. The name of topic which will be subscribed
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The optional properties used for this topic's subscription e.g. session id
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicSubscription represents topic and metadata.

func (*TopicSubscription) Descriptor deprecated 

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

Deprecated: Use TopicSubscription.ProtoReflect.Descriptor instead.

func (*TopicSubscription) GetMetadata 

func (x *TopicSubscription) GetMetadata() map[string]string

func (*TopicSubscription) GetPubsubName added in v0.10.0 

func (x *TopicSubscription) GetPubsubName() string

func (*TopicSubscription) GetTopic 

func (x *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage 

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect added in v1.0.0 

func (x *TopicSubscription) ProtoReflect() protoreflect.Message

func (*TopicSubscription) Reset 

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String 

func (x *TopicSubscription) String() string

type TransactionalActorStateOperation added in v1.0.0 

type TransactionalActorStateOperation struct {
	OperationType string     `protobuf:"bytes,1,opt,name=operationType,proto3" json:"operationType,omitempty"`
	Key           string     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value         *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

TransactionalAcorStateOperation is the message to execute a specified operation with a key-value pair.

func (*TransactionalActorStateOperation) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use TransactionalActorStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalActorStateOperation) GetKey added in v1.0.0 

func (x *TransactionalActorStateOperation) GetKey() string

func (*TransactionalActorStateOperation) GetOperationType added in v1.0.0 

func (x *TransactionalActorStateOperation) GetOperationType() string

func (*TransactionalActorStateOperation) GetValue added in v1.0.0 

func (x *TransactionalActorStateOperation) GetValue() *anypb.Any

func (*TransactionalActorStateOperation) ProtoMessage added in v1.0.0 

func (*TransactionalActorStateOperation) ProtoMessage()

func (*TransactionalActorStateOperation) ProtoReflect added in v1.0.0 

func (x *TransactionalActorStateOperation) ProtoReflect() protoreflect.Message

func (*TransactionalActorStateOperation) Reset added in v1.0.0 

func (x *TransactionalActorStateOperation) Reset()

func (*TransactionalActorStateOperation) String added in v1.0.0 

func (x *TransactionalActorStateOperation) String() string

type TransactionalStateOperation added in v0.10.0 

type TransactionalStateOperation struct {

	// The type of operation to be executed
	OperationType string `protobuf:"bytes,1,opt,name=operationType,proto3" json:"operationType,omitempty"`
	// State values to be operated on
	Request *v1.StateItem `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

TransactionalStateOperation is the message to execute a specified operation with a key-value pair.

func (*TransactionalStateOperation) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use TransactionalStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalStateOperation) GetOperationType added in v0.10.0 

func (x *TransactionalStateOperation) GetOperationType() string

func (*TransactionalStateOperation) GetRequest added in v0.10.0 

func (x *TransactionalStateOperation) GetRequest() *v1.StateItem

func (*TransactionalStateOperation) ProtoMessage added in v0.10.0 

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect added in v1.0.0 

func (x *TransactionalStateOperation) ProtoReflect() protoreflect.Message

func (*TransactionalStateOperation) Reset added in v0.10.0 

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String added in v0.10.0 

func (x *TransactionalStateOperation) String() string

type UnimplementedAppCallbackServer 

type UnimplementedAppCallbackServer struct {
}

UnimplementedAppCallbackServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackServer) ListInputBindings 

func (UnimplementedAppCallbackServer) ListInputBindings(context.Context, *emptypb.Empty) (*ListInputBindingsResponse, error)

func (UnimplementedAppCallbackServer) ListTopicSubscriptions 

func (UnimplementedAppCallbackServer) ListTopicSubscriptions(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)

func (UnimplementedAppCallbackServer) OnBindingEvent 

func (UnimplementedAppCallbackServer) OnBindingEvent(context.Context, *BindingEventRequest) (*BindingEventResponse, error)

func (UnimplementedAppCallbackServer) OnInvoke 

func (UnimplementedAppCallbackServer) OnInvoke(context.Context, *v1.InvokeRequest) (*v1.InvokeResponse, error)

func (UnimplementedAppCallbackServer) OnTopicEvent 

func (UnimplementedAppCallbackServer) OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error)

type UnimplementedDaprServer 

type UnimplementedDaprServer struct {
}

UnimplementedDaprServer should be embedded to have forward compatible implementations.

func (UnimplementedDaprServer) DeleteBulkState added in v1.0.0 

func (UnimplementedDaprServer) DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) DeleteState 

func (UnimplementedDaprServer) DeleteState(context.Context, *DeleteStateRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) ExecuteActorStateTransaction added in v1.0.0 

func (UnimplementedDaprServer) ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) ExecuteStateTransaction added in v0.10.0 

func (UnimplementedDaprServer) ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) GetActorState added in v1.0.0 

func (UnimplementedDaprServer) GetActorState(context.Context, *GetActorStateRequest) (*GetActorStateResponse, error)

func (UnimplementedDaprServer) GetBulkSecret added in v1.0.0 

func (UnimplementedDaprServer) GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error)

func (UnimplementedDaprServer) GetBulkState added in v0.10.0 

func (UnimplementedDaprServer) GetBulkState(context.Context, *GetBulkStateRequest) (*GetBulkStateResponse, error)

func (UnimplementedDaprServer) GetMetadata added in v1.0.0 

func (UnimplementedDaprServer) GetMetadata(context.Context, *emptypb.Empty) (*GetMetadataResponse, error)

func (UnimplementedDaprServer) GetSecret 

func (UnimplementedDaprServer) GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)

func (UnimplementedDaprServer) GetState 

func (UnimplementedDaprServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)

func (UnimplementedDaprServer) InvokeActor added in v1.0.0 

func (UnimplementedDaprServer) InvokeActor(context.Context, *InvokeActorRequest) (*InvokeActorResponse, error)

func (UnimplementedDaprServer) InvokeBinding 

func (UnimplementedDaprServer) InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)

func (UnimplementedDaprServer) InvokeService 

func (UnimplementedDaprServer) InvokeService(context.Context, *InvokeServiceRequest) (*v1.InvokeResponse, error)

func (UnimplementedDaprServer) PublishEvent 

func (UnimplementedDaprServer) PublishEvent(context.Context, *PublishEventRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) RegisterActorReminder added in v1.0.0 

func (UnimplementedDaprServer) RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) RegisterActorTimer added in v1.0.0 

func (UnimplementedDaprServer) RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) SaveState 

func (UnimplementedDaprServer) SaveState(context.Context, *SaveStateRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) SetMetadata added in v1.0.0 

func (UnimplementedDaprServer) SetMetadata(context.Context, *SetMetadataRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) Shutdown added in v1.1.0 

func (UnimplementedDaprServer) Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedDaprServer) UnregisterActorReminder added in v1.0.0 

func (UnimplementedDaprServer) UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*emptypb.Empty, error)

func (UnimplementedDaprServer) UnregisterActorTimer added in v1.0.0 

func (UnimplementedDaprServer) UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*emptypb.Empty, error)

type UnregisterActorReminderRequest added in v1.0.0 

type UnregisterActorReminderRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

UnregisterActorReminderRequest is the message to unregister an actor reminder.

func (*UnregisterActorReminderRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use UnregisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorReminderRequest) GetActorId added in v1.0.0 

func (x *UnregisterActorReminderRequest) GetActorId() string

func (*UnregisterActorReminderRequest) GetActorType added in v1.0.0 

func (x *UnregisterActorReminderRequest) GetActorType() string

func (*UnregisterActorReminderRequest) GetName added in v1.0.0 

func (x *UnregisterActorReminderRequest) GetName() string

func (*UnregisterActorReminderRequest) ProtoMessage added in v1.0.0 

func (*UnregisterActorReminderRequest) ProtoMessage()

func (*UnregisterActorReminderRequest) ProtoReflect added in v1.0.0 

func (x *UnregisterActorReminderRequest) ProtoReflect() protoreflect.Message

func (*UnregisterActorReminderRequest) Reset added in v1.0.0 

func (x *UnregisterActorReminderRequest) Reset()

func (*UnregisterActorReminderRequest) String added in v1.0.0 

func (x *UnregisterActorReminderRequest) String() string

type UnregisterActorTimerRequest added in v1.0.0 

type UnregisterActorTimerRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

UnregisterActorTimerRequest is the message to unregister an actor timer

func (*UnregisterActorTimerRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use UnregisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorTimerRequest) GetActorId added in v1.0.0 

func (x *UnregisterActorTimerRequest) GetActorId() string

func (*UnregisterActorTimerRequest) GetActorType added in v1.0.0 

func (x *UnregisterActorTimerRequest) GetActorType() string

func (*UnregisterActorTimerRequest) GetName added in v1.0.0 

func (x *UnregisterActorTimerRequest) GetName() string

func (*UnregisterActorTimerRequest) ProtoMessage added in v1.0.0 

func (*UnregisterActorTimerRequest) ProtoMessage()

func (*UnregisterActorTimerRequest) ProtoReflect added in v1.0.0 

func (x *UnregisterActorTimerRequest) ProtoReflect() protoreflect.Message

func (*UnregisterActorTimerRequest) Reset added in v1.0.0 

func (x *UnregisterActorTimerRequest) Reset()

func (*UnregisterActorTimerRequest) String added in v1.0.0 

func (x *UnregisterActorTimerRequest) String() string

type UnsafeAppCallbackServer added in v1.0.0 

type UnsafeAppCallbackServer interface {
	// contains filtered or unexported methods
}

UnsafeAppCallbackServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AppCallbackServer will result in compilation errors.

type UnsafeDaprServer added in v1.0.0 

type UnsafeDaprServer interface {
	// contains filtered or unexported methods
}

UnsafeDaprServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DaprServer will result in compilation errors.

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.