runtime

package
v1.10.3 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2023 License: Apache-2.0 Imports: 12 Imported by: 28

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for TopicEventResponse_TopicEventResponseStatus.

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

Enum value maps for BindingEventResponse_BindingEventConcurrency.

View Source 
var (
	UnlockResponse_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "LOCK_DOES_NOT_EXIST",
		2: "LOCK_BELONGS_TO_OTHERS",
		3: "INTERNAL_ERROR",
	}
	UnlockResponse_Status_value = map[string]int32{
		"SUCCESS":                0,
		"LOCK_DOES_NOT_EXIST":    1,
		"LOCK_BELONGS_TO_OTHERS": 2,
		"INTERNAL_ERROR":         3,
	}
)

Enum value maps for UnlockResponse_Status.

View Source 
var AppCallbackAlpha_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.runtime.v1.AppCallbackAlpha",
	HandlerType: (*AppCallbackAlphaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OnBulkTopicEventAlpha1",
			Handler:    _AppCallbackAlpha_OnBulkTopicEventAlpha1_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/runtime/v1/appcallback.proto",
}

AppCallbackAlpha_ServiceDesc is the grpc.ServiceDesc for AppCallbackAlpha 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 AppCallbackHealthCheck_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.runtime.v1.AppCallbackHealthCheck",
	HandlerType: (*AppCallbackHealthCheckServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HealthCheck",
			Handler:    _AppCallbackHealthCheck_HealthCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/runtime/v1/appcallback.proto",
}

AppCallbackHealthCheck_ServiceDesc is the grpc.ServiceDesc for AppCallbackHealthCheck 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 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: "BulkPublishEventAlpha1",
			Handler:    _Dapr_BulkPublishEventAlpha1_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: "RenameActorReminder",
			Handler:    _Dapr_RenameActorReminder_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: "UnsubscribeConfigurationAlpha1",
			Handler:    _Dapr_UnsubscribeConfigurationAlpha1_Handler,
		},
		{
			MethodName: "TryLockAlpha1",
			Handler:    _Dapr_TryLockAlpha1_Handler,
		},
		{
			MethodName: "UnlockAlpha1",
			Handler:    _Dapr_UnlockAlpha1_Handler,
		},
		{
			MethodName: "GetMetadata",
			Handler:    _Dapr_GetMetadata_Handler,
		},
		{
			MethodName: "SetMetadata",
			Handler:    _Dapr_SetMetadata_Handler,
		},
		{
			MethodName: "StartWorkflowAlpha1",
			Handler:    _Dapr_StartWorkflowAlpha1_Handler,
		},
		{
			MethodName: "GetWorkflowAlpha1",
			Handler:    _Dapr_GetWorkflowAlpha1_Handler,
		},
		{
			MethodName: "TerminateWorkflowAlpha1",
			Handler:    _Dapr_TerminateWorkflowAlpha1_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 RegisterAppCallbackAlphaServer added in v1.10.0 

func RegisterAppCallbackAlphaServer(s grpc.ServiceRegistrar, srv AppCallbackAlphaServer)

func RegisterAppCallbackHealthCheckServer added in v1.9.0 

func RegisterAppCallbackHealthCheckServer(s grpc.ServiceRegistrar, srv AppCallbackHealthCheckServer)

func RegisterAppCallbackServer 

func RegisterAppCallbackServer(s grpc.ServiceRegistrar, srv AppCallbackServer)

func RegisterDaprServer 

func RegisterDaprServer(s grpc.ServiceRegistrar, srv DaprServer)

Types

type ActiveActorsCount added in v1.0.0 

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

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

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

Deprecated: Use ActiveActorsCount.ProtoReflect.Descriptor instead.

func (*ActiveActorsCount) GetCount added in v1.0.0 

func (x *ActiveActorsCount) GetCount() int32

func (*ActiveActorsCount) GetType added in v1.0.0 

func (x *ActiveActorsCount) GetType() string

func (*ActiveActorsCount) ProtoMessage added in v1.0.0 

func (*ActiveActorsCount) ProtoMessage()

func (*ActiveActorsCount) ProtoReflect added in v1.0.0 

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

func (*ActiveActorsCount) Reset added in v1.0.0 

func (x *ActiveActorsCount) Reset()

func (*ActiveActorsCount) String added in v1.0.0 

func (x *ActiveActorsCount) String() string

type AppCallbackAlphaClient added in v1.10.0 

type AppCallbackAlphaClient interface {
	// Subscribes bulk events from Pubsub
	OnBulkTopicEventAlpha1(ctx context.Context, in *TopicEventBulkRequest, opts ...grpc.CallOption) (*TopicEventBulkResponse, error)
}

AppCallbackAlphaClient is the client API for AppCallbackAlpha 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 NewAppCallbackAlphaClient added in v1.10.0 

func NewAppCallbackAlphaClient(cc grpc.ClientConnInterface) AppCallbackAlphaClient

type AppCallbackAlphaServer added in v1.10.0 

type AppCallbackAlphaServer interface {
	// Subscribes bulk events from Pubsub
	OnBulkTopicEventAlpha1(context.Context, *TopicEventBulkRequest) (*TopicEventBulkResponse, error)
}

AppCallbackAlphaServer is the server API for AppCallbackAlpha service. All implementations should embed UnimplementedAppCallbackAlphaServer for forward compatibility

type AppCallbackClient 

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

AppCallbackClient is the client API for AppCallback service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAppCallbackClient 

func NewAppCallbackClient(cc grpc.ClientConnInterface) AppCallbackClient

type AppCallbackHealthCheckClient added in v1.9.0 

type AppCallbackHealthCheckClient interface {
	// Health check.
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

AppCallbackHealthCheckClient is the client API for AppCallbackHealthCheck 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 NewAppCallbackHealthCheckClient added in v1.9.0 

func NewAppCallbackHealthCheckClient(cc grpc.ClientConnInterface) AppCallbackHealthCheckClient

type AppCallbackHealthCheckServer added in v1.9.0 

type AppCallbackHealthCheckServer interface {
	// Health check.
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)
}

AppCallbackHealthCheckServer is the server API for AppCallbackHealthCheck service. All implementations should embed UnimplementedAppCallbackHealthCheckServer for forward compatibility

type AppCallbackServer 

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

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

type BindingEventRequest 

type BindingEventRequest struct {

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

BindingEventRequest represents input bindings event.

func (*BindingEventRequest) Descriptor deprecated 

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

Deprecated: Use BindingEventRequest.ProtoReflect.Descriptor instead.

func (*BindingEventRequest) GetData 

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

func (*BindingEventRequest) GetMetadata 

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

func (*BindingEventRequest) GetName 

func (x *BindingEventRequest) GetName() string

func (*BindingEventRequest) ProtoMessage 

func (*BindingEventRequest) ProtoMessage()

func (*BindingEventRequest) ProtoReflect added in v1.0.0 

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

func (*BindingEventRequest) Reset 

func (x *BindingEventRequest) Reset()

func (*BindingEventRequest) String 

func (x *BindingEventRequest) String() string

type BindingEventResponse 

type BindingEventResponse struct {

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

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

func (*BindingEventResponse) Descriptor deprecated 

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

Deprecated: Use BindingEventResponse.ProtoReflect.Descriptor instead.

func (*BindingEventResponse) GetConcurrency 

func (x *BindingEventResponse) GetConcurrency() BindingEventResponse_BindingEventConcurrency

func (*BindingEventResponse) GetData 

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

func (*BindingEventResponse) GetStates 

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

func (*BindingEventResponse) GetStoreName 

func (x *BindingEventResponse) GetStoreName() string

func (*BindingEventResponse) GetTo 

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

func (*BindingEventResponse) ProtoMessage 

func (*BindingEventResponse) ProtoMessage()

func (*BindingEventResponse) ProtoReflect added in v1.0.0 

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

func (*BindingEventResponse) Reset 

func (x *BindingEventResponse) Reset()

func (*BindingEventResponse) String 

func (x *BindingEventResponse) String() string

type BindingEventResponse_BindingEventConcurrency 

type BindingEventResponse_BindingEventConcurrency int32

BindingEventConcurrency is the kind of concurrency 

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

func (BindingEventResponse_BindingEventConcurrency) Descriptor added in v1.0.0 

func (BindingEventResponse_BindingEventConcurrency) Descriptor() protoreflect.EnumDescriptor

func (BindingEventResponse_BindingEventConcurrency) Enum added in v1.0.0 

func (x BindingEventResponse_BindingEventConcurrency) Enum() *BindingEventResponse_BindingEventConcurrency

func (BindingEventResponse_BindingEventConcurrency) EnumDescriptor deprecated 

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

Deprecated: Use BindingEventResponse_BindingEventConcurrency.Descriptor instead.

func (BindingEventResponse_BindingEventConcurrency) Number added in v1.0.0 

func (x BindingEventResponse_BindingEventConcurrency) Number() protoreflect.EnumNumber

func (BindingEventResponse_BindingEventConcurrency) String 

func (x BindingEventResponse_BindingEventConcurrency) String() string

func (BindingEventResponse_BindingEventConcurrency) Type added in v1.0.0 

func (BindingEventResponse_BindingEventConcurrency) Type() protoreflect.EnumType

type BulkPublishRequest added in v1.10.0 

type BulkPublishRequest 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 entries which contain the individual events and associated details to be published
	Entries []*BulkPublishRequestEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// The request level metadata passing to to the pubsub components
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

BulkPublishRequest is the message to bulk publish events to pubsub topic

func (*BulkPublishRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use BulkPublishRequest.ProtoReflect.Descriptor instead.

func (*BulkPublishRequest) GetEntries added in v1.10.0 

func (x *BulkPublishRequest) GetEntries() []*BulkPublishRequestEntry

func (*BulkPublishRequest) GetMetadata added in v1.10.0 

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

func (*BulkPublishRequest) GetPubsubName added in v1.10.0 

func (x *BulkPublishRequest) GetPubsubName() string

func (*BulkPublishRequest) GetTopic added in v1.10.0 

func (x *BulkPublishRequest) GetTopic() string

func (*BulkPublishRequest) ProtoMessage added in v1.10.0 

func (*BulkPublishRequest) ProtoMessage()

func (*BulkPublishRequest) ProtoReflect added in v1.10.0 

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

func (*BulkPublishRequest) Reset added in v1.10.0 

func (x *BulkPublishRequest) Reset()

func (*BulkPublishRequest) String added in v1.10.0 

func (x *BulkPublishRequest) String() string

type BulkPublishRequestEntry added in v1.10.0 

type BulkPublishRequestEntry struct {

	// The request scoped unique ID referring to this message. Used to map status in response
	EntryId string `protobuf:"bytes,1,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// The event which will be pulished to the topic
	Event []byte `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// The content type for the event
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// The event level metadata passing to the pubsub component
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

BulkPublishRequestEntry is the message containing the event to be bulk published

func (*BulkPublishRequestEntry) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use BulkPublishRequestEntry.ProtoReflect.Descriptor instead.

func (*BulkPublishRequestEntry) GetContentType added in v1.10.0 

func (x *BulkPublishRequestEntry) GetContentType() string

func (*BulkPublishRequestEntry) GetEntryId added in v1.10.0 

func (x *BulkPublishRequestEntry) GetEntryId() string

func (*BulkPublishRequestEntry) GetEvent added in v1.10.0 

func (x *BulkPublishRequestEntry) GetEvent() []byte

func (*BulkPublishRequestEntry) GetMetadata added in v1.10.0 

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

func (*BulkPublishRequestEntry) ProtoMessage added in v1.10.0 

func (*BulkPublishRequestEntry) ProtoMessage()

func (*BulkPublishRequestEntry) ProtoReflect added in v1.10.0 

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

func (*BulkPublishRequestEntry) Reset added in v1.10.0 

func (x *BulkPublishRequestEntry) Reset()

func (*BulkPublishRequestEntry) String added in v1.10.0 

func (x *BulkPublishRequestEntry) String() string

type BulkPublishResponse added in v1.10.0 

type BulkPublishResponse struct {

	// The entries for different events that failed publish in the BulkPublishEvent call
	FailedEntries []*BulkPublishResponseFailedEntry `protobuf:"bytes,1,rep,name=failedEntries,proto3" json:"failedEntries,omitempty"`
	// contains filtered or unexported fields
}

BulkPublishResponse is the message returned from a BulkPublishEvent call

func (*BulkPublishResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use BulkPublishResponse.ProtoReflect.Descriptor instead.

func (*BulkPublishResponse) GetFailedEntries added in v1.10.0 

func (x *BulkPublishResponse) GetFailedEntries() []*BulkPublishResponseFailedEntry

func (*BulkPublishResponse) ProtoMessage added in v1.10.0 

func (*BulkPublishResponse) ProtoMessage()

func (*BulkPublishResponse) ProtoReflect added in v1.10.0 

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

func (*BulkPublishResponse) Reset added in v1.10.0 

func (x *BulkPublishResponse) Reset()

func (*BulkPublishResponse) String added in v1.10.0 

func (x *BulkPublishResponse) String() string

type BulkPublishResponseFailedEntry added in v1.10.0 

type BulkPublishResponseFailedEntry struct {

	// The response scoped unique ID referring to this message
	EntryId string `protobuf:"bytes,1,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// The error message if any on failure
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

BulkPublishResponseFailedEntry is the message containing the entryID and error of a failed event in BulkPublishEvent call

func (*BulkPublishResponseFailedEntry) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use BulkPublishResponseFailedEntry.ProtoReflect.Descriptor instead.

func (*BulkPublishResponseFailedEntry) GetEntryId added in v1.10.0 

func (x *BulkPublishResponseFailedEntry) GetEntryId() string

func (*BulkPublishResponseFailedEntry) GetError added in v1.10.0 

func (x *BulkPublishResponseFailedEntry) GetError() string

func (*BulkPublishResponseFailedEntry) ProtoMessage added in v1.10.0 

func (*BulkPublishResponseFailedEntry) ProtoMessage()

func (*BulkPublishResponseFailedEntry) ProtoReflect added in v1.10.0 

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

func (*BulkPublishResponseFailedEntry) Reset added in v1.10.0 

func (x *BulkPublishResponseFailedEntry) Reset()

func (*BulkPublishResponseFailedEntry) String added in v1.10.0 

func (x *BulkPublishResponseFailedEntry) String() string

type BulkStateItem added in v0.10.0 

type BulkStateItem struct {

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

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

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

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

Deprecated: Use BulkStateItem.ProtoReflect.Descriptor instead.

func (*BulkStateItem) GetData added in v0.10.0 

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

func (*BulkStateItem) GetError added in v0.11.0 

func (x *BulkStateItem) GetError() string

func (*BulkStateItem) GetEtag added in v0.10.0 

func (x *BulkStateItem) GetEtag() string

func (*BulkStateItem) GetKey added in v0.10.0 

func (x *BulkStateItem) GetKey() string

func (*BulkStateItem) GetMetadata added in v1.0.0 

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

func (*BulkStateItem) ProtoMessage added in v0.10.0 

func (*BulkStateItem) ProtoMessage()

func (*BulkStateItem) ProtoReflect added in v1.0.0 

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

func (*BulkStateItem) Reset added in v0.10.0 

func (x *BulkStateItem) Reset()

func (*BulkStateItem) String added in v0.10.0 

func (x *BulkStateItem) String() string

type BulkSubscribeConfig added in v1.10.0 

type BulkSubscribeConfig struct {

	// Required. Flag to enable/disable bulk subscribe
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Optional. Max number of messages to be sent in a single bulk request
	MaxMessagesCount int32 `protobuf:"varint,2,opt,name=max_messages_count,json=maxMessagesCount,proto3" json:"max_messages_count,omitempty"`
	// Optional. Max duration to wait for messages to be sent in a single bulk request
	MaxAwaitDurationMs int32 `protobuf:"varint,3,opt,name=max_await_duration_ms,json=maxAwaitDurationMs,proto3" json:"max_await_duration_ms,omitempty"`
	// contains filtered or unexported fields
}

BulkSubscribeConfig is the message to pass settings for bulk subscribe

func (*BulkSubscribeConfig) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use BulkSubscribeConfig.ProtoReflect.Descriptor instead.

func (*BulkSubscribeConfig) GetEnabled added in v1.10.0 

func (x *BulkSubscribeConfig) GetEnabled() bool

func (*BulkSubscribeConfig) GetMaxAwaitDurationMs added in v1.10.0 

func (x *BulkSubscribeConfig) GetMaxAwaitDurationMs() int32

func (*BulkSubscribeConfig) GetMaxMessagesCount added in v1.10.0 

func (x *BulkSubscribeConfig) GetMaxMessagesCount() int32

func (*BulkSubscribeConfig) ProtoMessage added in v1.10.0 

func (*BulkSubscribeConfig) ProtoMessage()

func (*BulkSubscribeConfig) ProtoReflect added in v1.10.0 

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

func (*BulkSubscribeConfig) Reset added in v1.10.0 

func (x *BulkSubscribeConfig) Reset()

func (*BulkSubscribeConfig) String added in v1.10.0 

func (x *BulkSubscribeConfig) String() string

type DaprClient 

type DaprClient interface {
	// Invokes a method on a remote Dapr app.
	// Deprecated: Use proxy mode service invocation instead.
	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)
	// Bulk Publishes multiple events to the specified topic.
	BulkPublishEventAlpha1(ctx context.Context, in *BulkPublishRequest, opts ...grpc.CallOption) (*BulkPublishResponse, 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)
	// Rename an actor reminder.
	RenameActorReminder(ctx context.Context, in *RenameActorReminderRequest, 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)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfigurationAlpha1(ctx context.Context, in *UnsubscribeConfigurationRequest, opts ...grpc.CallOption) (*UnsubscribeConfigurationResponse, error)
	// TryLockAlpha1 tries to get a lock with an expiry.
	TryLockAlpha1(ctx context.Context, in *TryLockRequest, opts ...grpc.CallOption) (*TryLockResponse, error)
	// UnlockAlpha1 unlocks a lock.
	UnlockAlpha1(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, 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)
	// Start Workflow
	StartWorkflowAlpha1(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*WorkflowReference, error)
	// Get Workflow details
	GetWorkflowAlpha1(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)
	// Terminate Workflow
	TerminateWorkflowAlpha1(ctx context.Context, in *TerminateWorkflowRequest, opts ...grpc.CallOption) (*TerminateWorkflowResponse, 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.
	// Deprecated: Use proxy mode service invocation instead.
	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)
	// Bulk Publishes multiple events to the specified topic.
	BulkPublishEventAlpha1(context.Context, *BulkPublishRequest) (*BulkPublishResponse, 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)
	// Rename an actor reminder.
	RenameActorReminder(context.Context, *RenameActorReminderRequest) (*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
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfigurationAlpha1(context.Context, *UnsubscribeConfigurationRequest) (*UnsubscribeConfigurationResponse, error)
	// TryLockAlpha1 tries to get a lock with an expiry.
	TryLockAlpha1(context.Context, *TryLockRequest) (*TryLockResponse, error)
	// UnlockAlpha1 unlocks a lock.
	UnlockAlpha1(context.Context, *UnlockRequest) (*UnlockResponse, 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)
	// Start Workflow
	StartWorkflowAlpha1(context.Context, *StartWorkflowRequest) (*WorkflowReference, error)
	// Get Workflow details
	GetWorkflowAlpha1(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)
	// Terminate Workflow
	TerminateWorkflowAlpha1(context.Context, *TerminateWorkflowRequest) (*TerminateWorkflowResponse, 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 added in v1.5.0 

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

type Dapr_SubscribeConfigurationAlpha1Server added in v1.5.0 

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

type DeleteBulkStateRequest added in v1.0.0 

type DeleteBulkStateRequest struct {

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

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

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

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

Deprecated: Use DeleteBulkStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteBulkStateRequest) GetStates added in v1.0.0 

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

func (*DeleteBulkStateRequest) GetStoreName added in v1.0.0 

func (x *DeleteBulkStateRequest) GetStoreName() string

func (*DeleteBulkStateRequest) ProtoMessage added in v1.0.0 

func (*DeleteBulkStateRequest) ProtoMessage()

func (*DeleteBulkStateRequest) ProtoReflect added in v1.0.0 

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

func (*DeleteBulkStateRequest) Reset added in v1.0.0 

func (x *DeleteBulkStateRequest) Reset()

func (*DeleteBulkStateRequest) String added in v1.0.0 

func (x *DeleteBulkStateRequest) String() string

type DeleteStateRequest 

type DeleteStateRequest struct {

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

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

func (*DeleteStateRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteStateRequest) GetEtag 

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

func (*DeleteStateRequest) GetKey 

func (x *DeleteStateRequest) GetKey() string

func (*DeleteStateRequest) GetMetadata added in v0.11.0 

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

func (*DeleteStateRequest) GetOptions 

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

func (*DeleteStateRequest) GetStoreName 

func (x *DeleteStateRequest) GetStoreName() string

func (*DeleteStateRequest) ProtoMessage 

func (*DeleteStateRequest) ProtoMessage()

func (*DeleteStateRequest) ProtoReflect added in v1.0.0 

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

func (*DeleteStateRequest) Reset 

func (x *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String 

func (x *DeleteStateRequest) String() string

type ExecuteActorStateTransactionRequest added in v1.0.0 

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

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

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

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

Deprecated: Use ExecuteActorStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActorStateTransactionRequest) GetActorId added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) GetActorId() string

func (*ExecuteActorStateTransactionRequest) GetActorType added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) GetActorType() string

func (*ExecuteActorStateTransactionRequest) GetOperations added in v1.0.0 

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

func (*ExecuteActorStateTransactionRequest) ProtoMessage added in v1.0.0 

func (*ExecuteActorStateTransactionRequest) ProtoMessage()

func (*ExecuteActorStateTransactionRequest) ProtoReflect added in v1.0.0 

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

func (*ExecuteActorStateTransactionRequest) Reset added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) Reset()

func (*ExecuteActorStateTransactionRequest) String added in v1.0.0 

func (x *ExecuteActorStateTransactionRequest) String() string

type ExecuteStateTransactionRequest added in v0.10.0 

type ExecuteStateTransactionRequest struct {

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

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

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

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

Deprecated: Use ExecuteStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStateTransactionRequest) GetMetadata added in v0.10.0 

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

func (*ExecuteStateTransactionRequest) GetOperations added in v0.10.0 

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

func (*ExecuteStateTransactionRequest) GetStoreName added in v0.10.0 

func (x *ExecuteStateTransactionRequest) GetStoreName() string

func (*ExecuteStateTransactionRequest) ProtoMessage added in v0.10.0 

func (*ExecuteStateTransactionRequest) ProtoMessage()

func (*ExecuteStateTransactionRequest) ProtoReflect added in v1.0.0 

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

func (*ExecuteStateTransactionRequest) Reset added in v0.10.0 

func (x *ExecuteStateTransactionRequest) Reset()

func (*ExecuteStateTransactionRequest) String added in v0.10.0 

func (x *ExecuteStateTransactionRequest) String() string

type GetActorStateRequest added in v1.0.0 

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

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

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

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

Deprecated: Use GetActorStateRequest.ProtoReflect.Descriptor instead.

func (*GetActorStateRequest) GetActorId added in v1.0.0 

func (x *GetActorStateRequest) GetActorId() string

func (*GetActorStateRequest) GetActorType added in v1.0.0 

func (x *GetActorStateRequest) GetActorType() string

func (*GetActorStateRequest) GetKey added in v1.0.0 

func (x *GetActorStateRequest) GetKey() string

func (*GetActorStateRequest) ProtoMessage added in v1.0.0 

func (*GetActorStateRequest) ProtoMessage()

func (*GetActorStateRequest) ProtoReflect added in v1.0.0 

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

func (*GetActorStateRequest) Reset added in v1.0.0 

func (x *GetActorStateRequest) Reset()

func (*GetActorStateRequest) String added in v1.0.0 

func (x *GetActorStateRequest) String() string

type GetActorStateResponse added in v1.0.0 

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

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

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

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

Deprecated: Use GetActorStateResponse.ProtoReflect.Descriptor instead.

func (*GetActorStateResponse) GetData added in v1.0.0 

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

func (*GetActorStateResponse) ProtoMessage added in v1.0.0 

func (*GetActorStateResponse) ProtoMessage()

func (*GetActorStateResponse) ProtoReflect added in v1.0.0 

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

func (*GetActorStateResponse) Reset added in v1.0.0 

func (x *GetActorStateResponse) Reset()

func (*GetActorStateResponse) String added in v1.0.0 

func (x *GetActorStateResponse) String() string

type GetBulkSecretRequest added in v1.0.0 

type GetBulkSecretRequest struct {

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

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

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

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

Deprecated: Use GetBulkSecretRequest.ProtoReflect.Descriptor instead.

func (*GetBulkSecretRequest) GetMetadata added in v1.0.0 

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

func (*GetBulkSecretRequest) GetStoreName added in v1.0.0 

func (x *GetBulkSecretRequest) GetStoreName() string

func (*GetBulkSecretRequest) ProtoMessage added in v1.0.0 

func (*GetBulkSecretRequest) ProtoMessage()

func (*GetBulkSecretRequest) ProtoReflect added in v1.0.0 

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

func (*GetBulkSecretRequest) Reset added in v1.0.0 

func (x *GetBulkSecretRequest) Reset()

func (*GetBulkSecretRequest) String added in v1.0.0 

func (x *GetBulkSecretRequest) String() string

type GetBulkSecretResponse added in v1.0.0 

type GetBulkSecretResponse struct {

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

GetBulkSecretResponse is the response message to convey the requested secrets.

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

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

Deprecated: Use GetBulkSecretResponse.ProtoReflect.Descriptor instead.

func (*GetBulkSecretResponse) GetData added in v1.0.0 

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

func (*GetBulkSecretResponse) ProtoMessage added in v1.0.0 

func (*GetBulkSecretResponse) ProtoMessage()

func (*GetBulkSecretResponse) ProtoReflect added in v1.0.0 

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

func (*GetBulkSecretResponse) Reset added in v1.0.0 

func (x *GetBulkSecretResponse) Reset()

func (*GetBulkSecretResponse) String added in v1.0.0 

func (x *GetBulkSecretResponse) String() string

type GetBulkStateRequest added in v0.10.0 

type GetBulkStateRequest struct {

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

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

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

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

Deprecated: Use GetBulkStateRequest.ProtoReflect.Descriptor instead.

func (*GetBulkStateRequest) GetKeys added in v0.10.0 

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

func (*GetBulkStateRequest) GetMetadata added in v0.11.0 

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

func (*GetBulkStateRequest) GetParallelism added in v0.10.0 

func (x *GetBulkStateRequest) GetParallelism() int32

func (*GetBulkStateRequest) GetStoreName added in v0.10.0 

func (x *GetBulkStateRequest) GetStoreName() string

func (*GetBulkStateRequest) ProtoMessage added in v0.10.0 

func (*GetBulkStateRequest) ProtoMessage()

func (*GetBulkStateRequest) ProtoReflect added in v1.0.0 

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

func (*GetBulkStateRequest) Reset added in v0.10.0 

func (x *GetBulkStateRequest) Reset()

func (*GetBulkStateRequest) String added in v0.10.0 

func (x *GetBulkStateRequest) String() string

type GetBulkStateResponse added in v0.10.0 

type GetBulkStateResponse struct {

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

GetBulkStateResponse is the response conveying the list of state values.

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

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

Deprecated: Use GetBulkStateResponse.ProtoReflect.Descriptor instead.

func (*GetBulkStateResponse) GetItems added in v0.10.0 

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

func (*GetBulkStateResponse) ProtoMessage added in v0.10.0 

func (*GetBulkStateResponse) ProtoMessage()

func (*GetBulkStateResponse) ProtoReflect added in v1.0.0 

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

func (*GetBulkStateResponse) Reset added in v0.10.0 

func (x *GetBulkStateResponse) Reset()

func (*GetBulkStateResponse) String added in v0.10.0 

func (x *GetBulkStateResponse) String() string

type GetConfigurationRequest added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetKeys added in v1.5.0 

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

func (*GetConfigurationRequest) GetMetadata added in v1.5.0 

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

func (*GetConfigurationRequest) GetStoreName added in v1.5.0 

func (x *GetConfigurationRequest) GetStoreName() string

func (*GetConfigurationRequest) ProtoMessage added in v1.5.0 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect added in v1.5.0 

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

func (*GetConfigurationRequest) Reset added in v1.5.0 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String added in v1.5.0 

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse added in v1.5.0 

type GetConfigurationResponse struct {
	Items map[string]*v1.ConfigurationItem `` /* 151-byte string literal not displayed */
	// 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 added in v1.5.0 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetItems added in v1.5.0 

func (x *GetConfigurationResponse) GetItems() map[string]*v1.ConfigurationItem

func (*GetConfigurationResponse) ProtoMessage added in v1.5.0 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect added in v1.5.0 

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

func (*GetConfigurationResponse) Reset added in v1.5.0 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String added in v1.5.0 

func (x *GetConfigurationResponse) String() string

type GetMetadataResponse added in v1.0.0 

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

GetMetadataResponse is a message that is returned on GetMetadata rpc call

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

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

Deprecated: Use GetMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetMetadataResponse) GetActiveActorsCount added in v1.0.0 

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

func (*GetMetadataResponse) GetExtendedMetadata added in v1.0.0 

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

func (*GetMetadataResponse) GetId added in v1.0.0 

func (x *GetMetadataResponse) GetId() string

func (*GetMetadataResponse) GetRegisteredComponents added in v1.0.0 

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

func (*GetMetadataResponse) GetSubscriptions added in v1.10.0 

func (x *GetMetadataResponse) GetSubscriptions() []*PubsubSubscription

func (*GetMetadataResponse) ProtoMessage added in v1.0.0 

func (*GetMetadataResponse) ProtoMessage()

func (*GetMetadataResponse) ProtoReflect added in v1.0.0 

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

func (*GetMetadataResponse) Reset added in v1.0.0 

func (x *GetMetadataResponse) Reset()

func (*GetMetadataResponse) String added in v1.0.0 

func (x *GetMetadataResponse) String() string

type GetSecretRequest 

type GetSecretRequest struct {

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

GetSecretRequest is the message to get secret from secret store.

func (*GetSecretRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetKey 

func (x *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetMetadata 

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

func (*GetSecretRequest) GetStoreName 

func (x *GetSecretRequest) GetStoreName() string

func (*GetSecretRequest) ProtoMessage 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect added in v1.0.0 

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

func (*GetSecretRequest) Reset 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String 

func (x *GetSecretRequest) String() string

type GetSecretResponse 

type GetSecretResponse struct {

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

GetSecretResponse is the response message to convey the requested secret.

func (*GetSecretResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetData 

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

func (*GetSecretResponse) ProtoMessage 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect added in v1.0.0 

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

func (*GetSecretResponse) Reset 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String 

func (x *GetSecretResponse) String() string

type GetStateRequest 

type GetStateRequest struct {

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

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

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) GetConsistency 

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

func (*GetStateRequest) GetKey 

func (x *GetStateRequest) GetKey() string

func (*GetStateRequest) GetMetadata added in v0.11.0 

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

func (*GetStateRequest) GetStoreName 

func (x *GetStateRequest) GetStoreName() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect added in v1.0.0 

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

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {

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

GetStateResponse is the response conveying the state value and etag.

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetData 

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

func (*GetStateResponse) GetEtag 

func (x *GetStateResponse) GetEtag() string

func (*GetStateResponse) GetMetadata added in v1.0.0 

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

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect added in v1.0.0 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type GetWorkflowRequest added in v1.10.0 

type GetWorkflowRequest struct {
	InstanceId        string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	WorkflowType      string `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	WorkflowComponent string `protobuf:"bytes,3,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetInstanceId added in v1.10.0 

func (x *GetWorkflowRequest) GetInstanceId() string

func (*GetWorkflowRequest) GetWorkflowComponent added in v1.10.0 

func (x *GetWorkflowRequest) GetWorkflowComponent() string

func (*GetWorkflowRequest) GetWorkflowType added in v1.10.0 

func (x *GetWorkflowRequest) GetWorkflowType() string

func (*GetWorkflowRequest) ProtoMessage added in v1.10.0 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect added in v1.10.0 

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

func (*GetWorkflowRequest) Reset added in v1.10.0 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) String added in v1.10.0 

func (x *GetWorkflowRequest) String() string

type GetWorkflowResponse added in v1.10.0 

type GetWorkflowResponse struct {
	InstanceId string            `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	StartTime  int64             `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	Metadata   map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse) GetInstanceId added in v1.10.0 

func (x *GetWorkflowResponse) GetInstanceId() string

func (*GetWorkflowResponse) GetMetadata added in v1.10.0 

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

func (*GetWorkflowResponse) GetStartTime added in v1.10.0 

func (x *GetWorkflowResponse) GetStartTime() int64

func (*GetWorkflowResponse) ProtoMessage added in v1.10.0 

func (*GetWorkflowResponse) ProtoMessage()

func (*GetWorkflowResponse) ProtoReflect added in v1.10.0 

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

func (*GetWorkflowResponse) Reset added in v1.10.0 

func (x *GetWorkflowResponse) Reset()

func (*GetWorkflowResponse) String added in v1.10.0 

func (x *GetWorkflowResponse) String() string

type HealthCheckResponse added in v1.9.0 

type HealthCheckResponse struct {
	// contains filtered or unexported fields
}

HealthCheckResponse is the message with the response to the health check. This message is currently empty as used as placeholder.

func (*HealthCheckResponse) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) ProtoMessage added in v1.9.0 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect added in v1.9.0 

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

func (*HealthCheckResponse) Reset added in v1.9.0 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String added in v1.9.0 

func (x *HealthCheckResponse) String() string

type InvokeActorRequest added in v1.0.0 

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

InvokeActorRequest is the message to call an actor.

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

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

Deprecated: Use InvokeActorRequest.ProtoReflect.Descriptor instead.

func (*InvokeActorRequest) GetActorId added in v1.0.0 

func (x *InvokeActorRequest) GetActorId() string

func (*InvokeActorRequest) GetActorType added in v1.0.0 

func (x *InvokeActorRequest) GetActorType() string

func (*InvokeActorRequest) GetData added in v1.0.0 

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

func (*InvokeActorRequest) GetMetadata added in v1.9.0 

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

func (*InvokeActorRequest) GetMethod added in v1.0.0 

func (x *InvokeActorRequest) GetMethod() string

func (*InvokeActorRequest) ProtoMessage added in v1.0.0 

func (*InvokeActorRequest) ProtoMessage()

func (*InvokeActorRequest) ProtoReflect added in v1.0.0 

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

func (*InvokeActorRequest) Reset added in v1.0.0 

func (x *InvokeActorRequest) Reset()

func (*InvokeActorRequest) String added in v1.0.0 

func (x *InvokeActorRequest) String() string

type InvokeActorResponse added in v1.0.0 

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

InvokeActorResponse is the method that returns an actor invocation response.

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

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

Deprecated: Use InvokeActorResponse.ProtoReflect.Descriptor instead.

func (*InvokeActorResponse) GetData added in v1.0.0 

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

func (*InvokeActorResponse) ProtoMessage added in v1.0.0 

func (*InvokeActorResponse) ProtoMessage()

func (*InvokeActorResponse) ProtoReflect added in v1.0.0 

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

func (*InvokeActorResponse) Reset added in v1.0.0 

func (x *InvokeActorResponse) Reset()

func (*InvokeActorResponse) String added in v1.0.0 

func (x *InvokeActorResponse) String() string

type InvokeBindingRequest 

type InvokeBindingRequest struct {

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

InvokeBindingRequest is the message to send data to output bindings

func (*InvokeBindingRequest) Descriptor deprecated 

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

Deprecated: Use InvokeBindingRequest.ProtoReflect.Descriptor instead.

func (*InvokeBindingRequest) GetData 

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

func (*InvokeBindingRequest) GetMetadata 

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

func (*InvokeBindingRequest) GetName 

func (x *InvokeBindingRequest) GetName() string

func (*InvokeBindingRequest) GetOperation 

func (x *InvokeBindingRequest) GetOperation() string

func (*InvokeBindingRequest) ProtoMessage 

func (*InvokeBindingRequest) ProtoMessage()

func (*InvokeBindingRequest) ProtoReflect added in v1.0.0 

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

func (*InvokeBindingRequest) Reset 

func (x *InvokeBindingRequest) Reset()

func (*InvokeBindingRequest) String 

func (x *InvokeBindingRequest) String() string

type InvokeBindingResponse 

type InvokeBindingResponse struct {

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

InvokeBindingResponse is the message returned from an output binding invocation

func (*InvokeBindingResponse) Descriptor deprecated 

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

Deprecated: Use InvokeBindingResponse.ProtoReflect.Descriptor instead.

func (*InvokeBindingResponse) GetData 

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

func (*InvokeBindingResponse) GetMetadata 

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

func (*InvokeBindingResponse) ProtoMessage 

func (*InvokeBindingResponse) ProtoMessage()

func (*InvokeBindingResponse) ProtoReflect added in v1.0.0 

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

func (*InvokeBindingResponse) Reset 

func (x *InvokeBindingResponse) Reset()

func (*InvokeBindingResponse) String 

func (x *InvokeBindingResponse) String() string

type InvokeServiceRequest 

type InvokeServiceRequest struct {

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

InvokeServiceRequest represents the request message for Service invocation.

func (*InvokeServiceRequest) Descriptor deprecated 

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

Deprecated: Use InvokeServiceRequest.ProtoReflect.Descriptor instead.

func (*InvokeServiceRequest) GetId 

func (x *InvokeServiceRequest) GetId() string

func (*InvokeServiceRequest) GetMessage 

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

func (*InvokeServiceRequest) ProtoMessage 

func (*InvokeServiceRequest) ProtoMessage()

func (*InvokeServiceRequest) ProtoReflect added in v1.0.0 

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

func (*InvokeServiceRequest) Reset 

func (x *InvokeServiceRequest) Reset()

func (*InvokeServiceRequest) String 

func (x *InvokeServiceRequest) String() string

type ListInputBindingsResponse 

type ListInputBindingsResponse struct {

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

ListInputBindingsResponse is the message including the list of input bindings.

func (*ListInputBindingsResponse) Descriptor deprecated 

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

Deprecated: Use ListInputBindingsResponse.ProtoReflect.Descriptor instead.

func (*ListInputBindingsResponse) GetBindings 

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

func (*ListInputBindingsResponse) ProtoMessage 

func (*ListInputBindingsResponse) ProtoMessage()

func (*ListInputBindingsResponse) ProtoReflect added in v1.0.0 

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

func (*ListInputBindingsResponse) Reset 

func (x *ListInputBindingsResponse) Reset()

func (*ListInputBindingsResponse) String 

func (x *ListInputBindingsResponse) String() string

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {

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

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

func (*ListTopicSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

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

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect added in v1.0.0 

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

func (*ListTopicSubscriptionsResponse) Reset 

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (x *ListTopicSubscriptionsResponse) String() string

type PublishEventRequest 

type PublishEventRequest struct {

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

PublishEventRequest is the message to publish event data to pubsub topic

func (*PublishEventRequest) Descriptor deprecated 

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetData 

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

func (*PublishEventRequest) GetDataContentType added in v1.0.0 

func (x *PublishEventRequest) GetDataContentType() string

func (*PublishEventRequest) GetMetadata added in v1.0.0 

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

func (*PublishEventRequest) GetPubsubName added in v0.10.0 

func (x *PublishEventRequest) GetPubsubName() string

func (*PublishEventRequest) GetTopic 

func (x *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect added in v1.0.0 

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

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type PubsubSubscription added in v1.10.0 

type PubsubSubscription struct {
	PubsubName      string                   `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	Topic           string                   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Metadata        map[string]string        `` /* 157-byte string literal not displayed */
	Rules           *PubsubSubscriptionRules `protobuf:"bytes,4,opt,name=rules,proto3" json:"rules,omitempty"`
	DeadLetterTopic string                   `protobuf:"bytes,5,opt,name=dead_letter_topic,json=deadLetterTopic,proto3" json:"dead_letter_topic,omitempty"`
	// contains filtered or unexported fields
}

func (*PubsubSubscription) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use PubsubSubscription.ProtoReflect.Descriptor instead.

func (*PubsubSubscription) GetDeadLetterTopic added in v1.10.0 

func (x *PubsubSubscription) GetDeadLetterTopic() string

func (*PubsubSubscription) GetMetadata added in v1.10.0 

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

func (*PubsubSubscription) GetPubsubName added in v1.10.0 

func (x *PubsubSubscription) GetPubsubName() string

func (*PubsubSubscription) GetRules added in v1.10.0 

func (x *PubsubSubscription) GetRules() *PubsubSubscriptionRules

func (*PubsubSubscription) GetTopic added in v1.10.0 

func (x *PubsubSubscription) GetTopic() string

func (*PubsubSubscription) ProtoMessage added in v1.10.0 

func (*PubsubSubscription) ProtoMessage()

func (*PubsubSubscription) ProtoReflect added in v1.10.0 

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

func (*PubsubSubscription) Reset added in v1.10.0 

func (x *PubsubSubscription) Reset()

func (*PubsubSubscription) String added in v1.10.0 

func (x *PubsubSubscription) String() string

type PubsubSubscriptionRule added in v1.10.0 

type PubsubSubscriptionRule struct {
	Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	Path  string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*PubsubSubscriptionRule) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use PubsubSubscriptionRule.ProtoReflect.Descriptor instead.

func (*PubsubSubscriptionRule) GetMatch added in v1.10.0 

func (x *PubsubSubscriptionRule) GetMatch() string

func (*PubsubSubscriptionRule) GetPath added in v1.10.0 

func (x *PubsubSubscriptionRule) GetPath() string

func (*PubsubSubscriptionRule) ProtoMessage added in v1.10.0 

func (*PubsubSubscriptionRule) ProtoMessage()

func (*PubsubSubscriptionRule) ProtoReflect added in v1.10.0 

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

func (*PubsubSubscriptionRule) Reset added in v1.10.0 

func (x *PubsubSubscriptionRule) Reset()

func (*PubsubSubscriptionRule) String added in v1.10.0 

func (x *PubsubSubscriptionRule) String() string

type PubsubSubscriptionRules added in v1.10.0 

type PubsubSubscriptionRules struct {
	Rules []*PubsubSubscriptionRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*PubsubSubscriptionRules) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use PubsubSubscriptionRules.ProtoReflect.Descriptor instead.

func (*PubsubSubscriptionRules) GetRules added in v1.10.0 

func (x *PubsubSubscriptionRules) GetRules() []*PubsubSubscriptionRule

func (*PubsubSubscriptionRules) ProtoMessage added in v1.10.0 

func (*PubsubSubscriptionRules) ProtoMessage()

func (*PubsubSubscriptionRules) ProtoReflect added in v1.10.0 

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

func (*PubsubSubscriptionRules) Reset added in v1.10.0 

func (x *PubsubSubscriptionRules) Reset()

func (*PubsubSubscriptionRules) String added in v1.10.0 

func (x *PubsubSubscriptionRules) String() string

type QueryStateItem added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use QueryStateItem.ProtoReflect.Descriptor instead.

func (*QueryStateItem) GetData added in v1.5.0 

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

func (*QueryStateItem) GetError added in v1.5.0 

func (x *QueryStateItem) GetError() string

func (*QueryStateItem) GetEtag added in v1.5.0 

func (x *QueryStateItem) GetEtag() string

func (*QueryStateItem) GetKey added in v1.5.0 

func (x *QueryStateItem) GetKey() string

func (*QueryStateItem) ProtoMessage added in v1.5.0 

func (*QueryStateItem) ProtoMessage()

func (*QueryStateItem) ProtoReflect added in v1.5.0 

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

func (*QueryStateItem) Reset added in v1.5.0 

func (x *QueryStateItem) Reset()

func (*QueryStateItem) String added in v1.5.0 

func (x *QueryStateItem) String() string

type QueryStateRequest added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use QueryStateRequest.ProtoReflect.Descriptor instead.

func (*QueryStateRequest) GetMetadata added in v1.5.0 

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

func (*QueryStateRequest) GetQuery added in v1.5.0 

func (x *QueryStateRequest) GetQuery() string

func (*QueryStateRequest) GetStoreName added in v1.5.0 

func (x *QueryStateRequest) GetStoreName() string

func (*QueryStateRequest) ProtoMessage added in v1.5.0 

func (*QueryStateRequest) ProtoMessage()

func (*QueryStateRequest) ProtoReflect added in v1.5.0 

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

func (*QueryStateRequest) Reset added in v1.5.0 

func (x *QueryStateRequest) Reset()

func (*QueryStateRequest) String added in v1.5.0 

func (x *QueryStateRequest) String() string

type QueryStateResponse added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use QueryStateResponse.ProtoReflect.Descriptor instead.

func (*QueryStateResponse) GetMetadata added in v1.5.0 

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

func (*QueryStateResponse) GetResults added in v1.5.0 

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

func (*QueryStateResponse) GetToken added in v1.5.0 

func (x *QueryStateResponse) GetToken() string

func (*QueryStateResponse) ProtoMessage added in v1.5.0 

func (*QueryStateResponse) ProtoMessage()

func (*QueryStateResponse) ProtoReflect added in v1.5.0 

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

func (*QueryStateResponse) Reset added in v1.5.0 

func (x *QueryStateResponse) Reset()

func (*QueryStateResponse) String added in v1.5.0 

func (x *QueryStateResponse) String() string

type RegisterActorReminderRequest added in v1.0.0 

type RegisterActorReminderRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	DueTime   string `protobuf:"bytes,4,opt,name=due_time,json=dueTime,proto3" json:"due_time,omitempty"`
	Period    string `protobuf:"bytes,5,opt,name=period,proto3" json:"period,omitempty"`
	Data      []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	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 added in v1.0.0 

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

Deprecated: Use RegisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorReminderRequest) GetActorId added in v1.0.0 

func (x *RegisterActorReminderRequest) GetActorId() string

func (*RegisterActorReminderRequest) GetActorType added in v1.0.0 

func (x *RegisterActorReminderRequest) GetActorType() string

func (*RegisterActorReminderRequest) GetData added in v1.0.0 

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

func (*RegisterActorReminderRequest) GetDueTime added in v1.0.0 

func (x *RegisterActorReminderRequest) GetDueTime() string

func (*RegisterActorReminderRequest) GetName added in v1.0.0 

func (x *RegisterActorReminderRequest) GetName() string

func (*RegisterActorReminderRequest) GetPeriod added in v1.0.0 

func (x *RegisterActorReminderRequest) GetPeriod() string

func (*RegisterActorReminderRequest) GetTtl added in v1.4.0 

func (x *RegisterActorReminderRequest) GetTtl() string

func (*RegisterActorReminderRequest) ProtoMessage added in v1.0.0 

func (*RegisterActorReminderRequest) ProtoMessage()

func (*RegisterActorReminderRequest) ProtoReflect added in v1.0.0 

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

func (*RegisterActorReminderRequest) Reset added in v1.0.0 

func (x *RegisterActorReminderRequest) Reset()

func (*RegisterActorReminderRequest) String added in v1.0.0 

func (x *RegisterActorReminderRequest) String() string

type RegisterActorTimerRequest added in v1.0.0 

type RegisterActorTimerRequest struct {
	ActorType string `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	DueTime   string `protobuf:"bytes,4,opt,name=due_time,json=dueTime,proto3" json:"due_time,omitempty"`
	Period    string `protobuf:"bytes,5,opt,name=period,proto3" json:"period,omitempty"`
	Callback  string `protobuf:"bytes,6,opt,name=callback,proto3" json:"callback,omitempty"`
	Data      []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	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 added in v1.0.0 

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

Deprecated: Use RegisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorTimerRequest) GetActorId added in v1.0.0 

func (x *RegisterActorTimerRequest) GetActorId() string

func (*RegisterActorTimerRequest) GetActorType added in v1.0.0 

func (x *RegisterActorTimerRequest) GetActorType() string

func (*RegisterActorTimerRequest) GetCallback added in v1.0.0 

func (x *RegisterActorTimerRequest) GetCallback() string

func (*RegisterActorTimerRequest) GetData added in v1.0.0 

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

func (*RegisterActorTimerRequest) GetDueTime added in v1.0.0 

func (x *RegisterActorTimerRequest) GetDueTime() string

func (*RegisterActorTimerRequest) GetName added in v1.0.0 

func (x *RegisterActorTimerRequest) GetName() string

func (*RegisterActorTimerRequest) GetPeriod added in v1.0.0 

func (x *RegisterActorTimerRequest) GetPeriod() string

func (*RegisterActorTimerRequest) GetTtl added in v1.4.0 

func (x *RegisterActorTimerRequest) GetTtl() string

func (*RegisterActorTimerRequest) ProtoMessage added in v1.0.0 

func (*RegisterActorTimerRequest) ProtoMessage()

func (*RegisterActorTimerRequest) ProtoReflect added in v1.0.0 

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

func (*RegisterActorTimerRequest) Reset added in v1.0.0 

func (x *RegisterActorTimerRequest) Reset()

func (*RegisterActorTimerRequest) String added in v1.0.0 

func (x *RegisterActorTimerRequest) String() string

type RegisteredComponents added in v1.0.0 

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

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

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

Deprecated: Use RegisteredComponents.ProtoReflect.Descriptor instead.

func (*RegisteredComponents) GetCapabilities added in v1.8.0 

func (x *RegisteredComponents) GetCapabilities() []string

func (*RegisteredComponents) GetName added in v1.0.0 

func (x *RegisteredComponents) GetName() string

func (*RegisteredComponents) GetType added in v1.0.0 

func (x *RegisteredComponents) GetType() string

func (*RegisteredComponents) GetVersion added in v1.0.0 

func (x *RegisteredComponents) GetVersion() string

func (*RegisteredComponents) ProtoMessage added in v1.0.0 

func (*RegisteredComponents) ProtoMessage()

func (*RegisteredComponents) ProtoReflect added in v1.0.0 

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

func (*RegisteredComponents) Reset added in v1.0.0 

func (x *RegisteredComponents) Reset()

func (*RegisteredComponents) String added in v1.0.0 

func (x *RegisteredComponents) String() string

type RenameActorReminderRequest added in v1.6.0 

type RenameActorReminderRequest 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"`
	OldName   string `protobuf:"bytes,3,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	NewName   string `protobuf:"bytes,4,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// contains filtered or unexported fields
}

RenameActorReminderRequest is the message to rename an actor reminder.

func (*RenameActorReminderRequest) Descriptor deprecated added in v1.6.0 

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

Deprecated: Use RenameActorReminderRequest.ProtoReflect.Descriptor instead.

func (*RenameActorReminderRequest) GetActorId added in v1.6.0 

func (x *RenameActorReminderRequest) GetActorId() string

func (*RenameActorReminderRequest) GetActorType added in v1.6.0 

func (x *RenameActorReminderRequest) GetActorType() string

func (*RenameActorReminderRequest) GetNewName added in v1.6.0 

func (x *RenameActorReminderRequest) GetNewName() string

func (*RenameActorReminderRequest) GetOldName added in v1.6.0 

func (x *RenameActorReminderRequest) GetOldName() string

func (*RenameActorReminderRequest) ProtoMessage added in v1.6.0 

func (*RenameActorReminderRequest) ProtoMessage()

func (*RenameActorReminderRequest) ProtoReflect added in v1.6.0 

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

func (*RenameActorReminderRequest) Reset added in v1.6.0 

func (x *RenameActorReminderRequest) Reset()

func (*RenameActorReminderRequest) String added in v1.6.0 

func (x *RenameActorReminderRequest) String() string

type SaveStateRequest 

type SaveStateRequest struct {

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

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

func (*SaveStateRequest) Descriptor deprecated 

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

Deprecated: Use SaveStateRequest.ProtoReflect.Descriptor instead.

func (*SaveStateRequest) GetStates 

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

func (*SaveStateRequest) GetStoreName 

func (x *SaveStateRequest) GetStoreName() string

func (*SaveStateRequest) ProtoMessage 

func (*SaveStateRequest) ProtoMessage()

func (*SaveStateRequest) ProtoReflect added in v1.0.0 

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

func (*SaveStateRequest) Reset 

func (x *SaveStateRequest) Reset()

func (*SaveStateRequest) String 

func (x *SaveStateRequest) String() string

type SecretResponse added in v1.0.0 

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

SecretResponse is a map of decrypted string/string values

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

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

Deprecated: Use SecretResponse.ProtoReflect.Descriptor instead.

func (*SecretResponse) GetSecrets added in v1.0.0 

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

func (*SecretResponse) ProtoMessage added in v1.0.0 

func (*SecretResponse) ProtoMessage()

func (*SecretResponse) ProtoReflect added in v1.0.0 

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

func (*SecretResponse) Reset added in v1.0.0 

func (x *SecretResponse) Reset()

func (*SecretResponse) String added in v1.0.0 

func (x *SecretResponse) String() string

type SetMetadataRequest added in v1.0.0 

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

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

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

Deprecated: Use SetMetadataRequest.ProtoReflect.Descriptor instead.

func (*SetMetadataRequest) GetKey added in v1.0.0 

func (x *SetMetadataRequest) GetKey() string

func (*SetMetadataRequest) GetValue added in v1.0.0 

func (x *SetMetadataRequest) GetValue() string

func (*SetMetadataRequest) ProtoMessage added in v1.0.0 

func (*SetMetadataRequest) ProtoMessage()

func (*SetMetadataRequest) ProtoReflect added in v1.0.0 

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

func (*SetMetadataRequest) Reset added in v1.0.0 

func (x *SetMetadataRequest) Reset()

func (*SetMetadataRequest) String added in v1.0.0 

func (x *SetMetadataRequest) String() string

type StartWorkflowRequest added in v1.10.0 

type StartWorkflowRequest struct {
	InstanceId        string            `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	WorkflowComponent string            `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	WorkflowName      string            `protobuf:"bytes,3,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	Options           map[string]string `` /* 155-byte string literal not displayed */
	Input             []byte            `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowRequest) GetInput added in v1.10.0 

func (x *StartWorkflowRequest) GetInput() []byte

func (*StartWorkflowRequest) GetInstanceId added in v1.10.0 

func (x *StartWorkflowRequest) GetInstanceId() string

func (*StartWorkflowRequest) GetOptions added in v1.10.0 

func (x *StartWorkflowRequest) GetOptions() map[string]string

func (*StartWorkflowRequest) GetWorkflowComponent added in v1.10.0 

func (x *StartWorkflowRequest) GetWorkflowComponent() string

func (*StartWorkflowRequest) GetWorkflowName added in v1.10.0 

func (x *StartWorkflowRequest) GetWorkflowName() string

func (*StartWorkflowRequest) ProtoMessage added in v1.10.0 

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) ProtoReflect added in v1.10.0 

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

func (*StartWorkflowRequest) Reset added in v1.10.0 

func (x *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) String added in v1.10.0 

func (x *StartWorkflowRequest) String() string

type SubscribeConfigurationRequest added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use SubscribeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationRequest) GetKeys added in v1.5.0 

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

func (*SubscribeConfigurationRequest) GetMetadata added in v1.5.0 

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

func (*SubscribeConfigurationRequest) GetStoreName added in v1.5.0 

func (x *SubscribeConfigurationRequest) GetStoreName() string

func (*SubscribeConfigurationRequest) ProtoMessage added in v1.5.0 

func (*SubscribeConfigurationRequest) ProtoMessage()

func (*SubscribeConfigurationRequest) ProtoReflect added in v1.5.0 

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

func (*SubscribeConfigurationRequest) Reset added in v1.5.0 

func (x *SubscribeConfigurationRequest) Reset()

func (*SubscribeConfigurationRequest) String added in v1.5.0 

func (x *SubscribeConfigurationRequest) String() string

type SubscribeConfigurationResponse added in v1.5.0 

type SubscribeConfigurationResponse struct {

	// Subscribe id, used to stop subscription.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The list of items containing configuration values
	Items map[string]*v1.ConfigurationItem `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SubscribeConfigurationResponse) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use SubscribeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationResponse) GetId added in v1.7.0 

func (x *SubscribeConfigurationResponse) GetId() string

func (*SubscribeConfigurationResponse) GetItems added in v1.5.0 

func (x *SubscribeConfigurationResponse) GetItems() map[string]*v1.ConfigurationItem

func (*SubscribeConfigurationResponse) ProtoMessage added in v1.5.0 

func (*SubscribeConfigurationResponse) ProtoMessage()

func (*SubscribeConfigurationResponse) ProtoReflect added in v1.5.0 

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

func (*SubscribeConfigurationResponse) Reset added in v1.5.0 

func (x *SubscribeConfigurationResponse) Reset()

func (*SubscribeConfigurationResponse) String added in v1.5.0 

func (x *SubscribeConfigurationResponse) String() string

type TerminateWorkflowRequest added in v1.10.0 

type TerminateWorkflowRequest struct {
	InstanceId        string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateWorkflowRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TerminateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowRequest) GetInstanceId added in v1.10.0 

func (x *TerminateWorkflowRequest) GetInstanceId() string

func (*TerminateWorkflowRequest) GetWorkflowComponent added in v1.10.0 

func (x *TerminateWorkflowRequest) GetWorkflowComponent() string

func (*TerminateWorkflowRequest) ProtoMessage added in v1.10.0 

func (*TerminateWorkflowRequest) ProtoMessage()

func (*TerminateWorkflowRequest) ProtoReflect added in v1.10.0 

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

func (*TerminateWorkflowRequest) Reset added in v1.10.0 

func (x *TerminateWorkflowRequest) Reset()

func (*TerminateWorkflowRequest) String added in v1.10.0 

func (x *TerminateWorkflowRequest) String() string

type TerminateWorkflowResponse added in v1.10.0 

type TerminateWorkflowResponse struct {
	// contains filtered or unexported fields
}

func (*TerminateWorkflowResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TerminateWorkflowResponse.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowResponse) ProtoMessage added in v1.10.0 

func (*TerminateWorkflowResponse) ProtoMessage()

func (*TerminateWorkflowResponse) ProtoReflect added in v1.10.0 

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

func (*TerminateWorkflowResponse) Reset added in v1.10.0 

func (x *TerminateWorkflowResponse) Reset()

func (*TerminateWorkflowResponse) String added in v1.10.0 

func (x *TerminateWorkflowResponse) String() string

type TopicEventBulkRequest added in v1.10.0 

type TopicEventBulkRequest struct {

	// Unique identifier for the bulk request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The list of items inside this bulk request.
	Entries []*TopicEventBulkRequestEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// The metadata associated with the this bulk request.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The pubsub topic which publisher sent to.
	Topic string `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	// The name of the pubsub the publisher sent to.
	PubsubName string `protobuf:"bytes,5,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// The type of event related to the originating occurrence.
	Type string `protobuf:"bytes,6,opt,name=type,proto3" json:"type,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,7,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

TopicEventBulkRequest represents request for bulk message

func (*TopicEventBulkRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TopicEventBulkRequest.ProtoReflect.Descriptor instead.

func (*TopicEventBulkRequest) GetEntries added in v1.10.0 

func (x *TopicEventBulkRequest) GetEntries() []*TopicEventBulkRequestEntry

func (*TopicEventBulkRequest) GetId added in v1.10.0 

func (x *TopicEventBulkRequest) GetId() string

func (*TopicEventBulkRequest) GetMetadata added in v1.10.0 

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

func (*TopicEventBulkRequest) GetPath added in v1.10.0 

func (x *TopicEventBulkRequest) GetPath() string

func (*TopicEventBulkRequest) GetPubsubName added in v1.10.0 

func (x *TopicEventBulkRequest) GetPubsubName() string

func (*TopicEventBulkRequest) GetTopic added in v1.10.0 

func (x *TopicEventBulkRequest) GetTopic() string

func (*TopicEventBulkRequest) GetType added in v1.10.0 

func (x *TopicEventBulkRequest) GetType() string

func (*TopicEventBulkRequest) ProtoMessage added in v1.10.0 

func (*TopicEventBulkRequest) ProtoMessage()

func (*TopicEventBulkRequest) ProtoReflect added in v1.10.0 

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

func (*TopicEventBulkRequest) Reset added in v1.10.0 

func (x *TopicEventBulkRequest) Reset()

func (*TopicEventBulkRequest) String added in v1.10.0 

func (x *TopicEventBulkRequest) String() string

type TopicEventBulkRequestEntry added in v1.10.0 

type TopicEventBulkRequestEntry struct {

	// Unique identifier for the message.
	EntryId string `protobuf:"bytes,1,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// The content of the event.
	//
	// Types that are assignable to Event:
	//
	//	*TopicEventBulkRequestEntry_Bytes
	//	*TopicEventBulkRequestEntry_CloudEvent
	Event isTopicEventBulkRequestEntry_Event `protobuf_oneof:"event"`
	// content type of the event contained.
	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// The metadata associated with the event.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicEventBulkRequestEntry represents a single message inside a bulk request

func (*TopicEventBulkRequestEntry) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TopicEventBulkRequestEntry.ProtoReflect.Descriptor instead.

func (*TopicEventBulkRequestEntry) GetBytes added in v1.10.0 

func (x *TopicEventBulkRequestEntry) GetBytes() []byte

func (*TopicEventBulkRequestEntry) GetCloudEvent added in v1.10.0 

func (x *TopicEventBulkRequestEntry) GetCloudEvent() *TopicEventCERequest

func (*TopicEventBulkRequestEntry) GetContentType added in v1.10.0 

func (x *TopicEventBulkRequestEntry) GetContentType() string

func (*TopicEventBulkRequestEntry) GetEntryId added in v1.10.0 

func (x *TopicEventBulkRequestEntry) GetEntryId() string

func (*TopicEventBulkRequestEntry) GetEvent added in v1.10.0 

func (m *TopicEventBulkRequestEntry) GetEvent() isTopicEventBulkRequestEntry_Event

func (*TopicEventBulkRequestEntry) GetMetadata added in v1.10.0 

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

func (*TopicEventBulkRequestEntry) ProtoMessage added in v1.10.0 

func (*TopicEventBulkRequestEntry) ProtoMessage()

func (*TopicEventBulkRequestEntry) ProtoReflect added in v1.10.0 

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

func (*TopicEventBulkRequestEntry) Reset added in v1.10.0 

func (x *TopicEventBulkRequestEntry) Reset()

func (*TopicEventBulkRequestEntry) String added in v1.10.0 

func (x *TopicEventBulkRequestEntry) String() string

type TopicEventBulkRequestEntry_Bytes added in v1.10.0 

type TopicEventBulkRequestEntry_Bytes struct {
	Bytes []byte `protobuf:"bytes,2,opt,name=bytes,proto3,oneof"`
}

type TopicEventBulkRequestEntry_CloudEvent added in v1.10.0 

type TopicEventBulkRequestEntry_CloudEvent struct {
	CloudEvent *TopicEventCERequest `protobuf:"bytes,3,opt,name=cloud_event,json=cloudEvent,proto3,oneof"`
}

type TopicEventBulkResponse added in v1.10.0 

type TopicEventBulkResponse struct {

	// The list of all responses for the bulk request.
	Statuses []*TopicEventBulkResponseEntry `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

AppBulkResponse is response from app on published message

func (*TopicEventBulkResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TopicEventBulkResponse.ProtoReflect.Descriptor instead.

func (*TopicEventBulkResponse) GetStatuses added in v1.10.0 

func (x *TopicEventBulkResponse) GetStatuses() []*TopicEventBulkResponseEntry

func (*TopicEventBulkResponse) ProtoMessage added in v1.10.0 

func (*TopicEventBulkResponse) ProtoMessage()

func (*TopicEventBulkResponse) ProtoReflect added in v1.10.0 

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

func (*TopicEventBulkResponse) Reset added in v1.10.0 

func (x *TopicEventBulkResponse) Reset()

func (*TopicEventBulkResponse) String added in v1.10.0 

func (x *TopicEventBulkResponse) String() string

type TopicEventBulkResponseEntry added in v1.10.0 

type TopicEventBulkResponseEntry struct {

	// Unique identifier associated the message.
	EntryId string `protobuf:"bytes,1,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// The status of the response.
	Status TopicEventResponse_TopicEventResponseStatus `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicEventBulkResponseEntry Represents single response, as part of TopicEventBulkResponse, to be sent by subscibed App for the corresponding single message during bulk subscribe

func (*TopicEventBulkResponseEntry) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TopicEventBulkResponseEntry.ProtoReflect.Descriptor instead.

func (*TopicEventBulkResponseEntry) GetEntryId added in v1.10.0 

func (x *TopicEventBulkResponseEntry) GetEntryId() string

func (*TopicEventBulkResponseEntry) GetStatus added in v1.10.0 

func (x *TopicEventBulkResponseEntry) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventBulkResponseEntry) ProtoMessage added in v1.10.0 

func (*TopicEventBulkResponseEntry) ProtoMessage()

func (*TopicEventBulkResponseEntry) ProtoReflect added in v1.10.0 

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

func (*TopicEventBulkResponseEntry) Reset added in v1.10.0 

func (x *TopicEventBulkResponseEntry) Reset()

func (*TopicEventBulkResponseEntry) String added in v1.10.0 

func (x *TopicEventBulkResponseEntry) String() string

type TopicEventCERequest added in v1.10.0 

type TopicEventCERequest struct {

	// The unique identifier of this cloud event.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// source identifies the context in which an event happened.
	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,6,opt,name=data,proto3" json:"data,omitempty"`
	// Custom attributes which includes cloud event extensions.
	Extensions *structpb.Struct `protobuf:"bytes,7,opt,name=extensions,proto3" json:"extensions,omitempty"`
	// contains filtered or unexported fields
}

TopicEventCERequest message is compatible with CloudEvent spec v1.0

func (*TopicEventCERequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use TopicEventCERequest.ProtoReflect.Descriptor instead.

func (*TopicEventCERequest) GetData added in v1.10.0 

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

func (*TopicEventCERequest) GetDataContentType added in v1.10.0 

func (x *TopicEventCERequest) GetDataContentType() string

func (*TopicEventCERequest) GetExtensions added in v1.10.0 

func (x *TopicEventCERequest) GetExtensions() *structpb.Struct

func (*TopicEventCERequest) GetId added in v1.10.0 

func (x *TopicEventCERequest) GetId() string

func (*TopicEventCERequest) GetSource added in v1.10.0 

func (x *TopicEventCERequest) GetSource() string

func (*TopicEventCERequest) GetSpecVersion added in v1.10.0 

func (x *TopicEventCERequest) GetSpecVersion() string

func (*TopicEventCERequest) GetType added in v1.10.0 

func (x *TopicEventCERequest) GetType() string

func (*TopicEventCERequest) ProtoMessage added in v1.10.0 

func (*TopicEventCERequest) ProtoMessage()

func (*TopicEventCERequest) ProtoReflect added in v1.10.0 

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

func (*TopicEventCERequest) Reset added in v1.10.0 

func (x *TopicEventCERequest) Reset()

func (*TopicEventCERequest) String added in v1.10.0 

func (x *TopicEventCERequest) 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"`
	// 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"`
	// The map of additional custom properties to be sent to the app. These are considered to be cloud event extensions.
	Extensions *structpb.Struct `protobuf:"bytes,10,opt,name=extensions,proto3" json:"extensions,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) GetExtensions added in v1.10.0 

func (x *TopicEventRequest) GetExtensions() *structpb.Struct

func (*TopicEventRequest) GetId 

func (x *TopicEventRequest) GetId() string

func (*TopicEventRequest) GetPath added in v1.4.0 

func (x *TopicEventRequest) GetPath() string

func (*TopicEventRequest) GetPubsubName added in v0.10.0 

func (x *TopicEventRequest) GetPubsubName() string

func (*TopicEventRequest) GetSource 

func (x *TopicEventRequest) GetSource() string

func (*TopicEventRequest) GetSpecVersion 

func (x *TopicEventRequest) GetSpecVersion() string

func (*TopicEventRequest) GetTopic 

func (x *TopicEventRequest) GetTopic() string

func (*TopicEventRequest) GetType 

func (x *TopicEventRequest) GetType() string

func (*TopicEventRequest) ProtoMessage 

func (*TopicEventRequest) ProtoMessage()

func (*TopicEventRequest) ProtoReflect added in v1.0.0 

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

func (*TopicEventRequest) Reset 

func (x *TopicEventRequest) Reset()

func (*TopicEventRequest) String 

func (x *TopicEventRequest) String() string

type TopicEventResponse added in v0.10.0 

type TopicEventResponse struct {

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

TopicEventResponse is response from app on published message

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

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

Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.

func (*TopicEventResponse) GetStatus added in v0.11.0 

func (x *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventResponse) ProtoMessage added in v0.10.0 

func (*TopicEventResponse) ProtoMessage()

func (*TopicEventResponse) ProtoReflect added in v1.0.0 

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

func (*TopicEventResponse) Reset added in v0.10.0 

func (x *TopicEventResponse) Reset()

func (*TopicEventResponse) String added in v0.10.0 

func (x *TopicEventResponse) String() string

type TopicEventResponse_TopicEventResponseStatus added in v0.11.0 

type TopicEventResponse_TopicEventResponseStatus int32

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

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

func (TopicEventResponse_TopicEventResponseStatus) Descriptor added in v1.0.0 

func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (TopicEventResponse_TopicEventResponseStatus) Enum added in v1.0.0 

func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

func (TopicEventResponse_TopicEventResponseStatus) EnumDescriptor deprecated added in v0.11.0 

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

Deprecated: Use TopicEventResponse_TopicEventResponseStatus.Descriptor instead.

func (TopicEventResponse_TopicEventResponseStatus) Number added in v1.0.0 

func (x TopicEventResponse_TopicEventResponseStatus) Number() protoreflect.EnumNumber

func (TopicEventResponse_TopicEventResponseStatus) String added in v0.11.0 

func (x TopicEventResponse_TopicEventResponseStatus) String() string

func (TopicEventResponse_TopicEventResponseStatus) Type added in v1.0.0 

func (TopicEventResponse_TopicEventResponseStatus) Type() protoreflect.EnumType

type TopicRoutes added in v1.4.0 

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 added in v1.4.0 

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

Deprecated: Use TopicRoutes.ProtoReflect.Descriptor instead.

func (*TopicRoutes) GetDefault added in v1.4.0 

func (x *TopicRoutes) GetDefault() string

func (*TopicRoutes) GetRules added in v1.4.0 

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

func (*TopicRoutes) ProtoMessage added in v1.4.0 

func (*TopicRoutes) ProtoMessage()

func (*TopicRoutes) ProtoReflect added in v1.4.0 

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

func (*TopicRoutes) Reset added in v1.4.0 

func (x *TopicRoutes) Reset()

func (*TopicRoutes) String added in v1.4.0 

func (x *TopicRoutes) String() string

type TopicRule added in v1.4.0 

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 added in v1.4.0 

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

Deprecated: Use TopicRule.ProtoReflect.Descriptor instead.

func (*TopicRule) GetMatch added in v1.4.0 

func (x *TopicRule) GetMatch() string

func (*TopicRule) GetPath added in v1.4.0 

func (x *TopicRule) GetPath() string

func (*TopicRule) ProtoMessage added in v1.4.0 

func (*TopicRule) ProtoMessage()

func (*TopicRule) ProtoReflect added in v1.4.0 

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

func (*TopicRule) Reset added in v1.4.0 

func (x *TopicRule) Reset()

func (*TopicRule) String added in v1.4.0 

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"`
	// The optional dead letter queue for this topic to send events to.
	DeadLetterTopic string `protobuf:"bytes,6,opt,name=dead_letter_topic,json=deadLetterTopic,proto3" json:"dead_letter_topic,omitempty"`
	// The optional bulk subscribe settings for this topic.
	BulkSubscribe *BulkSubscribeConfig `protobuf:"bytes,7,opt,name=bulk_subscribe,json=bulkSubscribe,proto3" json:"bulk_subscribe,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) GetBulkSubscribe added in v1.10.0 

func (x *TopicSubscription) GetBulkSubscribe() *BulkSubscribeConfig

func (*TopicSubscription) GetDeadLetterTopic added in v1.8.0 

func (x *TopicSubscription) GetDeadLetterTopic() string

func (*TopicSubscription) GetMetadata 

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

func (*TopicSubscription) GetPubsubName added in v0.10.0 

func (x *TopicSubscription) GetPubsubName() string

func (*TopicSubscription) GetRoutes added in v1.4.0 

func (x *TopicSubscription) GetRoutes() *TopicRoutes

func (*TopicSubscription) GetTopic 

func (x *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage 

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect added in v1.0.0 

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

func (*TopicSubscription) Reset 

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String 

func (x *TopicSubscription) String() string

type TransactionalActorStateOperation added in v1.0.0 

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

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

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

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

Deprecated: Use TransactionalActorStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalActorStateOperation) GetKey added in v1.0.0 

func (x *TransactionalActorStateOperation) GetKey() string

func (*TransactionalActorStateOperation) GetOperationType added in v1.0.0 

func (x *TransactionalActorStateOperation) GetOperationType() string

func (*TransactionalActorStateOperation) GetValue added in v1.0.0 

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

func (*TransactionalActorStateOperation) ProtoMessage added in v1.0.0 

func (*TransactionalActorStateOperation) ProtoMessage()

func (*TransactionalActorStateOperation) ProtoReflect added in v1.0.0 

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

func (*TransactionalActorStateOperation) Reset added in v1.0.0 

func (x *TransactionalActorStateOperation) Reset()

func (*TransactionalActorStateOperation) String added in v1.0.0 

func (x *TransactionalActorStateOperation) String() string

type TransactionalStateOperation added in v0.10.0 

type TransactionalStateOperation struct {

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

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

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

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

Deprecated: Use TransactionalStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalStateOperation) GetOperationType added in v0.10.0 

func (x *TransactionalStateOperation) GetOperationType() string

func (*TransactionalStateOperation) GetRequest added in v0.10.0 

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

func (*TransactionalStateOperation) ProtoMessage added in v0.10.0 

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect added in v1.0.0 

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

func (*TransactionalStateOperation) Reset added in v0.10.0 

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String added in v0.10.0 

func (x *TransactionalStateOperation) String() string

type TryLockRequest added in v1.8.0 

type TryLockRequest struct {

	// Required. The lock store name,e.g. `redis`.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. resource_id is the lock key. e.g. `order_id_111`
	// It stands for "which resource I want to protect"
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Required. lock_owner indicate the identifier of lock owner.
	// You can generate a uuid as lock_owner.For example,in golang:
	//
	// req.LockOwner = uuid.New().String()
	//
	// This field is per request,not per process,so it is different for each request,
	// which aims to prevent multi-thread in the same process trying the same lock concurrently.
	//
	// The reason why we don't make it automatically generated is:
	// 1. If it is automatically generated,there must be a 'my_lock_owner_id' field in the response.
	// This name is so weird that we think it is inappropriate to put it into the api spec
	// 2. If we change the field 'my_lock_owner_id' in the response to 'lock_owner',which means the current lock owner of this lock,
	// we find that in some lock services users can't get the current lock owner.Actually users don't need it at all.
	// 3. When reentrant lock is needed,the existing lock_owner is required to identify client and check "whether this client can reenter this lock".
	// So this field in the request shouldn't be removed.
	LockOwner string `protobuf:"bytes,3,opt,name=lock_owner,json=lockOwner,proto3" json:"lock_owner,omitempty"`
	// Required. The time before expiry.The time unit is second.
	ExpiryInSeconds int32 `protobuf:"varint,4,opt,name=expiryInSeconds,proto3" json:"expiryInSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*TryLockRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use TryLockRequest.ProtoReflect.Descriptor instead.

func (*TryLockRequest) GetExpiryInSeconds added in v1.8.0 

func (x *TryLockRequest) GetExpiryInSeconds() int32

func (*TryLockRequest) GetLockOwner added in v1.8.0 

func (x *TryLockRequest) GetLockOwner() string

func (*TryLockRequest) GetResourceId added in v1.8.0 

func (x *TryLockRequest) GetResourceId() string

func (*TryLockRequest) GetStoreName added in v1.8.0 

func (x *TryLockRequest) GetStoreName() string

func (*TryLockRequest) ProtoMessage added in v1.8.0 

func (*TryLockRequest) ProtoMessage()

func (*TryLockRequest) ProtoReflect added in v1.8.0 

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

func (*TryLockRequest) Reset added in v1.8.0 

func (x *TryLockRequest) Reset()

func (*TryLockRequest) String added in v1.8.0 

func (x *TryLockRequest) String() string

type TryLockResponse added in v1.8.0 

type TryLockResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*TryLockResponse) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use TryLockResponse.ProtoReflect.Descriptor instead.

func (*TryLockResponse) GetSuccess added in v1.8.0 

func (x *TryLockResponse) GetSuccess() bool

func (*TryLockResponse) ProtoMessage added in v1.8.0 

func (*TryLockResponse) ProtoMessage()

func (*TryLockResponse) ProtoReflect added in v1.8.0 

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

func (*TryLockResponse) Reset added in v1.8.0 

func (x *TryLockResponse) Reset()

func (*TryLockResponse) String added in v1.8.0 

func (x *TryLockResponse) String() string

type UnimplementedAppCallbackAlphaServer added in v1.10.0 

type UnimplementedAppCallbackAlphaServer struct {
}

UnimplementedAppCallbackAlphaServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackAlphaServer) OnBulkTopicEventAlpha1 added in v1.10.0 

func (UnimplementedAppCallbackAlphaServer) OnBulkTopicEventAlpha1(context.Context, *TopicEventBulkRequest) (*TopicEventBulkResponse, error)

type UnimplementedAppCallbackHealthCheckServer added in v1.9.0 

type UnimplementedAppCallbackHealthCheckServer struct {
}

UnimplementedAppCallbackHealthCheckServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackHealthCheckServer) HealthCheck added in v1.9.0 

func (UnimplementedAppCallbackHealthCheckServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)

type UnimplementedAppCallbackServer 

type UnimplementedAppCallbackServer struct {
}

UnimplementedAppCallbackServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackServer) ListInputBindings 

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

func (UnimplementedAppCallbackServer) ListTopicSubscriptions 

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

func (UnimplementedAppCallbackServer) OnBindingEvent 

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

func (UnimplementedAppCallbackServer) OnInvoke 

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

func (UnimplementedAppCallbackServer) OnTopicEvent 

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

type UnimplementedDaprServer 

type UnimplementedDaprServer struct {
}

UnimplementedDaprServer should be embedded to have forward compatible implementations.

func (UnimplementedDaprServer) BulkPublishEventAlpha1 added in v1.10.0 

func (UnimplementedDaprServer) BulkPublishEventAlpha1(context.Context, *BulkPublishRequest) (*BulkPublishResponse, error)

func (UnimplementedDaprServer) DeleteBulkState added in v1.0.0 

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

func (UnimplementedDaprServer) DeleteState 

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

func (UnimplementedDaprServer) ExecuteActorStateTransaction added in v1.0.0 

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

func (UnimplementedDaprServer) ExecuteStateTransaction added in v0.10.0 

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

func (UnimplementedDaprServer) GetActorState added in v1.0.0 

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

func (UnimplementedDaprServer) GetBulkSecret added in v1.0.0 

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

func (UnimplementedDaprServer) GetBulkState added in v0.10.0 

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

func (UnimplementedDaprServer) GetConfigurationAlpha1 added in v1.5.0 

func (UnimplementedDaprServer) GetConfigurationAlpha1(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (UnimplementedDaprServer) GetMetadata added in v1.0.0 

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

func (UnimplementedDaprServer) GetSecret 

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

func (UnimplementedDaprServer) GetState 

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

func (UnimplementedDaprServer) GetWorkflowAlpha1 added in v1.10.0 

func (UnimplementedDaprServer) GetWorkflowAlpha1(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)

func (UnimplementedDaprServer) InvokeActor added in v1.0.0 

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

func (UnimplementedDaprServer) InvokeBinding 

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

func (UnimplementedDaprServer) InvokeService 

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

func (UnimplementedDaprServer) PublishEvent 

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

func (UnimplementedDaprServer) QueryStateAlpha1 added in v1.5.0 

func (UnimplementedDaprServer) QueryStateAlpha1(context.Context, *QueryStateRequest) (*QueryStateResponse, error)

func (UnimplementedDaprServer) RegisterActorReminder added in v1.0.0 

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

func (UnimplementedDaprServer) RegisterActorTimer added in v1.0.0 

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

func (UnimplementedDaprServer) RenameActorReminder added in v1.6.0 

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

func (UnimplementedDaprServer) SaveState 

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

func (UnimplementedDaprServer) SetMetadata added in v1.0.0 

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

func (UnimplementedDaprServer) Shutdown added in v1.1.0 

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

func (UnimplementedDaprServer) StartWorkflowAlpha1 added in v1.10.0 

func (UnimplementedDaprServer) StartWorkflowAlpha1(context.Context, *StartWorkflowRequest) (*WorkflowReference, error)

func (UnimplementedDaprServer) SubscribeConfigurationAlpha1 added in v1.5.0 

func (UnimplementedDaprServer) SubscribeConfigurationAlpha1(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationAlpha1Server) error

func (UnimplementedDaprServer) TerminateWorkflowAlpha1 added in v1.10.0 

func (UnimplementedDaprServer) TerminateWorkflowAlpha1(context.Context, *TerminateWorkflowRequest) (*TerminateWorkflowResponse, error)

func (UnimplementedDaprServer) TryLockAlpha1 added in v1.8.0 

func (UnimplementedDaprServer) TryLockAlpha1(context.Context, *TryLockRequest) (*TryLockResponse, error)

func (UnimplementedDaprServer) UnlockAlpha1 added in v1.8.0 

func (UnimplementedDaprServer) UnlockAlpha1(context.Context, *UnlockRequest) (*UnlockResponse, error)

func (UnimplementedDaprServer) UnregisterActorReminder added in v1.0.0 

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

func (UnimplementedDaprServer) UnregisterActorTimer added in v1.0.0 

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

func (UnimplementedDaprServer) UnsubscribeConfigurationAlpha1 added in v1.7.0 

func (UnimplementedDaprServer) UnsubscribeConfigurationAlpha1(context.Context, *UnsubscribeConfigurationRequest) (*UnsubscribeConfigurationResponse, error)

type UnlockRequest added in v1.8.0 

type UnlockRequest struct {
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// resource_id is the lock key.
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	LockOwner  string `protobuf:"bytes,3,opt,name=lock_owner,json=lockOwner,proto3" json:"lock_owner,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlockRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use UnlockRequest.ProtoReflect.Descriptor instead.

func (*UnlockRequest) GetLockOwner added in v1.8.0 

func (x *UnlockRequest) GetLockOwner() string

func (*UnlockRequest) GetResourceId added in v1.8.0 

func (x *UnlockRequest) GetResourceId() string

func (*UnlockRequest) GetStoreName added in v1.8.0 

func (x *UnlockRequest) GetStoreName() string

func (*UnlockRequest) ProtoMessage added in v1.8.0 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) ProtoReflect added in v1.8.0 

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

func (*UnlockRequest) Reset added in v1.8.0 

func (x *UnlockRequest) Reset()

func (*UnlockRequest) String added in v1.8.0 

func (x *UnlockRequest) String() string

type UnlockResponse added in v1.8.0 

type UnlockResponse struct {
	Status UnlockResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=dapr.proto.runtime.v1.UnlockResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlockResponse) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use UnlockResponse.ProtoReflect.Descriptor instead.

func (*UnlockResponse) GetStatus added in v1.8.0 

func (x *UnlockResponse) GetStatus() UnlockResponse_Status

func (*UnlockResponse) ProtoMessage added in v1.8.0 

func (*UnlockResponse) ProtoMessage()

func (*UnlockResponse) ProtoReflect added in v1.8.0 

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

func (*UnlockResponse) Reset added in v1.8.0 

func (x *UnlockResponse) Reset()

func (*UnlockResponse) String added in v1.8.0 

func (x *UnlockResponse) String() string

type UnlockResponse_Status added in v1.8.0 

type UnlockResponse_Status int32
const (
	UnlockResponse_SUCCESS                UnlockResponse_Status = 0
	UnlockResponse_LOCK_DOES_NOT_EXIST    UnlockResponse_Status = 1
	UnlockResponse_LOCK_BELONGS_TO_OTHERS UnlockResponse_Status = 2
	UnlockResponse_INTERNAL_ERROR         UnlockResponse_Status = 3
)

func (UnlockResponse_Status) Descriptor added in v1.8.0 

func (UnlockResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (UnlockResponse_Status) Enum added in v1.8.0 

func (x UnlockResponse_Status) Enum() *UnlockResponse_Status

func (UnlockResponse_Status) EnumDescriptor deprecated added in v1.8.0 

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

Deprecated: Use UnlockResponse_Status.Descriptor instead.

func (UnlockResponse_Status) Number added in v1.8.0 

func (x UnlockResponse_Status) Number() protoreflect.EnumNumber

func (UnlockResponse_Status) String added in v1.8.0 

func (x UnlockResponse_Status) String() string

func (UnlockResponse_Status) Type added in v1.8.0 

func (UnlockResponse_Status) Type() protoreflect.EnumType

type UnregisterActorReminderRequest added in v1.0.0 

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

UnregisterActorReminderRequest is the message to unregister an actor reminder.

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

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

Deprecated: Use UnregisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorReminderRequest) GetActorId added in v1.0.0 

func (x *UnregisterActorReminderRequest) GetActorId() string

func (*UnregisterActorReminderRequest) GetActorType added in v1.0.0 

func (x *UnregisterActorReminderRequest) GetActorType() string

func (*UnregisterActorReminderRequest) GetName added in v1.0.0 

func (x *UnregisterActorReminderRequest) GetName() string

func (*UnregisterActorReminderRequest) ProtoMessage added in v1.0.0 

func (*UnregisterActorReminderRequest) ProtoMessage()

func (*UnregisterActorReminderRequest) ProtoReflect added in v1.0.0 

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

func (*UnregisterActorReminderRequest) Reset added in v1.0.0 

func (x *UnregisterActorReminderRequest) Reset()

func (*UnregisterActorReminderRequest) String added in v1.0.0 

func (x *UnregisterActorReminderRequest) String() string

type UnregisterActorTimerRequest added in v1.0.0 

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

UnregisterActorTimerRequest is the message to unregister an actor timer

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

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

Deprecated: Use UnregisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorTimerRequest) GetActorId added in v1.0.0 

func (x *UnregisterActorTimerRequest) GetActorId() string

func (*UnregisterActorTimerRequest) GetActorType added in v1.0.0 

func (x *UnregisterActorTimerRequest) GetActorType() string

func (*UnregisterActorTimerRequest) GetName added in v1.0.0 

func (x *UnregisterActorTimerRequest) GetName() string

func (*UnregisterActorTimerRequest) ProtoMessage added in v1.0.0 

func (*UnregisterActorTimerRequest) ProtoMessage()

func (*UnregisterActorTimerRequest) ProtoReflect added in v1.0.0 

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

func (*UnregisterActorTimerRequest) Reset added in v1.0.0 

func (x *UnregisterActorTimerRequest) Reset()

func (*UnregisterActorTimerRequest) String added in v1.0.0 

func (x *UnregisterActorTimerRequest) String() string

type UnsafeAppCallbackAlphaServer added in v1.10.0 

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

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

type UnsafeAppCallbackHealthCheckServer added in v1.9.0 

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

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

type UnsafeAppCallbackServer added in v1.0.0 

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

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

type UnsafeDaprServer added in v1.0.0 

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

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

type UnsubscribeConfigurationRequest added in v1.7.0 

type UnsubscribeConfigurationRequest struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The id to unsubscribe.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

UnSubscribeConfigurationRequest is the message to stop watching the key-value configuration.

func (*UnsubscribeConfigurationRequest) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use UnsubscribeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeConfigurationRequest) GetId added in v1.7.0 

func (x *UnsubscribeConfigurationRequest) GetId() string

func (*UnsubscribeConfigurationRequest) GetStoreName added in v1.7.0 

func (x *UnsubscribeConfigurationRequest) GetStoreName() string

func (*UnsubscribeConfigurationRequest) ProtoMessage added in v1.7.0 

func (*UnsubscribeConfigurationRequest) ProtoMessage()

func (*UnsubscribeConfigurationRequest) ProtoReflect added in v1.7.0 

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

func (*UnsubscribeConfigurationRequest) Reset added in v1.7.0 

func (x *UnsubscribeConfigurationRequest) Reset()

func (*UnsubscribeConfigurationRequest) String added in v1.7.0 

func (x *UnsubscribeConfigurationRequest) String() string

type UnsubscribeConfigurationResponse added in v1.7.0 

type UnsubscribeConfigurationResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeConfigurationResponse) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use UnsubscribeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*UnsubscribeConfigurationResponse) GetMessage added in v1.7.0 

func (x *UnsubscribeConfigurationResponse) GetMessage() string

func (*UnsubscribeConfigurationResponse) GetOk added in v1.7.0 

func (x *UnsubscribeConfigurationResponse) GetOk() bool

func (*UnsubscribeConfigurationResponse) ProtoMessage added in v1.7.0 

func (*UnsubscribeConfigurationResponse) ProtoMessage()

func (*UnsubscribeConfigurationResponse) ProtoReflect added in v1.7.0 

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

func (*UnsubscribeConfigurationResponse) Reset added in v1.7.0 

func (x *UnsubscribeConfigurationResponse) Reset()

func (*UnsubscribeConfigurationResponse) String added in v1.7.0 

func (x *UnsubscribeConfigurationResponse) String() string

type WorkflowReference added in v1.10.0 

type WorkflowReference struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowReference) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use WorkflowReference.ProtoReflect.Descriptor instead.

func (*WorkflowReference) GetInstanceId added in v1.10.0 

func (x *WorkflowReference) GetInstanceId() string

func (*WorkflowReference) ProtoMessage added in v1.10.0 

func (*WorkflowReference) ProtoMessage()

func (*WorkflowReference) ProtoReflect added in v1.10.0 

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

func (*WorkflowReference) Reset added in v1.10.0 

func (x *WorkflowReference) Reset()

func (*WorkflowReference) String added in v1.10.0 

func (x *WorkflowReference) String() string

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.