runtime

package
v1.0.1-0...-f351835 Latest Latest
Warning

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

 Go to latest Published: Mar 23, 2021 License: MIT Imports: 12 Imported by: 0

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 

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 

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

Deprecated: Use ActiveActorsCount.ProtoReflect.Descriptor instead.

func (*ActiveActorsCount) GetCount 

func (x *ActiveActorsCount) GetCount() int32

func (*ActiveActorsCount) GetType 

func (x *ActiveActorsCount) GetType() string

func (*ActiveActorsCount) ProtoMessage 

func (*ActiveActorsCount) ProtoMessage()

func (*ActiveActorsCount) ProtoReflect 

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

func (*ActiveActorsCount) Reset 

func (x *ActiveActorsCount) Reset()

func (*ActiveActorsCount) String 

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 *empty.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 *empty.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, *empty.Empty) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(context.Context, *empty.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 

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 

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 

func (BindingEventResponse_BindingEventConcurrency) Descriptor() protoreflect.EnumDescriptor

func (BindingEventResponse_BindingEventConcurrency) Enum 

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 

func (x BindingEventResponse_BindingEventConcurrency) Number() protoreflect.EnumNumber

func (BindingEventResponse_BindingEventConcurrency) String 

func (x BindingEventResponse_BindingEventConcurrency) String() string

func (BindingEventResponse_BindingEventConcurrency) Type 

func (BindingEventResponse_BindingEventConcurrency) Type() protoreflect.EnumType

type BulkStateItem 

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 

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

Deprecated: Use BulkStateItem.ProtoReflect.Descriptor instead.

func (*BulkStateItem) GetData 

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

func (*BulkStateItem) GetError 

func (x *BulkStateItem) GetError() string

func (*BulkStateItem) GetEtag 

func (x *BulkStateItem) GetEtag() string

func (*BulkStateItem) GetKey 

func (x *BulkStateItem) GetKey() string

func (*BulkStateItem) GetMetadata 

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

func (*BulkStateItem) ProtoMessage 

func (*BulkStateItem) ProtoMessage()

func (*BulkStateItem) ProtoReflect 

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

func (*BulkStateItem) Reset 

func (x *BulkStateItem) Reset()

func (*BulkStateItem) String 

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) (*empty.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Publishes events to the specific topic.
	PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*empty.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) (*empty.Empty, error)
	// Unregister an actor timer.
	UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Register an actor reminder.
	RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Unregister an actor reminder.
	UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*empty.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) (*empty.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 *empty.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Shutdown the sidecar
	Shutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.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) (*empty.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(context.Context, *DeleteStateRequest) (*empty.Empty, error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*empty.Empty, error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*empty.Empty, error)
	// Publishes events to the specific topic.
	PublishEvent(context.Context, *PublishEventRequest) (*empty.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) (*empty.Empty, error)
	// Unregister an actor timer.
	UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*empty.Empty, error)
	// Register an actor reminder.
	RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*empty.Empty, error)
	// Unregister an actor reminder.
	UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*empty.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) (*empty.Empty, error)
	// InvokeActor calls a method on an actor.
	InvokeActor(context.Context, *InvokeActorRequest) (*InvokeActorResponse, error)
	// Gets metadata of the sidecar
	GetMetadata(context.Context, *empty.Empty) (*GetMetadataResponse, error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(context.Context, *SetMetadataRequest) (*empty.Empty, error)
	// Shutdown the sidecar
	Shutdown(context.Context, *empty.Empty) (*empty.Empty, error)
}

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

type DeleteBulkStateRequest 

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 

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

Deprecated: Use DeleteBulkStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteBulkStateRequest) GetStates 

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

func (*DeleteBulkStateRequest) GetStoreName 

func (x *DeleteBulkStateRequest) GetStoreName() string

func (*DeleteBulkStateRequest) ProtoMessage 

func (*DeleteBulkStateRequest) ProtoMessage()

func (*DeleteBulkStateRequest) ProtoReflect 

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

func (*DeleteBulkStateRequest) Reset 

func (x *DeleteBulkStateRequest) Reset()

func (*DeleteBulkStateRequest) String 

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 

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 

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

func (*DeleteStateRequest) Reset 

func (x *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String 

func (x *DeleteStateRequest) String() string

type ExecuteActorStateTransactionRequest 

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 

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

Deprecated: Use ExecuteActorStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActorStateTransactionRequest) GetActorId 

func (x *ExecuteActorStateTransactionRequest) GetActorId() string

func (*ExecuteActorStateTransactionRequest) GetActorType 

func (x *ExecuteActorStateTransactionRequest) GetActorType() string

func (*ExecuteActorStateTransactionRequest) GetOperations 

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

func (*ExecuteActorStateTransactionRequest) ProtoMessage 

func (*ExecuteActorStateTransactionRequest) ProtoMessage()

func (*ExecuteActorStateTransactionRequest) ProtoReflect 

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

func (*ExecuteActorStateTransactionRequest) Reset 

func (x *ExecuteActorStateTransactionRequest) Reset()

func (*ExecuteActorStateTransactionRequest) String 

func (x *ExecuteActorStateTransactionRequest) String() string

type ExecuteStateTransactionRequest 

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 

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

Deprecated: Use ExecuteStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStateTransactionRequest) GetMetadata 

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

func (*ExecuteStateTransactionRequest) GetOperations 

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

func (*ExecuteStateTransactionRequest) GetStoreName 

func (x *ExecuteStateTransactionRequest) GetStoreName() string

func (*ExecuteStateTransactionRequest) ProtoMessage 

func (*ExecuteStateTransactionRequest) ProtoMessage()

func (*ExecuteStateTransactionRequest) ProtoReflect 

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

func (*ExecuteStateTransactionRequest) Reset 

func (x *ExecuteStateTransactionRequest) Reset()

func (*ExecuteStateTransactionRequest) String 

func (x *ExecuteStateTransactionRequest) String() string

type GetActorStateRequest 

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 

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

Deprecated: Use GetActorStateRequest.ProtoReflect.Descriptor instead.

func (*GetActorStateRequest) GetActorId 

func (x *GetActorStateRequest) GetActorId() string

func (*GetActorStateRequest) GetActorType 

func (x *GetActorStateRequest) GetActorType() string

func (*GetActorStateRequest) GetKey 

func (x *GetActorStateRequest) GetKey() string

func (*GetActorStateRequest) ProtoMessage 

func (*GetActorStateRequest) ProtoMessage()

func (*GetActorStateRequest) ProtoReflect 

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

func (*GetActorStateRequest) Reset 

func (x *GetActorStateRequest) Reset()

func (*GetActorStateRequest) String 

func (x *GetActorStateRequest) String() string

type GetActorStateResponse 

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 

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

Deprecated: Use GetActorStateResponse.ProtoReflect.Descriptor instead.

func (*GetActorStateResponse) GetData 

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

func (*GetActorStateResponse) ProtoMessage 

func (*GetActorStateResponse) ProtoMessage()

func (*GetActorStateResponse) ProtoReflect 

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

func (*GetActorStateResponse) Reset 

func (x *GetActorStateResponse) Reset()

func (*GetActorStateResponse) String 

func (x *GetActorStateResponse) String() string

type GetBulkSecretRequest 

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 

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

Deprecated: Use GetBulkSecretRequest.ProtoReflect.Descriptor instead.

func (*GetBulkSecretRequest) GetMetadata 

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

func (*GetBulkSecretRequest) GetStoreName 

func (x *GetBulkSecretRequest) GetStoreName() string

func (*GetBulkSecretRequest) ProtoMessage 

func (*GetBulkSecretRequest) ProtoMessage()

func (*GetBulkSecretRequest) ProtoReflect 

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

func (*GetBulkSecretRequest) Reset 

func (x *GetBulkSecretRequest) Reset()

func (*GetBulkSecretRequest) String 

func (x *GetBulkSecretRequest) String() string

type GetBulkSecretResponse 

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 

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

Deprecated: Use GetBulkSecretResponse.ProtoReflect.Descriptor instead.

func (*GetBulkSecretResponse) GetData 

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

func (*GetBulkSecretResponse) ProtoMessage 

func (*GetBulkSecretResponse) ProtoMessage()

func (*GetBulkSecretResponse) ProtoReflect 

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

func (*GetBulkSecretResponse) Reset 

func (x *GetBulkSecretResponse) Reset()

func (*GetBulkSecretResponse) String 

func (x *GetBulkSecretResponse) String() string

type GetBulkStateRequest 

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 

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

Deprecated: Use GetBulkStateRequest.ProtoReflect.Descriptor instead.

func (*GetBulkStateRequest) GetKeys 

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

func (*GetBulkStateRequest) GetMetadata 

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

func (*GetBulkStateRequest) GetParallelism 

func (x *GetBulkStateRequest) GetParallelism() int32

func (*GetBulkStateRequest) GetStoreName 

func (x *GetBulkStateRequest) GetStoreName() string

func (*GetBulkStateRequest) ProtoMessage 

func (*GetBulkStateRequest) ProtoMessage()

func (*GetBulkStateRequest) ProtoReflect 

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

func (*GetBulkStateRequest) Reset 

func (x *GetBulkStateRequest) Reset()

func (*GetBulkStateRequest) String 

func (x *GetBulkStateRequest) String() string

type GetBulkStateResponse 

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 

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

Deprecated: Use GetBulkStateResponse.ProtoReflect.Descriptor instead.

func (*GetBulkStateResponse) GetItems 

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

func (*GetBulkStateResponse) ProtoMessage 

func (*GetBulkStateResponse) ProtoMessage()

func (*GetBulkStateResponse) ProtoReflect 

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

func (*GetBulkStateResponse) Reset 

func (x *GetBulkStateResponse) Reset()

func (*GetBulkStateResponse) String 

func (x *GetBulkStateResponse) String() string

type GetMetadataResponse 

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 

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

Deprecated: Use GetMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetMetadataResponse) GetActiveActorsCount 

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

func (*GetMetadataResponse) GetExtendedMetadata 

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

func (*GetMetadataResponse) GetId 

func (x *GetMetadataResponse) GetId() string

func (*GetMetadataResponse) GetRegisteredComponents 

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

func (*GetMetadataResponse) ProtoMessage 

func (*GetMetadataResponse) ProtoMessage()

func (*GetMetadataResponse) ProtoReflect 

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

func (*GetMetadataResponse) Reset 

func (x *GetMetadataResponse) Reset()

func (*GetMetadataResponse) String 

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 

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 

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 

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

func (*GetStateRequest) GetStoreName 

func (x *GetStateRequest) GetStoreName() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

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 

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

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type InvokeActorRequest 

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 

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

Deprecated: Use InvokeActorRequest.ProtoReflect.Descriptor instead.

func (*InvokeActorRequest) GetActorId 

func (x *InvokeActorRequest) GetActorId() string

func (*InvokeActorRequest) GetActorType 

func (x *InvokeActorRequest) GetActorType() string

func (*InvokeActorRequest) GetData 

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

func (*InvokeActorRequest) GetMethod 

func (x *InvokeActorRequest) GetMethod() string

func (*InvokeActorRequest) ProtoMessage 

func (*InvokeActorRequest) ProtoMessage()

func (*InvokeActorRequest) ProtoReflect 

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

func (*InvokeActorRequest) Reset 

func (x *InvokeActorRequest) Reset()

func (*InvokeActorRequest) String 

func (x *InvokeActorRequest) String() string

type InvokeActorResponse 

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 

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

Deprecated: Use InvokeActorResponse.ProtoReflect.Descriptor instead.

func (*InvokeActorResponse) GetData 

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

func (*InvokeActorResponse) ProtoMessage 

func (*InvokeActorResponse) ProtoMessage()

func (*InvokeActorResponse) ProtoReflect 

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

func (*InvokeActorResponse) Reset 

func (x *InvokeActorResponse) Reset()

func (*InvokeActorResponse) String 

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 

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 

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 

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 

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 

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 

func (x *PublishEventRequest) GetDataContentType() string

func (*PublishEventRequest) GetMetadata 

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

func (*PublishEventRequest) GetPubsubName 

func (x *PublishEventRequest) GetPubsubName() string

func (*PublishEventRequest) GetTopic 

func (x *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect 

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

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type RegisterActorReminderRequest 

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 

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

Deprecated: Use RegisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorReminderRequest) GetActorId 

func (x *RegisterActorReminderRequest) GetActorId() string

func (*RegisterActorReminderRequest) GetActorType 

func (x *RegisterActorReminderRequest) GetActorType() string

func (*RegisterActorReminderRequest) GetData 

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

func (*RegisterActorReminderRequest) GetDueTime 

func (x *RegisterActorReminderRequest) GetDueTime() string

func (*RegisterActorReminderRequest) GetName 

func (x *RegisterActorReminderRequest) GetName() string

func (*RegisterActorReminderRequest) GetPeriod 

func (x *RegisterActorReminderRequest) GetPeriod() string

func (*RegisterActorReminderRequest) ProtoMessage 

func (*RegisterActorReminderRequest) ProtoMessage()

func (*RegisterActorReminderRequest) ProtoReflect 

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

func (*RegisterActorReminderRequest) Reset 

func (x *RegisterActorReminderRequest) Reset()

func (*RegisterActorReminderRequest) String 

func (x *RegisterActorReminderRequest) String() string

type RegisterActorTimerRequest 

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 

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

Deprecated: Use RegisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorTimerRequest) GetActorId 

func (x *RegisterActorTimerRequest) GetActorId() string

func (*RegisterActorTimerRequest) GetActorType 

func (x *RegisterActorTimerRequest) GetActorType() string

func (*RegisterActorTimerRequest) GetCallback 

func (x *RegisterActorTimerRequest) GetCallback() string

func (*RegisterActorTimerRequest) GetData 

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

func (*RegisterActorTimerRequest) GetDueTime 

func (x *RegisterActorTimerRequest) GetDueTime() string

func (*RegisterActorTimerRequest) GetName 

func (x *RegisterActorTimerRequest) GetName() string

func (*RegisterActorTimerRequest) GetPeriod 

func (x *RegisterActorTimerRequest) GetPeriod() string

func (*RegisterActorTimerRequest) ProtoMessage 

func (*RegisterActorTimerRequest) ProtoMessage()

func (*RegisterActorTimerRequest) ProtoReflect 

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

func (*RegisterActorTimerRequest) Reset 

func (x *RegisterActorTimerRequest) Reset()

func (*RegisterActorTimerRequest) String 

func (x *RegisterActorTimerRequest) String() string

type RegisteredComponents 

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 

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

Deprecated: Use RegisteredComponents.ProtoReflect.Descriptor instead.

func (*RegisteredComponents) GetName 

func (x *RegisteredComponents) GetName() string

func (*RegisteredComponents) GetType 

func (x *RegisteredComponents) GetType() string

func (*RegisteredComponents) GetVersion 

func (x *RegisteredComponents) GetVersion() string

func (*RegisteredComponents) ProtoMessage 

func (*RegisteredComponents) ProtoMessage()

func (*RegisteredComponents) ProtoReflect 

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

func (*RegisteredComponents) Reset 

func (x *RegisteredComponents) Reset()

func (*RegisteredComponents) String 

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 

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

func (*SaveStateRequest) Reset 

func (x *SaveStateRequest) Reset()

func (*SaveStateRequest) String 

func (x *SaveStateRequest) String() string

type SecretResponse 

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 

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

Deprecated: Use SecretResponse.ProtoReflect.Descriptor instead.

func (*SecretResponse) GetSecrets 

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

func (*SecretResponse) ProtoMessage 

func (*SecretResponse) ProtoMessage()

func (*SecretResponse) ProtoReflect 

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

func (*SecretResponse) Reset 

func (x *SecretResponse) Reset()

func (*SecretResponse) String 

func (x *SecretResponse) String() string

type SetMetadataRequest 

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 

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

Deprecated: Use SetMetadataRequest.ProtoReflect.Descriptor instead.

func (*SetMetadataRequest) GetKey 

func (x *SetMetadataRequest) GetKey() string

func (*SetMetadataRequest) GetValue 

func (x *SetMetadataRequest) GetValue() string

func (*SetMetadataRequest) ProtoMessage 

func (*SetMetadataRequest) ProtoMessage()

func (*SetMetadataRequest) ProtoReflect 

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

func (*SetMetadataRequest) Reset 

func (x *SetMetadataRequest) Reset()

func (*SetMetadataRequest) String 

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 

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 

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

func (*TopicEventRequest) Reset 

func (x *TopicEventRequest) Reset()

func (*TopicEventRequest) String 

func (x *TopicEventRequest) String() string

type TopicEventResponse 

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 

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

Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.

func (*TopicEventResponse) GetStatus 

func (x *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventResponse) ProtoMessage 

func (*TopicEventResponse) ProtoMessage()

func (*TopicEventResponse) ProtoReflect 

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

func (*TopicEventResponse) Reset 

func (x *TopicEventResponse) Reset()

func (*TopicEventResponse) String 

func (x *TopicEventResponse) String() string

type TopicEventResponse_TopicEventResponseStatus 

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 

func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (TopicEventResponse_TopicEventResponseStatus) Enum 

func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

func (TopicEventResponse_TopicEventResponseStatus) EnumDescriptor deprecated 

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

Deprecated: Use TopicEventResponse_TopicEventResponseStatus.Descriptor instead.

func (TopicEventResponse_TopicEventResponseStatus) Number 

func (x TopicEventResponse_TopicEventResponseStatus) Number() protoreflect.EnumNumber

func (TopicEventResponse_TopicEventResponseStatus) String 

func (x TopicEventResponse_TopicEventResponseStatus) String() string

func (TopicEventResponse_TopicEventResponseStatus) Type 

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 

func (x *TopicSubscription) GetPubsubName() string

func (*TopicSubscription) GetTopic 

func (x *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage 

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect 

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

func (*TopicSubscription) Reset 

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String 

func (x *TopicSubscription) String() string

type TransactionalActorStateOperation 

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         *any.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 

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

Deprecated: Use TransactionalActorStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalActorStateOperation) GetKey 

func (x *TransactionalActorStateOperation) GetKey() string

func (*TransactionalActorStateOperation) GetOperationType 

func (x *TransactionalActorStateOperation) GetOperationType() string

func (*TransactionalActorStateOperation) GetValue 

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

func (*TransactionalActorStateOperation) ProtoMessage 

func (*TransactionalActorStateOperation) ProtoMessage()

func (*TransactionalActorStateOperation) ProtoReflect 

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

func (*TransactionalActorStateOperation) Reset 

func (x *TransactionalActorStateOperation) Reset()

func (*TransactionalActorStateOperation) String 

func (x *TransactionalActorStateOperation) String() string

type TransactionalStateOperation 

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 

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

Deprecated: Use TransactionalStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalStateOperation) GetOperationType 

func (x *TransactionalStateOperation) GetOperationType() string

func (*TransactionalStateOperation) GetRequest 

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

func (*TransactionalStateOperation) ProtoMessage 

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect 

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

func (*TransactionalStateOperation) Reset 

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String 

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, *empty.Empty) (*ListInputBindingsResponse, error)

func (UnimplementedAppCallbackServer) ListTopicSubscriptions 

func (UnimplementedAppCallbackServer) ListTopicSubscriptions(context.Context, *empty.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 

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

func (UnimplementedDaprServer) DeleteState 

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

func (UnimplementedDaprServer) ExecuteActorStateTransaction 

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

func (UnimplementedDaprServer) ExecuteStateTransaction 

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

func (UnimplementedDaprServer) GetActorState 

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

func (UnimplementedDaprServer) GetBulkSecret 

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

func (UnimplementedDaprServer) GetBulkState 

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

func (UnimplementedDaprServer) GetMetadata 

func (UnimplementedDaprServer) GetMetadata(context.Context, *empty.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 

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) (*empty.Empty, error)

func (UnimplementedDaprServer) RegisterActorReminder 

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

func (UnimplementedDaprServer) RegisterActorTimer 

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

func (UnimplementedDaprServer) SaveState 

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

func (UnimplementedDaprServer) SetMetadata 

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

func (UnimplementedDaprServer) Shutdown 

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

func (UnimplementedDaprServer) UnregisterActorReminder 

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

func (UnimplementedDaprServer) UnregisterActorTimer 

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

type UnregisterActorReminderRequest 

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 

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

Deprecated: Use UnregisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorReminderRequest) GetActorId 

func (x *UnregisterActorReminderRequest) GetActorId() string

func (*UnregisterActorReminderRequest) GetActorType 

func (x *UnregisterActorReminderRequest) GetActorType() string

func (*UnregisterActorReminderRequest) GetName 

func (x *UnregisterActorReminderRequest) GetName() string

func (*UnregisterActorReminderRequest) ProtoMessage 

func (*UnregisterActorReminderRequest) ProtoMessage()

func (*UnregisterActorReminderRequest) ProtoReflect 

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

func (*UnregisterActorReminderRequest) Reset 

func (x *UnregisterActorReminderRequest) Reset()

func (*UnregisterActorReminderRequest) String 

func (x *UnregisterActorReminderRequest) String() string

type UnregisterActorTimerRequest 

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 

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

Deprecated: Use UnregisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorTimerRequest) GetActorId 

func (x *UnregisterActorTimerRequest) GetActorId() string

func (*UnregisterActorTimerRequest) GetActorType 

func (x *UnregisterActorTimerRequest) GetActorType() string

func (*UnregisterActorTimerRequest) GetName 

func (x *UnregisterActorTimerRequest) GetName() string

func (*UnregisterActorTimerRequest) ProtoMessage 

func (*UnregisterActorTimerRequest) ProtoMessage()

func (*UnregisterActorTimerRequest) ProtoReflect 

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

func (*UnregisterActorTimerRequest) Reset 

func (x *UnregisterActorTimerRequest) Reset()

func (*UnregisterActorTimerRequest) String 

func (x *UnregisterActorTimerRequest) String() string

type UnsafeAppCallbackServer 

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 

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.