runtime

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Nov 4, 2022 License: Apache-2.0 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: "QueryStateAlpha1",
			Handler:    _Dapr_QueryStateAlpha1_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: "GetConfigurationAlpha1",
			Handler:    _Dapr_GetConfigurationAlpha1_Handler,
		},
		{
			MethodName: "GetMetadata",
			Handler:    _Dapr_GetMetadata_Handler,
		},
		{
			MethodName: "SetMetadata",
			Handler:    _Dapr_SetMetadata_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Dapr_Shutdown_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeConfigurationAlpha1",
			Handler:       _Dapr_SubscribeConfigurationAlpha1_Handler,
			ServerStreams: true,
		},
	},
	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 *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.

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

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 (*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) Enum

func (BindingEventResponse_BindingEventConcurrency) EnumDescriptor deprecated

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

Deprecated: Use BindingEventResponse_BindingEventConcurrency.Descriptor instead.

func (BindingEventResponse_BindingEventConcurrency) Number

func (BindingEventResponse_BindingEventConcurrency) String

func (BindingEventResponse_BindingEventConcurrency) Type

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) (*emptypb.Empty, error)
	// Queries the state.
	QueryStateAlpha1(ctx context.Context, in *QueryStateRequest, opts ...grpc.CallOption) (*QueryStateResponse, 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)
	// GetConfiguration gets configuration from configuration store.
	GetConfigurationAlpha1(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfigurationAlpha1(ctx context.Context, in *SubscribeConfigurationRequest, opts ...grpc.CallOption) (Dapr_SubscribeConfigurationAlpha1Client, 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)
	// Queries the state.
	QueryStateAlpha1(context.Context, *QueryStateRequest) (*QueryStateResponse, 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)
	// GetConfiguration gets configuration from configuration store.
	GetConfigurationAlpha1(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfigurationAlpha1(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationAlpha1Server) 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 Dapr_SubscribeConfigurationAlpha1Client

type Dapr_SubscribeConfigurationAlpha1Client interface {
	Recv() (*SubscribeConfigurationResponse, error)
	grpc.ClientStream
}

type Dapr_SubscribeConfigurationAlpha1Server

type Dapr_SubscribeConfigurationAlpha1Server interface {
	Send(*SubscribeConfigurationResponse) error
	grpc.ServerStream
}

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 (*ExecuteActorStateTransactionRequest) GetActorType

func (x *ExecuteActorStateTransactionRequest) GetActorType() string

func (*ExecuteActorStateTransactionRequest) GetOperations

func (*ExecuteActorStateTransactionRequest) ProtoMessage

func (*ExecuteActorStateTransactionRequest) ProtoMessage()

func (*ExecuteActorStateTransactionRequest) ProtoReflect

func (*ExecuteActorStateTransactionRequest) Reset

func (*ExecuteActorStateTransactionRequest) 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 (*ExecuteStateTransactionRequest) GetStoreName

func (x *ExecuteStateTransactionRequest) GetStoreName() string

func (*ExecuteStateTransactionRequest) ProtoMessage

func (*ExecuteStateTransactionRequest) ProtoMessage()

func (*ExecuteStateTransactionRequest) ProtoReflect

func (*ExecuteStateTransactionRequest) Reset

func (x *ExecuteStateTransactionRequest) Reset()

func (*ExecuteStateTransactionRequest) 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 GetConfigurationRequest

type GetConfigurationRequest struct {

	// Required. The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Optional. The key of the configuration item to fetch.
	// If set, only query for the specified configuration items.
	// Empty list means fetch all.
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// Optional. The metadata which will be sent to configuration store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetConfigurationRequest is the message to get a list of key-value configuration from specified configuration store.

func (*GetConfigurationRequest) Descriptor deprecated

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetKeys

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

func (*GetConfigurationRequest) GetMetadata

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

func (*GetConfigurationRequest) GetStoreName

func (x *GetConfigurationRequest) GetStoreName() string

func (*GetConfigurationRequest) ProtoMessage

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect

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

func (*GetConfigurationRequest) Reset

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse

type GetConfigurationResponse struct {
	Items []*v1.ConfigurationItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

GetConfigurationResponse is the response conveying the list of configuration values. It should be the FULL configuration of specified application which contains all of its configuration items.

func (*GetConfigurationResponse) Descriptor deprecated

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetItems

func (*GetConfigurationResponse) ProtoMessage

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect

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

func (*GetConfigurationResponse) Reset

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String

func (x *GetConfigurationResponse) 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 (*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 (*ListTopicSubscriptionsResponse) Reset

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) 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 QueryStateItem

type QueryStateItem struct {

	// The object key.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The object value.
	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 message indicating an error in processing of the query result.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryStateItem) Descriptor deprecated

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

Deprecated: Use QueryStateItem.ProtoReflect.Descriptor instead.

func (*QueryStateItem) GetData

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

func (*QueryStateItem) GetError

func (x *QueryStateItem) GetError() string

func (*QueryStateItem) GetEtag

func (x *QueryStateItem) GetEtag() string

func (*QueryStateItem) GetKey

func (x *QueryStateItem) GetKey() string

func (*QueryStateItem) ProtoMessage

func (*QueryStateItem) ProtoMessage()

func (*QueryStateItem) ProtoReflect

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

func (*QueryStateItem) Reset

func (x *QueryStateItem) Reset()

func (*QueryStateItem) String

func (x *QueryStateItem) String() string

type QueryStateRequest

type QueryStateRequest struct {

	// The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The query in JSON format.
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,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
}

QueryStateRequest is the message to query state store.

func (*QueryStateRequest) Descriptor deprecated

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

Deprecated: Use QueryStateRequest.ProtoReflect.Descriptor instead.

func (*QueryStateRequest) GetMetadata

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

func (*QueryStateRequest) GetQuery

func (x *QueryStateRequest) GetQuery() string

func (*QueryStateRequest) GetStoreName

func (x *QueryStateRequest) GetStoreName() string

func (*QueryStateRequest) ProtoMessage

func (*QueryStateRequest) ProtoMessage()

func (*QueryStateRequest) ProtoReflect

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

func (*QueryStateRequest) Reset

func (x *QueryStateRequest) Reset()

func (*QueryStateRequest) String

func (x *QueryStateRequest) String() string

type QueryStateResponse

type QueryStateResponse struct {

	// An array of query results.
	Results []*QueryStateItem `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// Pagination token.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// The metadata which will be sent to app.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueryStateResponse is the response conveying the query results.

func (*QueryStateResponse) Descriptor deprecated

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

Deprecated: Use QueryStateResponse.ProtoReflect.Descriptor instead.

func (*QueryStateResponse) GetMetadata

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

func (*QueryStateResponse) GetResults

func (x *QueryStateResponse) GetResults() []*QueryStateItem

func (*QueryStateResponse) GetToken

func (x *QueryStateResponse) GetToken() string

func (*QueryStateResponse) ProtoMessage

func (*QueryStateResponse) ProtoMessage()

func (*QueryStateResponse) ProtoReflect

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

func (*QueryStateResponse) Reset

func (x *QueryStateResponse) Reset()

func (*QueryStateResponse) String

func (x *QueryStateResponse) 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"`
	Ttl       string `protobuf:"bytes,7,opt,name=ttl,proto3" json:"ttl,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) GetTtl

func (*RegisterActorReminderRequest) ProtoMessage

func (*RegisterActorReminderRequest) ProtoMessage()

func (*RegisterActorReminderRequest) ProtoReflect

func (*RegisterActorReminderRequest) Reset

func (x *RegisterActorReminderRequest) Reset()

func (*RegisterActorReminderRequest) 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"`
	Ttl       string `protobuf:"bytes,8,opt,name=ttl,proto3" json:"ttl,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) GetTtl

func (x *RegisterActorTimerRequest) GetTtl() string

func (*RegisterActorTimerRequest) ProtoMessage

func (*RegisterActorTimerRequest) ProtoMessage()

func (*RegisterActorTimerRequest) ProtoReflect

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 SubscribeConfigurationRequest

type SubscribeConfigurationRequest struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Optional. The key of the configuration item to fetch.
	// If set, only query for the specified configuration items.
	// Empty list means fetch all.
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// The metadata which will be sent to configuration store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

SubscribeConfigurationRequest is the message to get a list of key-value configuration from specified configuration store.

func (*SubscribeConfigurationRequest) Descriptor deprecated

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

Deprecated: Use SubscribeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationRequest) GetKeys

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

func (*SubscribeConfigurationRequest) GetMetadata

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

func (*SubscribeConfigurationRequest) GetStoreName

func (x *SubscribeConfigurationRequest) GetStoreName() string

func (*SubscribeConfigurationRequest) ProtoMessage

func (*SubscribeConfigurationRequest) ProtoMessage()

func (*SubscribeConfigurationRequest) ProtoReflect

func (*SubscribeConfigurationRequest) Reset

func (x *SubscribeConfigurationRequest) Reset()

func (*SubscribeConfigurationRequest) String

type SubscribeConfigurationResponse

type SubscribeConfigurationResponse struct {

	// The list of items containing configuration values
	Items []*v1.ConfigurationItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeConfigurationResponse) Descriptor deprecated

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

Deprecated: Use SubscribeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationResponse) GetItems

func (*SubscribeConfigurationResponse) ProtoMessage

func (*SubscribeConfigurationResponse) ProtoMessage()

func (*SubscribeConfigurationResponse) ProtoReflect

func (*SubscribeConfigurationResponse) Reset

func (x *SubscribeConfigurationResponse) Reset()

func (*SubscribeConfigurationResponse) 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"`
	// The matching path from TopicSubscription/routes (if specified) for this event.
	// This value is used by OnTopicEvent to "switch" inside the handler.
	Path string `protobuf:"bytes,9,opt,name=path,proto3" json:"path,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) GetPath

func (x *TopicEventRequest) GetPath() 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 (*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) Enum

func (TopicEventResponse_TopicEventResponseStatus) EnumDescriptor deprecated

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

Deprecated: Use TopicEventResponse_TopicEventResponseStatus.Descriptor instead.

func (TopicEventResponse_TopicEventResponseStatus) Number

func (TopicEventResponse_TopicEventResponseStatus) String

func (TopicEventResponse_TopicEventResponseStatus) Type

type TopicRoutes

type TopicRoutes struct {

	// The list of rules for this topic.
	Rules []*TopicRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// The default path for this topic.
	Default string `protobuf:"bytes,2,opt,name=default,proto3" json:"default,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicRoutes) Descriptor deprecated

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

Deprecated: Use TopicRoutes.ProtoReflect.Descriptor instead.

func (*TopicRoutes) GetDefault

func (x *TopicRoutes) GetDefault() string

func (*TopicRoutes) GetRules

func (x *TopicRoutes) GetRules() []*TopicRule

func (*TopicRoutes) ProtoMessage

func (*TopicRoutes) ProtoMessage()

func (*TopicRoutes) ProtoReflect

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

func (*TopicRoutes) Reset

func (x *TopicRoutes) Reset()

func (*TopicRoutes) String

func (x *TopicRoutes) String() string

type TopicRule

type TopicRule struct {

	// The optional CEL expression used to match the event.
	// If the match is not specified, then the route is considered
	// the default.
	Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// The path used to identify matches for this subscription.
	// This value is passed in TopicEventRequest and used by OnTopicEvent to "switch"
	// inside the handler.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicRule) Descriptor deprecated

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

Deprecated: Use TopicRule.ProtoReflect.Descriptor instead.

func (*TopicRule) GetMatch

func (x *TopicRule) GetMatch() string

func (*TopicRule) GetPath

func (x *TopicRule) GetPath() string

func (*TopicRule) ProtoMessage

func (*TopicRule) ProtoMessage()

func (*TopicRule) ProtoReflect

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

func (*TopicRule) Reset

func (x *TopicRule) Reset()

func (*TopicRule) String

func (x *TopicRule) String() string

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 */
	// The optional routing rules to match against. In the gRPC interface, OnTopicEvent
	// is still invoked but the matching path is sent in the TopicEventRequest.
	Routes *TopicRoutes `protobuf:"bytes,5,opt,name=routes,proto3" json:"routes,omitempty"`
	// 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) GetRoutes

func (x *TopicSubscription) GetRoutes() *TopicRoutes

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

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

Deprecated: Use TransactionalActorStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalActorStateOperation) GetKey

func (*TransactionalActorStateOperation) GetOperationType

func (x *TransactionalActorStateOperation) GetOperationType() string

func (*TransactionalActorStateOperation) GetValue

func (*TransactionalActorStateOperation) ProtoMessage

func (*TransactionalActorStateOperation) ProtoMessage()

func (*TransactionalActorStateOperation) ProtoReflect

func (*TransactionalActorStateOperation) Reset

func (*TransactionalActorStateOperation) 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 (*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) ListTopicSubscriptions

func (UnimplementedAppCallbackServer) OnBindingEvent

func (UnimplementedAppCallbackServer) OnInvoke

func (UnimplementedAppCallbackServer) OnTopicEvent

type UnimplementedDaprServer

type UnimplementedDaprServer struct {
}

UnimplementedDaprServer should be embedded to have forward compatible implementations.

func (UnimplementedDaprServer) DeleteBulkState

func (UnimplementedDaprServer) DeleteState

func (UnimplementedDaprServer) ExecuteActorStateTransaction

func (UnimplementedDaprServer) ExecuteStateTransaction

func (UnimplementedDaprServer) GetActorState

func (UnimplementedDaprServer) GetBulkSecret

func (UnimplementedDaprServer) GetBulkState

func (UnimplementedDaprServer) GetConfigurationAlpha1

func (UnimplementedDaprServer) GetMetadata

func (UnimplementedDaprServer) GetSecret

func (UnimplementedDaprServer) GetState

func (UnimplementedDaprServer) InvokeActor

func (UnimplementedDaprServer) InvokeBinding

func (UnimplementedDaprServer) InvokeService

func (UnimplementedDaprServer) PublishEvent

func (UnimplementedDaprServer) QueryStateAlpha1

func (UnimplementedDaprServer) RegisterActorReminder

func (UnimplementedDaprServer) RegisterActorTimer

func (UnimplementedDaprServer) SaveState

func (UnimplementedDaprServer) SetMetadata

func (UnimplementedDaprServer) Shutdown

func (UnimplementedDaprServer) UnregisterActorReminder

func (UnimplementedDaprServer) UnregisterActorTimer

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 (*UnregisterActorReminderRequest) ProtoMessage

func (*UnregisterActorReminderRequest) ProtoMessage()

func (*UnregisterActorReminderRequest) ProtoReflect

func (*UnregisterActorReminderRequest) Reset

func (x *UnregisterActorReminderRequest) Reset()

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL