runtime

package
v0.0.0-...-949823d Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2024 License: Apache-2.0 Imports: 16 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	AppCallback_OnInvoke_FullMethodName               = "/dapr.proto.runtime.v1.AppCallback/OnInvoke"
	AppCallback_ListTopicSubscriptions_FullMethodName = "/dapr.proto.runtime.v1.AppCallback/ListTopicSubscriptions"
	AppCallback_OnTopicEvent_FullMethodName           = "/dapr.proto.runtime.v1.AppCallback/OnTopicEvent"
	AppCallback_ListInputBindings_FullMethodName      = "/dapr.proto.runtime.v1.AppCallback/ListInputBindings"
	AppCallback_OnBindingEvent_FullMethodName         = "/dapr.proto.runtime.v1.AppCallback/OnBindingEvent"
)
View Source 
const (
	AppCallbackAlpha_OnBulkTopicEventAlpha1_FullMethodName = "/dapr.proto.runtime.v1.AppCallbackAlpha/OnBulkTopicEventAlpha1"
	AppCallbackAlpha_OnJobEventAlpha1_FullMethodName       = "/dapr.proto.runtime.v1.AppCallbackAlpha/OnJobEventAlpha1"
)
View Source 
const (
	Dapr_InvokeService_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/InvokeService"
	Dapr_GetState_FullMethodName                       = "/dapr.proto.runtime.v1.Dapr/GetState"
	Dapr_GetBulkState_FullMethodName                   = "/dapr.proto.runtime.v1.Dapr/GetBulkState"
	Dapr_SaveState_FullMethodName                      = "/dapr.proto.runtime.v1.Dapr/SaveState"
	Dapr_QueryStateAlpha1_FullMethodName               = "/dapr.proto.runtime.v1.Dapr/QueryStateAlpha1"
	Dapr_DeleteState_FullMethodName                    = "/dapr.proto.runtime.v1.Dapr/DeleteState"
	Dapr_DeleteBulkState_FullMethodName                = "/dapr.proto.runtime.v1.Dapr/DeleteBulkState"
	Dapr_ExecuteStateTransaction_FullMethodName        = "/dapr.proto.runtime.v1.Dapr/ExecuteStateTransaction"
	Dapr_PublishEvent_FullMethodName                   = "/dapr.proto.runtime.v1.Dapr/PublishEvent"
	Dapr_BulkPublishEventAlpha1_FullMethodName         = "/dapr.proto.runtime.v1.Dapr/BulkPublishEventAlpha1"
	Dapr_SubscribeTopicEventsAlpha1_FullMethodName     = "/dapr.proto.runtime.v1.Dapr/SubscribeTopicEventsAlpha1"
	Dapr_InvokeBinding_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/InvokeBinding"
	Dapr_GetSecret_FullMethodName                      = "/dapr.proto.runtime.v1.Dapr/GetSecret"
	Dapr_GetBulkSecret_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/GetBulkSecret"
	Dapr_RegisterActorTimer_FullMethodName             = "/dapr.proto.runtime.v1.Dapr/RegisterActorTimer"
	Dapr_UnregisterActorTimer_FullMethodName           = "/dapr.proto.runtime.v1.Dapr/UnregisterActorTimer"
	Dapr_RegisterActorReminder_FullMethodName          = "/dapr.proto.runtime.v1.Dapr/RegisterActorReminder"
	Dapr_UnregisterActorReminder_FullMethodName        = "/dapr.proto.runtime.v1.Dapr/UnregisterActorReminder"
	Dapr_GetActorState_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/GetActorState"
	Dapr_ExecuteActorStateTransaction_FullMethodName   = "/dapr.proto.runtime.v1.Dapr/ExecuteActorStateTransaction"
	Dapr_InvokeActor_FullMethodName                    = "/dapr.proto.runtime.v1.Dapr/InvokeActor"
	Dapr_GetConfigurationAlpha1_FullMethodName         = "/dapr.proto.runtime.v1.Dapr/GetConfigurationAlpha1"
	Dapr_GetConfiguration_FullMethodName               = "/dapr.proto.runtime.v1.Dapr/GetConfiguration"
	Dapr_SubscribeConfigurationAlpha1_FullMethodName   = "/dapr.proto.runtime.v1.Dapr/SubscribeConfigurationAlpha1"
	Dapr_SubscribeConfiguration_FullMethodName         = "/dapr.proto.runtime.v1.Dapr/SubscribeConfiguration"
	Dapr_UnsubscribeConfigurationAlpha1_FullMethodName = "/dapr.proto.runtime.v1.Dapr/UnsubscribeConfigurationAlpha1"
	Dapr_UnsubscribeConfiguration_FullMethodName       = "/dapr.proto.runtime.v1.Dapr/UnsubscribeConfiguration"
	Dapr_TryLockAlpha1_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/TryLockAlpha1"
	Dapr_UnlockAlpha1_FullMethodName                   = "/dapr.proto.runtime.v1.Dapr/UnlockAlpha1"
	Dapr_EncryptAlpha1_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/EncryptAlpha1"
	Dapr_DecryptAlpha1_FullMethodName                  = "/dapr.proto.runtime.v1.Dapr/DecryptAlpha1"
	Dapr_GetMetadata_FullMethodName                    = "/dapr.proto.runtime.v1.Dapr/GetMetadata"
	Dapr_SetMetadata_FullMethodName                    = "/dapr.proto.runtime.v1.Dapr/SetMetadata"
	Dapr_SubtleGetKeyAlpha1_FullMethodName             = "/dapr.proto.runtime.v1.Dapr/SubtleGetKeyAlpha1"
	Dapr_SubtleEncryptAlpha1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/SubtleEncryptAlpha1"
	Dapr_SubtleDecryptAlpha1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/SubtleDecryptAlpha1"
	Dapr_SubtleWrapKeyAlpha1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/SubtleWrapKeyAlpha1"
	Dapr_SubtleUnwrapKeyAlpha1_FullMethodName          = "/dapr.proto.runtime.v1.Dapr/SubtleUnwrapKeyAlpha1"
	Dapr_SubtleSignAlpha1_FullMethodName               = "/dapr.proto.runtime.v1.Dapr/SubtleSignAlpha1"
	Dapr_SubtleVerifyAlpha1_FullMethodName             = "/dapr.proto.runtime.v1.Dapr/SubtleVerifyAlpha1"
	Dapr_StartWorkflowAlpha1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/StartWorkflowAlpha1"
	Dapr_GetWorkflowAlpha1_FullMethodName              = "/dapr.proto.runtime.v1.Dapr/GetWorkflowAlpha1"
	Dapr_PurgeWorkflowAlpha1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/PurgeWorkflowAlpha1"
	Dapr_TerminateWorkflowAlpha1_FullMethodName        = "/dapr.proto.runtime.v1.Dapr/TerminateWorkflowAlpha1"
	Dapr_PauseWorkflowAlpha1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/PauseWorkflowAlpha1"
	Dapr_ResumeWorkflowAlpha1_FullMethodName           = "/dapr.proto.runtime.v1.Dapr/ResumeWorkflowAlpha1"
	Dapr_RaiseEventWorkflowAlpha1_FullMethodName       = "/dapr.proto.runtime.v1.Dapr/RaiseEventWorkflowAlpha1"
	Dapr_StartWorkflowBeta1_FullMethodName             = "/dapr.proto.runtime.v1.Dapr/StartWorkflowBeta1"
	Dapr_GetWorkflowBeta1_FullMethodName               = "/dapr.proto.runtime.v1.Dapr/GetWorkflowBeta1"
	Dapr_PurgeWorkflowBeta1_FullMethodName             = "/dapr.proto.runtime.v1.Dapr/PurgeWorkflowBeta1"
	Dapr_TerminateWorkflowBeta1_FullMethodName         = "/dapr.proto.runtime.v1.Dapr/TerminateWorkflowBeta1"
	Dapr_PauseWorkflowBeta1_FullMethodName             = "/dapr.proto.runtime.v1.Dapr/PauseWorkflowBeta1"
	Dapr_ResumeWorkflowBeta1_FullMethodName            = "/dapr.proto.runtime.v1.Dapr/ResumeWorkflowBeta1"
	Dapr_RaiseEventWorkflowBeta1_FullMethodName        = "/dapr.proto.runtime.v1.Dapr/RaiseEventWorkflowBeta1"
	Dapr_Shutdown_FullMethodName                       = "/dapr.proto.runtime.v1.Dapr/Shutdown"
	Dapr_ScheduleJobAlpha1_FullMethodName              = "/dapr.proto.runtime.v1.Dapr/ScheduleJobAlpha1"
	Dapr_GetJobAlpha1_FullMethodName                   = "/dapr.proto.runtime.v1.Dapr/GetJobAlpha1"
	Dapr_DeleteJobAlpha1_FullMethodName                = "/dapr.proto.runtime.v1.Dapr/DeleteJobAlpha1"
	Dapr_ConverseAlpha1_FullMethodName                 = "/dapr.proto.runtime.v1.Dapr/ConverseAlpha1"
)
View Source 
const (
	AppCallbackHealthCheck_HealthCheck_FullMethodName = "/dapr.proto.runtime.v1.AppCallbackHealthCheck/HealthCheck"
)

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 (
	PubsubSubscriptionType_name = map[int32]string{
		0: "UNKNOWN",
		1: "DECLARATIVE",
		2: "PROGRAMMATIC",
		3: "STREAMING",
	}
	PubsubSubscriptionType_value = map[string]int32{
		"UNKNOWN":      0,
		"DECLARATIVE":  1,
		"PROGRAMMATIC": 2,
		"STREAMING":    3,
	}
)

Enum value maps for PubsubSubscriptionType.

View Source 
var (
	ActorRuntime_ActorRuntimeStatus_name = map[int32]string{
		0: "INITIALIZING",
		1: "DISABLED",
		2: "RUNNING",
	}
	ActorRuntime_ActorRuntimeStatus_value = map[string]int32{
		"INITIALIZING": 0,
		"DISABLED":     1,
		"RUNNING":      2,
	}
)

Enum value maps for ActorRuntime_ActorRuntimeStatus.

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 (
	SubtleGetKeyRequest_KeyFormat_name = map[int32]string{
		0: "PEM",
		1: "JSON",
	}
	SubtleGetKeyRequest_KeyFormat_value = map[string]int32{
		"PEM":  0,
		"JSON": 1,
	}
)

Enum value maps for SubtleGetKeyRequest_KeyFormat.

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,
		},
		{
			MethodName: "OnJobEventAlpha1",
			Handler:    _AppCallbackAlpha_OnJobEventAlpha1_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: "GetActorState",
			Handler:    _Dapr_GetActorState_Handler,
		},
		{
			MethodName: "ExecuteActorStateTransaction",
			Handler:    _Dapr_ExecuteActorStateTransaction_Handler,
		},
		{
			MethodName: "InvokeActor",
			Handler:    _Dapr_InvokeActor_Handler,
		},
		{
			MethodName: "GetConfigurationAlpha1",
			Handler:    _Dapr_GetConfigurationAlpha1_Handler,
		},
		{
			MethodName: "GetConfiguration",
			Handler:    _Dapr_GetConfiguration_Handler,
		},
		{
			MethodName: "UnsubscribeConfigurationAlpha1",
			Handler:    _Dapr_UnsubscribeConfigurationAlpha1_Handler,
		},
		{
			MethodName: "UnsubscribeConfiguration",
			Handler:    _Dapr_UnsubscribeConfiguration_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: "SubtleGetKeyAlpha1",
			Handler:    _Dapr_SubtleGetKeyAlpha1_Handler,
		},
		{
			MethodName: "SubtleEncryptAlpha1",
			Handler:    _Dapr_SubtleEncryptAlpha1_Handler,
		},
		{
			MethodName: "SubtleDecryptAlpha1",
			Handler:    _Dapr_SubtleDecryptAlpha1_Handler,
		},
		{
			MethodName: "SubtleWrapKeyAlpha1",
			Handler:    _Dapr_SubtleWrapKeyAlpha1_Handler,
		},
		{
			MethodName: "SubtleUnwrapKeyAlpha1",
			Handler:    _Dapr_SubtleUnwrapKeyAlpha1_Handler,
		},
		{
			MethodName: "SubtleSignAlpha1",
			Handler:    _Dapr_SubtleSignAlpha1_Handler,
		},
		{
			MethodName: "SubtleVerifyAlpha1",
			Handler:    _Dapr_SubtleVerifyAlpha1_Handler,
		},
		{
			MethodName: "StartWorkflowAlpha1",
			Handler:    _Dapr_StartWorkflowAlpha1_Handler,
		},
		{
			MethodName: "GetWorkflowAlpha1",
			Handler:    _Dapr_GetWorkflowAlpha1_Handler,
		},
		{
			MethodName: "PurgeWorkflowAlpha1",
			Handler:    _Dapr_PurgeWorkflowAlpha1_Handler,
		},
		{
			MethodName: "TerminateWorkflowAlpha1",
			Handler:    _Dapr_TerminateWorkflowAlpha1_Handler,
		},
		{
			MethodName: "PauseWorkflowAlpha1",
			Handler:    _Dapr_PauseWorkflowAlpha1_Handler,
		},
		{
			MethodName: "ResumeWorkflowAlpha1",
			Handler:    _Dapr_ResumeWorkflowAlpha1_Handler,
		},
		{
			MethodName: "RaiseEventWorkflowAlpha1",
			Handler:    _Dapr_RaiseEventWorkflowAlpha1_Handler,
		},
		{
			MethodName: "StartWorkflowBeta1",
			Handler:    _Dapr_StartWorkflowBeta1_Handler,
		},
		{
			MethodName: "GetWorkflowBeta1",
			Handler:    _Dapr_GetWorkflowBeta1_Handler,
		},
		{
			MethodName: "PurgeWorkflowBeta1",
			Handler:    _Dapr_PurgeWorkflowBeta1_Handler,
		},
		{
			MethodName: "TerminateWorkflowBeta1",
			Handler:    _Dapr_TerminateWorkflowBeta1_Handler,
		},
		{
			MethodName: "PauseWorkflowBeta1",
			Handler:    _Dapr_PauseWorkflowBeta1_Handler,
		},
		{
			MethodName: "ResumeWorkflowBeta1",
			Handler:    _Dapr_ResumeWorkflowBeta1_Handler,
		},
		{
			MethodName: "RaiseEventWorkflowBeta1",
			Handler:    _Dapr_RaiseEventWorkflowBeta1_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Dapr_Shutdown_Handler,
		},
		{
			MethodName: "ScheduleJobAlpha1",
			Handler:    _Dapr_ScheduleJobAlpha1_Handler,
		},
		{
			MethodName: "GetJobAlpha1",
			Handler:    _Dapr_GetJobAlpha1_Handler,
		},
		{
			MethodName: "DeleteJobAlpha1",
			Handler:    _Dapr_DeleteJobAlpha1_Handler,
		},
		{
			MethodName: "ConverseAlpha1",
			Handler:    _Dapr_ConverseAlpha1_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeTopicEventsAlpha1",
			Handler:       _Dapr_SubscribeTopicEventsAlpha1_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SubscribeConfigurationAlpha1",
			Handler:       _Dapr_SubscribeConfigurationAlpha1_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeConfiguration",
			Handler:       _Dapr_SubscribeConfiguration_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "EncryptAlpha1",
			Handler:       _Dapr_EncryptAlpha1_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "DecryptAlpha1",
			Handler:       _Dapr_DecryptAlpha1_Handler,
			ServerStreams: true,
			ClientStreams: 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 

func RegisterAppCallbackAlphaServer(s grpc.ServiceRegistrar, srv AppCallbackAlphaServer)

func RegisterAppCallbackHealthCheckServer 

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 

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

func (*ActiveActorsCount) Descriptor deprecated 

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

Deprecated: Use ActiveActorsCount.ProtoReflect.Descriptor instead.

func (*ActiveActorsCount) GetCount 

func (x *ActiveActorsCount) GetCount() int32

func (*ActiveActorsCount) GetType 

func (x *ActiveActorsCount) GetType() string

func (*ActiveActorsCount) ProtoMessage 

func (*ActiveActorsCount) ProtoMessage()

func (*ActiveActorsCount) ProtoReflect 

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

func (*ActiveActorsCount) Reset 

func (x *ActiveActorsCount) Reset()

func (*ActiveActorsCount) String 

func (x *ActiveActorsCount) String() string

type ActorRuntime 

type ActorRuntime struct {

	// Contains an enum indicating whether the actor runtime has been initialized.
	RuntimeStatus ActorRuntime_ActorRuntimeStatus `` /* 160-byte string literal not displayed */
	// Count of active actors per type.
	ActiveActors []*ActiveActorsCount `protobuf:"bytes,2,rep,name=active_actors,json=activeActors,proto3" json:"active_actors,omitempty"`
	// Indicates whether the actor runtime is ready to host actors.
	HostReady bool `protobuf:"varint,3,opt,name=host_ready,json=hostReady,proto3" json:"host_ready,omitempty"`
	// Custom message from the placement provider.
	Placement string `protobuf:"bytes,4,opt,name=placement,proto3" json:"placement,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorRuntime) Descriptor deprecated 

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

Deprecated: Use ActorRuntime.ProtoReflect.Descriptor instead.

func (*ActorRuntime) GetActiveActors 

func (x *ActorRuntime) GetActiveActors() []*ActiveActorsCount

func (*ActorRuntime) GetHostReady 

func (x *ActorRuntime) GetHostReady() bool

func (*ActorRuntime) GetPlacement 

func (x *ActorRuntime) GetPlacement() string

func (*ActorRuntime) GetRuntimeStatus 

func (x *ActorRuntime) GetRuntimeStatus() ActorRuntime_ActorRuntimeStatus

func (*ActorRuntime) ProtoMessage 

func (*ActorRuntime) ProtoMessage()

func (*ActorRuntime) ProtoReflect 

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

func (*ActorRuntime) Reset 

func (x *ActorRuntime) Reset()

func (*ActorRuntime) String 

func (x *ActorRuntime) String() string

type ActorRuntime_ActorRuntimeStatus 

type ActorRuntime_ActorRuntimeStatus int32
const (
	// Indicates that the actor runtime is still being initialized.
	ActorRuntime_INITIALIZING ActorRuntime_ActorRuntimeStatus = 0
	// Indicates that the actor runtime is disabled.
	// This normally happens when Dapr is started without "placement-host-address"
	ActorRuntime_DISABLED ActorRuntime_ActorRuntimeStatus = 1
	// Indicates the actor runtime is running, either as an actor host or client.
	ActorRuntime_RUNNING ActorRuntime_ActorRuntimeStatus = 2
)

func (ActorRuntime_ActorRuntimeStatus) Descriptor 

func (ActorRuntime_ActorRuntimeStatus) Descriptor() protoreflect.EnumDescriptor

func (ActorRuntime_ActorRuntimeStatus) Enum 

func (x ActorRuntime_ActorRuntimeStatus) Enum() *ActorRuntime_ActorRuntimeStatus

func (ActorRuntime_ActorRuntimeStatus) EnumDescriptor deprecated 

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

Deprecated: Use ActorRuntime_ActorRuntimeStatus.Descriptor instead.

func (ActorRuntime_ActorRuntimeStatus) Number 

func (x ActorRuntime_ActorRuntimeStatus) Number() protoreflect.EnumNumber

func (ActorRuntime_ActorRuntimeStatus) String 

func (x ActorRuntime_ActorRuntimeStatus) String() string

func (ActorRuntime_ActorRuntimeStatus) Type 

func (ActorRuntime_ActorRuntimeStatus) Type() protoreflect.EnumType

type AppCallbackAlphaClient 

type AppCallbackAlphaClient interface {
	// Subscribes bulk events from Pubsub
	OnBulkTopicEventAlpha1(ctx context.Context, in *TopicEventBulkRequest, opts ...grpc.CallOption) (*TopicEventBulkResponse, error)
	// Sends job back to the app's endpoint at trigger time.
	OnJobEventAlpha1(ctx context.Context, in *JobEventRequest, opts ...grpc.CallOption) (*JobEventResponse, 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 

func NewAppCallbackAlphaClient(cc grpc.ClientConnInterface) AppCallbackAlphaClient

type AppCallbackAlphaServer 

type AppCallbackAlphaServer interface {
	// Subscribes bulk events from Pubsub
	OnBulkTopicEventAlpha1(context.Context, *TopicEventBulkRequest) (*TopicEventBulkResponse, error)
	// Sends job back to the app's endpoint at trigger time.
	OnJobEventAlpha1(context.Context, *JobEventRequest) (*JobEventResponse, 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 

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 

func NewAppCallbackHealthCheckClient(cc grpc.ClientConnInterface) AppCallbackHealthCheckClient

type AppCallbackHealthCheckServer 

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 AppConnectionHealthProperties 

type AppConnectionHealthProperties struct {
	HealthCheckPath     string `protobuf:"bytes,1,opt,name=health_check_path,json=healthCheckPath,proto3" json:"health_check_path,omitempty"`
	HealthProbeInterval string `protobuf:"bytes,2,opt,name=health_probe_interval,json=healthProbeInterval,proto3" json:"health_probe_interval,omitempty"`
	HealthProbeTimeout  string `protobuf:"bytes,3,opt,name=health_probe_timeout,json=healthProbeTimeout,proto3" json:"health_probe_timeout,omitempty"`
	HealthThreshold     int32  `protobuf:"varint,4,opt,name=health_threshold,json=healthThreshold,proto3" json:"health_threshold,omitempty"`
	// contains filtered or unexported fields
}

func (*AppConnectionHealthProperties) Descriptor deprecated 

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

Deprecated: Use AppConnectionHealthProperties.ProtoReflect.Descriptor instead.

func (*AppConnectionHealthProperties) GetHealthCheckPath 

func (x *AppConnectionHealthProperties) GetHealthCheckPath() string

func (*AppConnectionHealthProperties) GetHealthProbeInterval 

func (x *AppConnectionHealthProperties) GetHealthProbeInterval() string

func (*AppConnectionHealthProperties) GetHealthProbeTimeout 

func (x *AppConnectionHealthProperties) GetHealthProbeTimeout() string

func (*AppConnectionHealthProperties) GetHealthThreshold 

func (x *AppConnectionHealthProperties) GetHealthThreshold() int32

func (*AppConnectionHealthProperties) ProtoMessage 

func (*AppConnectionHealthProperties) ProtoMessage()

func (*AppConnectionHealthProperties) ProtoReflect 

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

func (*AppConnectionHealthProperties) Reset 

func (x *AppConnectionHealthProperties) Reset()

func (*AppConnectionHealthProperties) String 

func (x *AppConnectionHealthProperties) String() string

type AppConnectionProperties 

type AppConnectionProperties struct {
	Port           int32                          `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Protocol       string                         `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ChannelAddress string                         `protobuf:"bytes,3,opt,name=channel_address,json=channelAddress,proto3" json:"channel_address,omitempty"`
	MaxConcurrency int32                          `protobuf:"varint,4,opt,name=max_concurrency,json=maxConcurrency,proto3" json:"max_concurrency,omitempty"`
	Health         *AppConnectionHealthProperties `protobuf:"bytes,5,opt,name=health,proto3" json:"health,omitempty"`
	// contains filtered or unexported fields
}

func (*AppConnectionProperties) Descriptor deprecated 

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

Deprecated: Use AppConnectionProperties.ProtoReflect.Descriptor instead.

func (*AppConnectionProperties) GetChannelAddress 

func (x *AppConnectionProperties) GetChannelAddress() string

func (*AppConnectionProperties) GetHealth 

func (x *AppConnectionProperties) GetHealth() *AppConnectionHealthProperties

func (*AppConnectionProperties) GetMaxConcurrency 

func (x *AppConnectionProperties) GetMaxConcurrency() int32

func (*AppConnectionProperties) GetPort 

func (x *AppConnectionProperties) GetPort() int32

func (*AppConnectionProperties) GetProtocol 

func (x *AppConnectionProperties) GetProtocol() string

func (*AppConnectionProperties) ProtoMessage 

func (*AppConnectionProperties) ProtoMessage()

func (*AppConnectionProperties) ProtoReflect 

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

func (*AppConnectionProperties) Reset 

func (x *AppConnectionProperties) Reset()

func (*AppConnectionProperties) String 

func (x *AppConnectionProperties) String() string

type BindingEventRequest 

type BindingEventRequest struct {

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

BindingEventRequest represents input bindings event.

func (*BindingEventRequest) Descriptor deprecated 

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

Deprecated: Use BindingEventRequest.ProtoReflect.Descriptor instead.

func (*BindingEventRequest) GetData 

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

func (*BindingEventRequest) GetMetadata 

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

func (*BindingEventRequest) GetName 

func (x *BindingEventRequest) GetName() string

func (*BindingEventRequest) ProtoMessage 

func (*BindingEventRequest) ProtoMessage()

func (*BindingEventRequest) ProtoReflect 

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

func (*BindingEventRequest) Reset 

func (x *BindingEventRequest) Reset()

func (*BindingEventRequest) String 

func (x *BindingEventRequest) String() string

type BindingEventResponse 

type BindingEventResponse struct {

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

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

func (*BindingEventResponse) Descriptor deprecated 

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

Deprecated: Use BindingEventResponse.ProtoReflect.Descriptor instead.

func (*BindingEventResponse) GetConcurrency 

func (x *BindingEventResponse) GetConcurrency() BindingEventResponse_BindingEventConcurrency

func (*BindingEventResponse) GetData 

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

func (*BindingEventResponse) GetStates 

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

func (*BindingEventResponse) GetStoreName 

func (x *BindingEventResponse) GetStoreName() string

func (*BindingEventResponse) GetTo 

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

func (*BindingEventResponse) ProtoMessage 

func (*BindingEventResponse) ProtoMessage()

func (*BindingEventResponse) ProtoReflect 

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

func (*BindingEventResponse) Reset 

func (x *BindingEventResponse) Reset()

func (*BindingEventResponse) String 

func (x *BindingEventResponse) String() string

type BindingEventResponse_BindingEventConcurrency 

type BindingEventResponse_BindingEventConcurrency int32

BindingEventConcurrency is the kind of concurrency 

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

func (BindingEventResponse_BindingEventConcurrency) Descriptor 

func (BindingEventResponse_BindingEventConcurrency) Descriptor() protoreflect.EnumDescriptor

func (BindingEventResponse_BindingEventConcurrency) Enum 

func (x BindingEventResponse_BindingEventConcurrency) Enum() *BindingEventResponse_BindingEventConcurrency

func (BindingEventResponse_BindingEventConcurrency) EnumDescriptor deprecated 

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

Deprecated: Use BindingEventResponse_BindingEventConcurrency.Descriptor instead.

func (BindingEventResponse_BindingEventConcurrency) Number 

func (x BindingEventResponse_BindingEventConcurrency) Number() protoreflect.EnumNumber

func (BindingEventResponse_BindingEventConcurrency) String 

func (x BindingEventResponse_BindingEventConcurrency) String() string

func (BindingEventResponse_BindingEventConcurrency) Type 

func (BindingEventResponse_BindingEventConcurrency) Type() protoreflect.EnumType

type BulkPublishRequest 

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) AppendSpanAttributes 

func (x *BulkPublishRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*BulkPublishRequest) Descriptor deprecated 

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

Deprecated: Use BulkPublishRequest.ProtoReflect.Descriptor instead.

func (*BulkPublishRequest) GetEntries 

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

func (*BulkPublishRequest) GetMetadata 

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

func (*BulkPublishRequest) GetPubsubName 

func (x *BulkPublishRequest) GetPubsubName() string

func (*BulkPublishRequest) GetTopic 

func (x *BulkPublishRequest) GetTopic() string

func (*BulkPublishRequest) ProtoMessage 

func (*BulkPublishRequest) ProtoMessage()

func (*BulkPublishRequest) ProtoReflect 

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

func (*BulkPublishRequest) Reset 

func (x *BulkPublishRequest) Reset()

func (*BulkPublishRequest) String 

func (x *BulkPublishRequest) String() string

type BulkPublishRequestEntry 

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 

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

Deprecated: Use BulkPublishRequestEntry.ProtoReflect.Descriptor instead.

func (*BulkPublishRequestEntry) GetContentType 

func (x *BulkPublishRequestEntry) GetContentType() string

func (*BulkPublishRequestEntry) GetEntryId 

func (x *BulkPublishRequestEntry) GetEntryId() string

func (*BulkPublishRequestEntry) GetEvent 

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

func (*BulkPublishRequestEntry) GetMetadata 

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

func (*BulkPublishRequestEntry) ProtoMessage 

func (*BulkPublishRequestEntry) ProtoMessage()

func (*BulkPublishRequestEntry) ProtoReflect 

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

func (*BulkPublishRequestEntry) Reset 

func (x *BulkPublishRequestEntry) Reset()

func (*BulkPublishRequestEntry) String 

func (x *BulkPublishRequestEntry) String() string

type BulkPublishResponse 

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 

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

Deprecated: Use BulkPublishResponse.ProtoReflect.Descriptor instead.

func (*BulkPublishResponse) GetFailedEntries 

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

func (*BulkPublishResponse) ProtoMessage 

func (*BulkPublishResponse) ProtoMessage()

func (*BulkPublishResponse) ProtoReflect 

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

func (*BulkPublishResponse) Reset 

func (x *BulkPublishResponse) Reset()

func (*BulkPublishResponse) String 

func (x *BulkPublishResponse) String() string

type BulkPublishResponseFailedEntry 

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 

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

Deprecated: Use BulkPublishResponseFailedEntry.ProtoReflect.Descriptor instead.

func (*BulkPublishResponseFailedEntry) GetEntryId 

func (x *BulkPublishResponseFailedEntry) GetEntryId() string

func (*BulkPublishResponseFailedEntry) GetError 

func (x *BulkPublishResponseFailedEntry) GetError() string

func (*BulkPublishResponseFailedEntry) ProtoMessage 

func (*BulkPublishResponseFailedEntry) ProtoMessage()

func (*BulkPublishResponseFailedEntry) ProtoReflect 

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

func (*BulkPublishResponseFailedEntry) Reset 

func (x *BulkPublishResponseFailedEntry) Reset()

func (*BulkPublishResponseFailedEntry) String 

func (x *BulkPublishResponseFailedEntry) String() string

type BulkStateItem 

type BulkStateItem struct {

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

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

func (*BulkStateItem) Descriptor deprecated 

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

Deprecated: Use BulkStateItem.ProtoReflect.Descriptor instead.

func (*BulkStateItem) GetData 

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

func (*BulkStateItem) GetError 

func (x *BulkStateItem) GetError() string

func (*BulkStateItem) GetEtag 

func (x *BulkStateItem) GetEtag() string

func (*BulkStateItem) GetKey 

func (x *BulkStateItem) GetKey() string

func (*BulkStateItem) GetMetadata 

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

func (*BulkStateItem) ProtoMessage 

func (*BulkStateItem) ProtoMessage()

func (*BulkStateItem) ProtoReflect 

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

func (*BulkStateItem) Reset 

func (x *BulkStateItem) Reset()

func (*BulkStateItem) String 

func (x *BulkStateItem) String() string

type BulkSubscribeConfig 

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 

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

Deprecated: Use BulkSubscribeConfig.ProtoReflect.Descriptor instead.

func (*BulkSubscribeConfig) GetEnabled 

func (x *BulkSubscribeConfig) GetEnabled() bool

func (*BulkSubscribeConfig) GetMaxAwaitDurationMs 

func (x *BulkSubscribeConfig) GetMaxAwaitDurationMs() int32

func (*BulkSubscribeConfig) GetMaxMessagesCount 

func (x *BulkSubscribeConfig) GetMaxMessagesCount() int32

func (*BulkSubscribeConfig) ProtoMessage 

func (*BulkSubscribeConfig) ProtoMessage()

func (*BulkSubscribeConfig) ProtoReflect 

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

func (*BulkSubscribeConfig) Reset 

func (x *BulkSubscribeConfig) Reset()

func (*BulkSubscribeConfig) String 

func (x *BulkSubscribeConfig) String() string

type ConversationInput 

type ConversationInput struct {

	// The message to send to the llm
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The role to set for the message
	Role *string `protobuf:"bytes,2,opt,name=role,proto3,oneof" json:"role,omitempty"`
	// Scrub PII data that goes into the LLM
	ScrubPII *bool `protobuf:"varint,3,opt,name=scrubPII,proto3,oneof" json:"scrubPII,omitempty"`
	// contains filtered or unexported fields
}

func (*ConversationInput) Descriptor deprecated 

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

Deprecated: Use ConversationInput.ProtoReflect.Descriptor instead.

func (*ConversationInput) GetMessage 

func (x *ConversationInput) GetMessage() string

func (*ConversationInput) GetRole 

func (x *ConversationInput) GetRole() string

func (*ConversationInput) GetScrubPII 

func (x *ConversationInput) GetScrubPII() bool

func (*ConversationInput) ProtoMessage 

func (*ConversationInput) ProtoMessage()

func (*ConversationInput) ProtoReflect 

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

func (*ConversationInput) Reset 

func (x *ConversationInput) Reset()

func (*ConversationInput) String 

func (x *ConversationInput) String() string

type ConversationRequest 

type ConversationRequest struct {

	// The name of Conversation component
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The ID of an existing chat (like in ChatGPT)
	ContextID *string `protobuf:"bytes,2,opt,name=contextID,proto3,oneof" json:"contextID,omitempty"`
	// Inputs for the conversation, support multiple input in one time.
	Inputs []*ConversationInput `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Parameters for all custom fields.
	Parameters map[string]*anypb.Any `` /* 161-byte string literal not displayed */
	// The metadata passing to conversation components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Scrub PII data that comes back from the LLM
	ScrubPII *bool `protobuf:"varint,6,opt,name=scrubPII,proto3,oneof" json:"scrubPII,omitempty"`
	// Temperature for the LLM to optimize for creativity or predictability
	Temperature *float64 `protobuf:"fixed64,7,opt,name=temperature,proto3,oneof" json:"temperature,omitempty"`
	// contains filtered or unexported fields
}

ConversationRequest is the request object for Conversation.

func (*ConversationRequest) AppendSpanAttributes 

func (*ConversationRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*ConversationRequest) Descriptor deprecated 

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

Deprecated: Use ConversationRequest.ProtoReflect.Descriptor instead.

func (*ConversationRequest) GetContextID 

func (x *ConversationRequest) GetContextID() string

func (*ConversationRequest) GetInputs 

func (x *ConversationRequest) GetInputs() []*ConversationInput

func (*ConversationRequest) GetMetadata 

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

func (*ConversationRequest) GetName 

func (x *ConversationRequest) GetName() string

func (*ConversationRequest) GetParameters 

func (x *ConversationRequest) GetParameters() map[string]*anypb.Any

func (*ConversationRequest) GetScrubPII 

func (x *ConversationRequest) GetScrubPII() bool

func (*ConversationRequest) GetTemperature 

func (x *ConversationRequest) GetTemperature() float64

func (*ConversationRequest) ProtoMessage 

func (*ConversationRequest) ProtoMessage()

func (*ConversationRequest) ProtoReflect 

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

func (*ConversationRequest) Reset 

func (x *ConversationRequest) Reset()

func (*ConversationRequest) String 

func (x *ConversationRequest) String() string

type ConversationResponse 

type ConversationResponse struct {

	// The ID of an existing chat (like in ChatGPT)
	ContextID *string `protobuf:"bytes,1,opt,name=contextID,proto3,oneof" json:"contextID,omitempty"`
	// An array of results.
	Outputs []*ConversationResult `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

ConversationResponse is the response for Conversation.

func (*ConversationResponse) Descriptor deprecated 

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

Deprecated: Use ConversationResponse.ProtoReflect.Descriptor instead.

func (*ConversationResponse) GetContextID 

func (x *ConversationResponse) GetContextID() string

func (*ConversationResponse) GetOutputs 

func (x *ConversationResponse) GetOutputs() []*ConversationResult

func (*ConversationResponse) ProtoMessage 

func (*ConversationResponse) ProtoMessage()

func (*ConversationResponse) ProtoReflect 

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

func (*ConversationResponse) Reset 

func (x *ConversationResponse) Reset()

func (*ConversationResponse) String 

func (x *ConversationResponse) String() string

type ConversationResult 

type ConversationResult struct {

	// Result for the one conversation input.
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// Parameters for all custom fields.
	Parameters map[string]*anypb.Any `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

ConversationResult is the result for one input.

func (*ConversationResult) Descriptor deprecated 

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

Deprecated: Use ConversationResult.ProtoReflect.Descriptor instead.

func (*ConversationResult) GetParameters 

func (x *ConversationResult) GetParameters() map[string]*anypb.Any

func (*ConversationResult) GetResult 

func (x *ConversationResult) GetResult() string

func (*ConversationResult) ProtoMessage 

func (*ConversationResult) ProtoMessage()

func (*ConversationResult) ProtoReflect 

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

func (*ConversationResult) Reset 

func (x *ConversationResult) Reset()

func (*ConversationResult) String 

func (x *ConversationResult) String() string

type CryptoRequests 

type CryptoRequests interface {
	proto.Message

	// SetPayload sets the payload.
	SetPayload(payload *commonv1pb.StreamPayload)
	// GetPayload returns the payload.
	GetPayload() *commonv1pb.StreamPayload
	// Reset the object.
	Reset()
	// SetOptions sets the Options property.
	SetOptions(opts proto.Message)
	// HasOptions returns true if the Options property is not empty.
	HasOptions() bool
}

CryptoRequests is an interface for EncryptRequest and DecryptRequest.

type CryptoResponses 

type CryptoResponses interface {
	proto.Message

	// SetPayload sets the payload.
	SetPayload(payload *commonv1pb.StreamPayload)
	// GetPayload returns the payload.
	GetPayload() *commonv1pb.StreamPayload
	// Reset the object.
	Reset()
}

CryptoResponses is an interface for EncryptResponse and DecryptResponse.

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)
	// SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
	// events from it.
	SubscribeTopicEventsAlpha1(ctx context.Context, opts ...grpc.CallOption) (Dapr_SubscribeTopicEventsAlpha1Client, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(ctx context.Context, in *InvokeBindingRequest, opts ...grpc.CallOption) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// Gets a bulk of secrets
	GetBulkSecret(ctx context.Context, in *GetBulkSecretRequest, opts ...grpc.CallOption) (*GetBulkSecretResponse, error)
	// Register an actor timer.
	RegisterActorTimer(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Unregister an actor timer.
	UnregisterActorTimer(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Register an actor reminder.
	RegisterActorReminder(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Unregister an actor reminder.
	UnregisterActorReminder(ctx context.Context, in *UnregisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Gets the state for a specific actor.
	GetActorState(ctx context.Context, in *GetActorStateRequest, opts ...grpc.CallOption) (*GetActorStateResponse, error)
	// Executes state transactions for a specified actor
	ExecuteActorStateTransaction(ctx context.Context, in *ExecuteActorStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// InvokeActor calls a method on an actor.
	InvokeActor(ctx context.Context, in *InvokeActorRequest, opts ...grpc.CallOption) (*InvokeActorResponse, error)
	// GetConfiguration gets configuration from configuration store.
	GetConfigurationAlpha1(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	// GetConfiguration gets configuration from configuration store.
	GetConfiguration(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)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfiguration(ctx context.Context, in *SubscribeConfigurationRequest, opts ...grpc.CallOption) (Dapr_SubscribeConfigurationClient, error)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfigurationAlpha1(ctx context.Context, in *UnsubscribeConfigurationRequest, opts ...grpc.CallOption) (*UnsubscribeConfigurationResponse, error)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfiguration(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)
	// EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
	EncryptAlpha1(ctx context.Context, opts ...grpc.CallOption) (Dapr_EncryptAlpha1Client, error)
	// DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
	DecryptAlpha1(ctx context.Context, opts ...grpc.CallOption) (Dapr_DecryptAlpha1Client, error)
	// Gets metadata of the sidecar
	GetMetadata(ctx context.Context, in *GetMetadataRequest, 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)
	// SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
	SubtleGetKeyAlpha1(ctx context.Context, in *SubtleGetKeyRequest, opts ...grpc.CallOption) (*SubtleGetKeyResponse, error)
	// SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
	SubtleEncryptAlpha1(ctx context.Context, in *SubtleEncryptRequest, opts ...grpc.CallOption) (*SubtleEncryptResponse, error)
	// SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
	SubtleDecryptAlpha1(ctx context.Context, in *SubtleDecryptRequest, opts ...grpc.CallOption) (*SubtleDecryptResponse, error)
	// SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
	SubtleWrapKeyAlpha1(ctx context.Context, in *SubtleWrapKeyRequest, opts ...grpc.CallOption) (*SubtleWrapKeyResponse, error)
	// SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
	SubtleUnwrapKeyAlpha1(ctx context.Context, in *SubtleUnwrapKeyRequest, opts ...grpc.CallOption) (*SubtleUnwrapKeyResponse, error)
	// SubtleSignAlpha1 signs a message using a key stored in the vault.
	SubtleSignAlpha1(ctx context.Context, in *SubtleSignRequest, opts ...grpc.CallOption) (*SubtleSignResponse, error)
	// SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
	SubtleVerifyAlpha1(ctx context.Context, in *SubtleVerifyRequest, opts ...grpc.CallOption) (*SubtleVerifyResponse, error)
	// Starts a new instance of a workflow
	StartWorkflowAlpha1(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*StartWorkflowResponse, error)
	// Gets details about a started workflow instance
	GetWorkflowAlpha1(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)
	// Purge Workflow
	PurgeWorkflowAlpha1(ctx context.Context, in *PurgeWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Terminates a running workflow instance
	TerminateWorkflowAlpha1(ctx context.Context, in *TerminateWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Pauses a running workflow instance
	PauseWorkflowAlpha1(ctx context.Context, in *PauseWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Resumes a paused workflow instance
	ResumeWorkflowAlpha1(ctx context.Context, in *ResumeWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Raise an event to a running workflow instance
	RaiseEventWorkflowAlpha1(ctx context.Context, in *RaiseEventWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a new instance of a workflow
	StartWorkflowBeta1(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*StartWorkflowResponse, error)
	// Gets details about a started workflow instance
	GetWorkflowBeta1(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)
	// Purge Workflow
	PurgeWorkflowBeta1(ctx context.Context, in *PurgeWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Terminates a running workflow instance
	TerminateWorkflowBeta1(ctx context.Context, in *TerminateWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Pauses a running workflow instance
	PauseWorkflowBeta1(ctx context.Context, in *PauseWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Resumes a paused workflow instance
	ResumeWorkflowBeta1(ctx context.Context, in *ResumeWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Raise an event to a running workflow instance
	RaiseEventWorkflowBeta1(ctx context.Context, in *RaiseEventWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Shutdown the sidecar
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Create and schedule a job
	ScheduleJobAlpha1(ctx context.Context, in *ScheduleJobRequest, opts ...grpc.CallOption) (*ScheduleJobResponse, error)
	// Gets a scheduled job
	GetJobAlpha1(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	// Delete a job
	DeleteJobAlpha1(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)
	// Converse with a LLM service
	ConverseAlpha1(ctx context.Context, in *ConversationRequest, opts ...grpc.CallOption) (*ConversationResponse, 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)
	// SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
	// events from it.
	SubscribeTopicEventsAlpha1(Dapr_SubscribeTopicEventsAlpha1Server) error
	// Invokes binding data to specific output bindings
	InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// Gets a bulk of secrets
	GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error)
	// Register an actor timer.
	RegisterActorTimer(context.Context, *RegisterActorTimerRequest) (*emptypb.Empty, error)
	// Unregister an actor timer.
	UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*emptypb.Empty, error)
	// Register an actor reminder.
	RegisterActorReminder(context.Context, *RegisterActorReminderRequest) (*emptypb.Empty, error)
	// Unregister an actor reminder.
	UnregisterActorReminder(context.Context, *UnregisterActorReminderRequest) (*emptypb.Empty, error)
	// Gets the state for a specific actor.
	GetActorState(context.Context, *GetActorStateRequest) (*GetActorStateResponse, error)
	// Executes state transactions for a specified actor
	ExecuteActorStateTransaction(context.Context, *ExecuteActorStateTransactionRequest) (*emptypb.Empty, error)
	// InvokeActor calls a method on an actor.
	InvokeActor(context.Context, *InvokeActorRequest) (*InvokeActorResponse, error)
	// GetConfiguration gets configuration from configuration store.
	GetConfigurationAlpha1(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	// GetConfiguration gets configuration from configuration store.
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfigurationAlpha1(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationAlpha1Server) error
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfiguration(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationServer) error
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfigurationAlpha1(context.Context, *UnsubscribeConfigurationRequest) (*UnsubscribeConfigurationResponse, error)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfiguration(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)
	// EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
	EncryptAlpha1(Dapr_EncryptAlpha1Server) error
	// DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
	DecryptAlpha1(Dapr_DecryptAlpha1Server) error
	// Gets metadata of the sidecar
	GetMetadata(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(context.Context, *SetMetadataRequest) (*emptypb.Empty, error)
	// SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
	SubtleGetKeyAlpha1(context.Context, *SubtleGetKeyRequest) (*SubtleGetKeyResponse, error)
	// SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
	SubtleEncryptAlpha1(context.Context, *SubtleEncryptRequest) (*SubtleEncryptResponse, error)
	// SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
	SubtleDecryptAlpha1(context.Context, *SubtleDecryptRequest) (*SubtleDecryptResponse, error)
	// SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
	SubtleWrapKeyAlpha1(context.Context, *SubtleWrapKeyRequest) (*SubtleWrapKeyResponse, error)
	// SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
	SubtleUnwrapKeyAlpha1(context.Context, *SubtleUnwrapKeyRequest) (*SubtleUnwrapKeyResponse, error)
	// SubtleSignAlpha1 signs a message using a key stored in the vault.
	SubtleSignAlpha1(context.Context, *SubtleSignRequest) (*SubtleSignResponse, error)
	// SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
	SubtleVerifyAlpha1(context.Context, *SubtleVerifyRequest) (*SubtleVerifyResponse, error)
	// Starts a new instance of a workflow
	StartWorkflowAlpha1(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)
	// Gets details about a started workflow instance
	GetWorkflowAlpha1(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)
	// Purge Workflow
	PurgeWorkflowAlpha1(context.Context, *PurgeWorkflowRequest) (*emptypb.Empty, error)
	// Terminates a running workflow instance
	TerminateWorkflowAlpha1(context.Context, *TerminateWorkflowRequest) (*emptypb.Empty, error)
	// Pauses a running workflow instance
	PauseWorkflowAlpha1(context.Context, *PauseWorkflowRequest) (*emptypb.Empty, error)
	// Resumes a paused workflow instance
	ResumeWorkflowAlpha1(context.Context, *ResumeWorkflowRequest) (*emptypb.Empty, error)
	// Raise an event to a running workflow instance
	RaiseEventWorkflowAlpha1(context.Context, *RaiseEventWorkflowRequest) (*emptypb.Empty, error)
	// Starts a new instance of a workflow
	StartWorkflowBeta1(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)
	// Gets details about a started workflow instance
	GetWorkflowBeta1(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)
	// Purge Workflow
	PurgeWorkflowBeta1(context.Context, *PurgeWorkflowRequest) (*emptypb.Empty, error)
	// Terminates a running workflow instance
	TerminateWorkflowBeta1(context.Context, *TerminateWorkflowRequest) (*emptypb.Empty, error)
	// Pauses a running workflow instance
	PauseWorkflowBeta1(context.Context, *PauseWorkflowRequest) (*emptypb.Empty, error)
	// Resumes a paused workflow instance
	ResumeWorkflowBeta1(context.Context, *ResumeWorkflowRequest) (*emptypb.Empty, error)
	// Raise an event to a running workflow instance
	RaiseEventWorkflowBeta1(context.Context, *RaiseEventWorkflowRequest) (*emptypb.Empty, error)
	// Shutdown the sidecar
	Shutdown(context.Context, *ShutdownRequest) (*emptypb.Empty, error)
	// Create and schedule a job
	ScheduleJobAlpha1(context.Context, *ScheduleJobRequest) (*ScheduleJobResponse, error)
	// Gets a scheduled job
	GetJobAlpha1(context.Context, *GetJobRequest) (*GetJobResponse, error)
	// Delete a job
	DeleteJobAlpha1(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
	// Converse with a LLM service
	ConverseAlpha1(context.Context, *ConversationRequest) (*ConversationResponse, error)
}

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

type Dapr_DecryptAlpha1Client 

type Dapr_DecryptAlpha1Client interface {
	Send(*DecryptRequest) error
	Recv() (*DecryptResponse, error)
	grpc.ClientStream
}

type Dapr_DecryptAlpha1Server 

type Dapr_DecryptAlpha1Server interface {
	Send(*DecryptResponse) error
	Recv() (*DecryptRequest, error)
	grpc.ServerStream
}

type Dapr_EncryptAlpha1Client 

type Dapr_EncryptAlpha1Client interface {
	Send(*EncryptRequest) error
	Recv() (*EncryptResponse, error)
	grpc.ClientStream
}

type Dapr_EncryptAlpha1Server 

type Dapr_EncryptAlpha1Server interface {
	Send(*EncryptResponse) error
	Recv() (*EncryptRequest, error)
	grpc.ServerStream
}

type Dapr_SubscribeConfigurationAlpha1Client 

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

type Dapr_SubscribeConfigurationAlpha1Server 

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

type Dapr_SubscribeConfigurationClient 

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

type Dapr_SubscribeConfigurationServer 

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

type Dapr_SubscribeTopicEventsAlpha1Client 

type Dapr_SubscribeTopicEventsAlpha1Client interface {
	Send(*SubscribeTopicEventsRequestAlpha1) error
	Recv() (*SubscribeTopicEventsResponseAlpha1, error)
	grpc.ClientStream
}

type Dapr_SubscribeTopicEventsAlpha1Server 

type Dapr_SubscribeTopicEventsAlpha1Server interface {
	Send(*SubscribeTopicEventsResponseAlpha1) error
	Recv() (*SubscribeTopicEventsRequestAlpha1, error)
	grpc.ServerStream
}

type DecryptRequest 

type DecryptRequest struct {

	// Request details. Must be present in the first message only.
	Options *DecryptRequestOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// Chunk of data of arbitrary size.
	Payload *v1.StreamPayload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

DecryptRequest is the request for DecryptAlpha1.

func (*DecryptRequest) AppendSpanAttributes 

func (*DecryptRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*DecryptRequest) Descriptor deprecated 

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

Deprecated: Use DecryptRequest.ProtoReflect.Descriptor instead.

func (*DecryptRequest) GetOptions 

func (x *DecryptRequest) GetOptions() *DecryptRequestOptions

func (*DecryptRequest) GetPayload 

func (x *DecryptRequest) GetPayload() *v1.StreamPayload

func (*DecryptRequest) HasOptions 

func (x *DecryptRequest) HasOptions() bool

func (*DecryptRequest) ProtoMessage 

func (*DecryptRequest) ProtoMessage()

func (*DecryptRequest) ProtoReflect 

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

func (*DecryptRequest) Reset 

func (x *DecryptRequest) Reset()

func (*DecryptRequest) SetOptions 

func (x *DecryptRequest) SetOptions(opts proto.Message)

func (*DecryptRequest) SetPayload 

func (x *DecryptRequest) SetPayload(payload *commonv1pb.StreamPayload)

func (*DecryptRequest) String 

func (x *DecryptRequest) String() string

type DecryptRequestOptions 

type DecryptRequestOptions struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Name (or name/version) of the key to decrypt the message.
	// Overrides any key reference included in the message if present.
	// This is required if the message doesn't include a key reference (i.e. was created with omit_decryption_key_name set to true).
	KeyName string `protobuf:"bytes,12,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// contains filtered or unexported fields
}

DecryptRequestOptions contains options for the first message in the DecryptAlpha1 request.

func (*DecryptRequestOptions) Descriptor deprecated 

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

Deprecated: Use DecryptRequestOptions.ProtoReflect.Descriptor instead.

func (*DecryptRequestOptions) GetComponentName 

func (x *DecryptRequestOptions) GetComponentName() string

func (*DecryptRequestOptions) GetKeyName 

func (x *DecryptRequestOptions) GetKeyName() string

func (*DecryptRequestOptions) ProtoMessage 

func (*DecryptRequestOptions) ProtoMessage()

func (*DecryptRequestOptions) ProtoReflect 

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

func (*DecryptRequestOptions) Reset 

func (x *DecryptRequestOptions) Reset()

func (*DecryptRequestOptions) String 

func (x *DecryptRequestOptions) String() string

type DecryptResponse 

type DecryptResponse struct {

	// Chunk of data.
	Payload *v1.StreamPayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

DecryptResponse is the response for DecryptAlpha1.

func (*DecryptResponse) Descriptor deprecated 

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

Deprecated: Use DecryptResponse.ProtoReflect.Descriptor instead.

func (*DecryptResponse) GetPayload 

func (x *DecryptResponse) GetPayload() *v1.StreamPayload

func (*DecryptResponse) ProtoMessage 

func (*DecryptResponse) ProtoMessage()

func (*DecryptResponse) ProtoReflect 

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

func (*DecryptResponse) Reset 

func (x *DecryptResponse) Reset()

func (*DecryptResponse) SetPayload 

func (x *DecryptResponse) SetPayload(payload *commonv1pb.StreamPayload)

func (*DecryptResponse) String 

func (x *DecryptResponse) String() string

type DeleteBulkStateRequest 

type DeleteBulkStateRequest struct {

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

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

func (*DeleteBulkStateRequest) AppendSpanAttributes 

func (*DeleteBulkStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*DeleteBulkStateRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBulkStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteBulkStateRequest) GetStates 

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

func (*DeleteBulkStateRequest) GetStoreName 

func (x *DeleteBulkStateRequest) GetStoreName() string

func (*DeleteBulkStateRequest) ProtoMessage 

func (*DeleteBulkStateRequest) ProtoMessage()

func (*DeleteBulkStateRequest) ProtoReflect 

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

func (*DeleteBulkStateRequest) Reset 

func (x *DeleteBulkStateRequest) Reset()

func (*DeleteBulkStateRequest) String 

func (x *DeleteBulkStateRequest) String() string

type DeleteJobRequest 

type DeleteJobRequest struct {

	// The name of the job.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteJobRequest is the message to delete the job by name.

func (*DeleteJobRequest) AppendSpanAttributes 

func (*DeleteJobRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*DeleteJobRequest) Descriptor deprecated 

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

Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobRequest) GetName 

func (x *DeleteJobRequest) GetName() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect 

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

func (*DeleteJobRequest) Reset 

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (x *DeleteJobRequest) String() string

type DeleteJobResponse 

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

DeleteJobResponse is the message response to delete the job by name.

func (*DeleteJobResponse) Descriptor deprecated 

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

Deprecated: Use DeleteJobResponse.ProtoReflect.Descriptor instead.

func (*DeleteJobResponse) ProtoMessage 

func (*DeleteJobResponse) ProtoMessage()

func (*DeleteJobResponse) ProtoReflect 

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

func (*DeleteJobResponse) Reset 

func (x *DeleteJobResponse) Reset()

func (*DeleteJobResponse) String 

func (x *DeleteJobResponse) 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) AppendSpanAttributes 

func (x *DeleteStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*DeleteStateRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteStateRequest) GetEtag 

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

func (*DeleteStateRequest) GetKey 

func (x *DeleteStateRequest) GetKey() string

func (*DeleteStateRequest) GetMetadata 

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

func (*DeleteStateRequest) GetOptions 

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

func (*DeleteStateRequest) GetStoreName 

func (x *DeleteStateRequest) GetStoreName() string

func (*DeleteStateRequest) ProtoMessage 

func (*DeleteStateRequest) ProtoMessage()

func (*DeleteStateRequest) ProtoReflect 

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

func (*DeleteStateRequest) Reset 

func (x *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String 

func (x *DeleteStateRequest) String() string

type EncryptRequest 

type EncryptRequest struct {

	// Request details. Must be present in the first message only.
	Options *EncryptRequestOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// Chunk of data of arbitrary size.
	Payload *v1.StreamPayload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

EncryptRequest is the request for EncryptAlpha1.

func (*EncryptRequest) AppendSpanAttributes 

func (*EncryptRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*EncryptRequest) Descriptor deprecated 

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

Deprecated: Use EncryptRequest.ProtoReflect.Descriptor instead.

func (*EncryptRequest) GetOptions 

func (x *EncryptRequest) GetOptions() *EncryptRequestOptions

func (*EncryptRequest) GetPayload 

func (x *EncryptRequest) GetPayload() *v1.StreamPayload

func (*EncryptRequest) HasOptions 

func (x *EncryptRequest) HasOptions() bool

func (*EncryptRequest) ProtoMessage 

func (*EncryptRequest) ProtoMessage()

func (*EncryptRequest) ProtoReflect 

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

func (*EncryptRequest) Reset 

func (x *EncryptRequest) Reset()

func (*EncryptRequest) SetOptions 

func (x *EncryptRequest) SetOptions(opts proto.Message)

func (*EncryptRequest) SetPayload 

func (x *EncryptRequest) SetPayload(payload *commonv1pb.StreamPayload)

func (*EncryptRequest) String 

func (x *EncryptRequest) String() string

type EncryptRequestOptions 

type EncryptRequestOptions struct {

	// Name of the component. Required.
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Name (or name/version) of the key. Required.
	KeyName string `protobuf:"bytes,2,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// Key wrapping algorithm to use. Required.
	// Supported options include: A256KW (alias: AES), A128CBC, A192CBC, A256CBC, RSA-OAEP-256 (alias: RSA).
	KeyWrapAlgorithm string `protobuf:"bytes,3,opt,name=key_wrap_algorithm,json=keyWrapAlgorithm,proto3" json:"key_wrap_algorithm,omitempty"`
	// Cipher used to encrypt data (optional): "aes-gcm" (default) or "chacha20-poly1305"
	DataEncryptionCipher string `protobuf:"bytes,10,opt,name=data_encryption_cipher,json=dataEncryptionCipher,proto3" json:"data_encryption_cipher,omitempty"`
	// If true, the encrypted document does not contain a key reference.
	// In that case, calls to the Decrypt method must provide a key reference (name or name/version).
	// Defaults to false.
	OmitDecryptionKeyName bool `` /* 130-byte string literal not displayed */
	// Key reference to embed in the encrypted document (name or name/version).
	// This is helpful if the reference of the key used to decrypt the document is different from the one used to encrypt it.
	// If unset, uses the reference of the key used to encrypt the document (this is the default behavior).
	// This option is ignored if omit_decryption_key_name is true.
	DecryptionKeyName string `protobuf:"bytes,12,opt,name=decryption_key_name,json=decryptionKeyName,proto3" json:"decryption_key_name,omitempty"`
	// contains filtered or unexported fields
}

EncryptRequestOptions contains options for the first message in the EncryptAlpha1 request.

func (*EncryptRequestOptions) Descriptor deprecated 

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

Deprecated: Use EncryptRequestOptions.ProtoReflect.Descriptor instead.

func (*EncryptRequestOptions) GetComponentName 

func (x *EncryptRequestOptions) GetComponentName() string

func (*EncryptRequestOptions) GetDataEncryptionCipher 

func (x *EncryptRequestOptions) GetDataEncryptionCipher() string

func (*EncryptRequestOptions) GetDecryptionKeyName 

func (x *EncryptRequestOptions) GetDecryptionKeyName() string

func (*EncryptRequestOptions) GetKeyName 

func (x *EncryptRequestOptions) GetKeyName() string

func (*EncryptRequestOptions) GetKeyWrapAlgorithm 

func (x *EncryptRequestOptions) GetKeyWrapAlgorithm() string

func (*EncryptRequestOptions) GetOmitDecryptionKeyName 

func (x *EncryptRequestOptions) GetOmitDecryptionKeyName() bool

func (*EncryptRequestOptions) ProtoMessage 

func (*EncryptRequestOptions) ProtoMessage()

func (*EncryptRequestOptions) ProtoReflect 

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

func (*EncryptRequestOptions) Reset 

func (x *EncryptRequestOptions) Reset()

func (*EncryptRequestOptions) String 

func (x *EncryptRequestOptions) String() string

type EncryptResponse 

type EncryptResponse struct {

	// Chunk of data.
	Payload *v1.StreamPayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

EncryptResponse is the response for EncryptAlpha1.

func (*EncryptResponse) Descriptor deprecated 

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

Deprecated: Use EncryptResponse.ProtoReflect.Descriptor instead.

func (*EncryptResponse) GetPayload 

func (x *EncryptResponse) GetPayload() *v1.StreamPayload

func (*EncryptResponse) ProtoMessage 

func (*EncryptResponse) ProtoMessage()

func (*EncryptResponse) ProtoReflect 

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

func (*EncryptResponse) Reset 

func (x *EncryptResponse) Reset()

func (*EncryptResponse) SetPayload 

func (x *EncryptResponse) SetPayload(payload *commonv1pb.StreamPayload)

func (*EncryptResponse) String 

func (x *EncryptResponse) String() string

type ExecuteActorStateTransactionRequest 

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

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

func (*ExecuteActorStateTransactionRequest) AppendSpanAttributes 

func (*ExecuteActorStateTransactionRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*ExecuteActorStateTransactionRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteActorStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActorStateTransactionRequest) GetActorId 

func (x *ExecuteActorStateTransactionRequest) GetActorId() string

func (*ExecuteActorStateTransactionRequest) GetActorType 

func (x *ExecuteActorStateTransactionRequest) GetActorType() string

func (*ExecuteActorStateTransactionRequest) GetOperations 

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

func (*ExecuteActorStateTransactionRequest) ProtoMessage 

func (*ExecuteActorStateTransactionRequest) ProtoMessage()

func (*ExecuteActorStateTransactionRequest) ProtoReflect 

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

func (*ExecuteActorStateTransactionRequest) Reset 

func (x *ExecuteActorStateTransactionRequest) Reset()

func (*ExecuteActorStateTransactionRequest) String 

func (x *ExecuteActorStateTransactionRequest) String() string

type ExecuteStateTransactionRequest 

type ExecuteStateTransactionRequest struct {

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

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

func (*ExecuteStateTransactionRequest) AppendSpanAttributes 

func (*ExecuteStateTransactionRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*ExecuteStateTransactionRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStateTransactionRequest) GetMetadata 

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

func (*ExecuteStateTransactionRequest) GetOperations 

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

func (*ExecuteStateTransactionRequest) GetStoreName 

func (x *ExecuteStateTransactionRequest) GetStoreName() string

func (*ExecuteStateTransactionRequest) ProtoMessage 

func (*ExecuteStateTransactionRequest) ProtoMessage()

func (*ExecuteStateTransactionRequest) ProtoReflect 

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

func (*ExecuteStateTransactionRequest) Reset 

func (x *ExecuteStateTransactionRequest) Reset()

func (*ExecuteStateTransactionRequest) String 

func (x *ExecuteStateTransactionRequest) String() string

type GetActorStateRequest 

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

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

func (*GetActorStateRequest) AppendSpanAttributes 

func (*GetActorStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetActorStateRequest) Descriptor deprecated 

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

Deprecated: Use GetActorStateRequest.ProtoReflect.Descriptor instead.

func (*GetActorStateRequest) GetActorId 

func (x *GetActorStateRequest) GetActorId() string

func (*GetActorStateRequest) GetActorType 

func (x *GetActorStateRequest) GetActorType() string

func (*GetActorStateRequest) GetKey 

func (x *GetActorStateRequest) GetKey() string

func (*GetActorStateRequest) ProtoMessage 

func (*GetActorStateRequest) ProtoMessage()

func (*GetActorStateRequest) ProtoReflect 

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

func (*GetActorStateRequest) Reset 

func (x *GetActorStateRequest) Reset()

func (*GetActorStateRequest) String 

func (x *GetActorStateRequest) String() string

type GetActorStateResponse 

type GetActorStateResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata which will be sent to app.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*GetActorStateResponse) Descriptor deprecated 

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

Deprecated: Use GetActorStateResponse.ProtoReflect.Descriptor instead.

func (*GetActorStateResponse) GetData 

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

func (*GetActorStateResponse) GetMetadata 

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

func (*GetActorStateResponse) ProtoMessage 

func (*GetActorStateResponse) ProtoMessage()

func (*GetActorStateResponse) ProtoReflect 

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

func (*GetActorStateResponse) Reset 

func (x *GetActorStateResponse) Reset()

func (*GetActorStateResponse) String 

func (x *GetActorStateResponse) String() string

type GetBulkSecretRequest 

type GetBulkSecretRequest struct {

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

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

func (*GetBulkSecretRequest) AppendSpanAttributes 

func (*GetBulkSecretRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetBulkSecretRequest) Descriptor deprecated 

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

Deprecated: Use GetBulkSecretRequest.ProtoReflect.Descriptor instead.

func (*GetBulkSecretRequest) GetMetadata 

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

func (*GetBulkSecretRequest) GetStoreName 

func (x *GetBulkSecretRequest) GetStoreName() string

func (*GetBulkSecretRequest) ProtoMessage 

func (*GetBulkSecretRequest) ProtoMessage()

func (*GetBulkSecretRequest) ProtoReflect 

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

func (*GetBulkSecretRequest) Reset 

func (x *GetBulkSecretRequest) Reset()

func (*GetBulkSecretRequest) String 

func (x *GetBulkSecretRequest) String() string

type GetBulkSecretResponse 

type GetBulkSecretResponse struct {

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

GetBulkSecretResponse is the response message to convey the requested secrets.

func (*GetBulkSecretResponse) Descriptor deprecated 

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

Deprecated: Use GetBulkSecretResponse.ProtoReflect.Descriptor instead.

func (*GetBulkSecretResponse) GetData 

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

func (*GetBulkSecretResponse) ProtoMessage 

func (*GetBulkSecretResponse) ProtoMessage()

func (*GetBulkSecretResponse) ProtoReflect 

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

func (*GetBulkSecretResponse) Reset 

func (x *GetBulkSecretResponse) Reset()

func (*GetBulkSecretResponse) String 

func (x *GetBulkSecretResponse) String() string

type GetBulkStateRequest 

type GetBulkStateRequest struct {

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

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

func (*GetBulkStateRequest) AppendSpanAttributes 

func (*GetBulkStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetBulkStateRequest) Descriptor deprecated 

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

Deprecated: Use GetBulkStateRequest.ProtoReflect.Descriptor instead.

func (*GetBulkStateRequest) GetKeys 

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

func (*GetBulkStateRequest) GetMetadata 

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

func (*GetBulkStateRequest) GetParallelism 

func (x *GetBulkStateRequest) GetParallelism() int32

func (*GetBulkStateRequest) GetStoreName 

func (x *GetBulkStateRequest) GetStoreName() string

func (*GetBulkStateRequest) ProtoMessage 

func (*GetBulkStateRequest) ProtoMessage()

func (*GetBulkStateRequest) ProtoReflect 

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

func (*GetBulkStateRequest) Reset 

func (x *GetBulkStateRequest) Reset()

func (*GetBulkStateRequest) String 

func (x *GetBulkStateRequest) String() string

type GetBulkStateResponse 

type GetBulkStateResponse struct {

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

GetBulkStateResponse is the response conveying the list of state values.

func (*GetBulkStateResponse) Descriptor deprecated 

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

Deprecated: Use GetBulkStateResponse.ProtoReflect.Descriptor instead.

func (*GetBulkStateResponse) GetItems 

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

func (*GetBulkStateResponse) ProtoMessage 

func (*GetBulkStateResponse) ProtoMessage()

func (*GetBulkStateResponse) ProtoReflect 

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

func (*GetBulkStateResponse) Reset 

func (x *GetBulkStateResponse) Reset()

func (*GetBulkStateResponse) String 

func (x *GetBulkStateResponse) String() string

type GetConfigurationRequest 

type GetConfigurationRequest struct {

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

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

func (*GetConfigurationRequest) AppendSpanAttributes 

func (*GetConfigurationRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetKeys 

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

func (*GetConfigurationRequest) GetMetadata 

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

func (*GetConfigurationRequest) GetStoreName 

func (x *GetConfigurationRequest) GetStoreName() string

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect 

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

func (*GetConfigurationRequest) Reset 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String 

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse 

type GetConfigurationResponse struct {
	Items 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 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetItems 

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

func (*GetConfigurationResponse) ProtoMessage 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect 

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

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

type GetJobRequest 

type GetJobRequest struct {

	// The name of the job.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetJobRequest is the message to retrieve a job.

func (*GetJobRequest) AppendSpanAttributes 

func (*GetJobRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetName 

func (x *GetJobRequest) GetName() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

type GetJobResponse struct {

	// The job details.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

GetJobResponse is the message's response for a job retrieved.

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

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

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type GetMetadataRequest 

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

GetMetadataRequest is the message for the GetMetadata request.

func (*GetMetadataRequest) AppendSpanAttributes 

func (*GetMetadataRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetMetadataRequest) Descriptor deprecated 

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

Deprecated: Use GetMetadataRequest.ProtoReflect.Descriptor instead.

func (*GetMetadataRequest) ProtoMessage 

func (*GetMetadataRequest) ProtoMessage()

func (*GetMetadataRequest) ProtoReflect 

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

func (*GetMetadataRequest) Reset 

func (x *GetMetadataRequest) Reset()

func (*GetMetadataRequest) String 

func (x *GetMetadataRequest) String() string

type GetMetadataResponse 

type GetMetadataResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Deprecated alias for actor_runtime.active_actors.
	//
	// Deprecated: Marked as deprecated in dapr/proto/runtime/v1/dapr.proto.
	ActiveActorsCount       []*ActiveActorsCount     `protobuf:"bytes,2,rep,name=active_actors_count,json=actors,proto3" json:"active_actors_count,omitempty"`
	RegisteredComponents    []*RegisteredComponents  `protobuf:"bytes,3,rep,name=registered_components,json=components,proto3" json:"registered_components,omitempty"`
	ExtendedMetadata        map[string]string        `` /* 189-byte string literal not displayed */
	Subscriptions           []*PubsubSubscription    `protobuf:"bytes,5,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	HttpEndpoints           []*MetadataHTTPEndpoint  `protobuf:"bytes,6,rep,name=http_endpoints,json=httpEndpoints,proto3" json:"http_endpoints,omitempty"`
	AppConnectionProperties *AppConnectionProperties `` /* 132-byte string literal not displayed */
	RuntimeVersion          string                   `protobuf:"bytes,8,opt,name=runtime_version,json=runtimeVersion,proto3" json:"runtime_version,omitempty"`
	EnabledFeatures         []string                 `protobuf:"bytes,9,rep,name=enabled_features,json=enabledFeatures,proto3" json:"enabled_features,omitempty"`
	ActorRuntime            *ActorRuntime            `protobuf:"bytes,10,opt,name=actor_runtime,json=actorRuntime,proto3" json:"actor_runtime,omitempty"` //TODO: Cassie: probably add scheduler runtime status
	// contains filtered or unexported fields
}

GetMetadataResponse is a message that is returned on GetMetadata rpc call.

func (*GetMetadataResponse) Descriptor deprecated 

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

Deprecated: Use GetMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetMetadataResponse) GetActiveActorsCount deprecated 

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

Deprecated: Marked as deprecated in dapr/proto/runtime/v1/dapr.proto.

func (*GetMetadataResponse) GetActorRuntime 

func (x *GetMetadataResponse) GetActorRuntime() *ActorRuntime

func (*GetMetadataResponse) GetAppConnectionProperties 

func (x *GetMetadataResponse) GetAppConnectionProperties() *AppConnectionProperties

func (*GetMetadataResponse) GetEnabledFeatures 

func (x *GetMetadataResponse) GetEnabledFeatures() []string

func (*GetMetadataResponse) GetExtendedMetadata 

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

func (*GetMetadataResponse) GetHttpEndpoints 

func (x *GetMetadataResponse) GetHttpEndpoints() []*MetadataHTTPEndpoint

func (*GetMetadataResponse) GetId 

func (x *GetMetadataResponse) GetId() string

func (*GetMetadataResponse) GetRegisteredComponents 

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

func (*GetMetadataResponse) GetRuntimeVersion 

func (x *GetMetadataResponse) GetRuntimeVersion() string

func (*GetMetadataResponse) GetSubscriptions 

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

func (*GetMetadataResponse) ProtoMessage 

func (*GetMetadataResponse) ProtoMessage()

func (*GetMetadataResponse) ProtoReflect 

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

func (*GetMetadataResponse) Reset 

func (x *GetMetadataResponse) Reset()

func (*GetMetadataResponse) String 

func (x *GetMetadataResponse) String() string

type GetSecretRequest 

type GetSecretRequest struct {

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

GetSecretRequest is the message to get secret from secret store.

func (*GetSecretRequest) AppendSpanAttributes 

func (x *GetSecretRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetSecretRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetKey 

func (x *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetMetadata 

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

func (*GetSecretRequest) GetStoreName 

func (x *GetSecretRequest) GetStoreName() string

func (*GetSecretRequest) ProtoMessage 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect 

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

func (*GetSecretRequest) Reset 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String 

func (x *GetSecretRequest) String() string

type GetSecretResponse 

type GetSecretResponse struct {

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

GetSecretResponse is the response message to convey the requested secret.

func (*GetSecretResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetData 

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

func (*GetSecretResponse) ProtoMessage 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect 

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

func (*GetSecretResponse) Reset 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String 

func (x *GetSecretResponse) String() string

type GetStateRequest 

type GetStateRequest struct {

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

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

func (*GetStateRequest) AppendSpanAttributes 

func (x *GetStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) GetConsistency 

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

func (*GetStateRequest) GetKey 

func (x *GetStateRequest) GetKey() string

func (*GetStateRequest) GetMetadata 

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

func (*GetStateRequest) GetStoreName 

func (x *GetStateRequest) GetStoreName() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

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

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {

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

GetStateResponse is the response conveying the state value and etag.

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetData 

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

func (*GetStateResponse) GetEtag 

func (x *GetStateResponse) GetEtag() string

func (*GetStateResponse) GetMetadata 

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

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type GetWorkflowRequest 

type GetWorkflowRequest struct {

	// ID of the workflow instance to query.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

GetWorkflowRequest is the request for GetWorkflowBeta1.

func (*GetWorkflowRequest) AppendSpanAttributes 

func (*GetWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*GetWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetInstanceId 

func (x *GetWorkflowRequest) GetInstanceId() string

func (*GetWorkflowRequest) GetWorkflowComponent 

func (x *GetWorkflowRequest) GetWorkflowComponent() string

func (*GetWorkflowRequest) ProtoMessage 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect 

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

func (*GetWorkflowRequest) Reset 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) SetInstanceId 

func (x *GetWorkflowRequest) SetInstanceId(val string)

func (*GetWorkflowRequest) SetWorkflowComponent 

func (x *GetWorkflowRequest) SetWorkflowComponent(val string)

func (*GetWorkflowRequest) String 

func (x *GetWorkflowRequest) String() string

type GetWorkflowResponse 

type GetWorkflowResponse struct {

	// ID of the workflow instance.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow.
	WorkflowName string `protobuf:"bytes,2,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	// The time at which the workflow instance was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The last time at which the workflow instance had its state changed.
	LastUpdatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_updated_at,json=lastUpdatedAt,proto3" json:"last_updated_at,omitempty"`
	// The current status of the workflow instance, for example, "PENDING", "RUNNING", "SUSPENDED", "COMPLETED", "FAILED", and "TERMINATED".
	RuntimeStatus string `protobuf:"bytes,5,opt,name=runtime_status,json=runtimeStatus,proto3" json:"runtime_status,omitempty"`
	// Additional component-specific properties of the workflow instance.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetWorkflowResponse is the response for GetWorkflowBeta1.

func (*GetWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse) GetCreatedAt 

func (x *GetWorkflowResponse) GetCreatedAt() *timestamppb.Timestamp

func (*GetWorkflowResponse) GetInstanceId 

func (x *GetWorkflowResponse) GetInstanceId() string

func (*GetWorkflowResponse) GetLastUpdatedAt 

func (x *GetWorkflowResponse) GetLastUpdatedAt() *timestamppb.Timestamp

func (*GetWorkflowResponse) GetProperties 

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

func (*GetWorkflowResponse) GetRuntimeStatus 

func (x *GetWorkflowResponse) GetRuntimeStatus() string

func (*GetWorkflowResponse) GetWorkflowName 

func (x *GetWorkflowResponse) GetWorkflowName() string

func (*GetWorkflowResponse) ProtoMessage 

func (*GetWorkflowResponse) ProtoMessage()

func (*GetWorkflowResponse) ProtoReflect 

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

func (*GetWorkflowResponse) Reset 

func (x *GetWorkflowResponse) Reset()

func (*GetWorkflowResponse) String 

func (x *GetWorkflowResponse) String() string

type HealthCheckResponse 

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 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type InvokeActorRequest 

type InvokeActorRequest struct {
	ActorType string            `protobuf:"bytes,1,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	ActorId   string            `protobuf:"bytes,2,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Method    string            `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Data      []byte            `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	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) AppendSpanAttributes 

func (*InvokeActorRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*InvokeActorRequest) Descriptor deprecated 

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

Deprecated: Use InvokeActorRequest.ProtoReflect.Descriptor instead.

func (*InvokeActorRequest) GetActorId 

func (x *InvokeActorRequest) GetActorId() string

func (*InvokeActorRequest) GetActorType 

func (x *InvokeActorRequest) GetActorType() string

func (*InvokeActorRequest) GetData 

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

func (*InvokeActorRequest) GetMetadata 

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

func (*InvokeActorRequest) GetMethod 

func (x *InvokeActorRequest) GetMethod() string

func (*InvokeActorRequest) ProtoMessage 

func (*InvokeActorRequest) ProtoMessage()

func (*InvokeActorRequest) ProtoReflect 

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

func (*InvokeActorRequest) Reset 

func (x *InvokeActorRequest) Reset()

func (*InvokeActorRequest) String 

func (x *InvokeActorRequest) String() string

func (*InvokeActorRequest) ToInternalInvokeRequest 

func (x *InvokeActorRequest) ToInternalInvokeRequest() *internalv1pb.InternalInvokeRequest

type InvokeActorResponse 

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

InvokeActorResponse is the method that returns an actor invocation response.

func (*InvokeActorResponse) Descriptor deprecated 

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

Deprecated: Use InvokeActorResponse.ProtoReflect.Descriptor instead.

func (*InvokeActorResponse) GetData 

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

func (*InvokeActorResponse) ProtoMessage 

func (*InvokeActorResponse) ProtoMessage()

func (*InvokeActorResponse) ProtoReflect 

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

func (*InvokeActorResponse) Reset 

func (x *InvokeActorResponse) Reset()

func (*InvokeActorResponse) String 

func (x *InvokeActorResponse) String() string

type InvokeBindingRequest 

type InvokeBindingRequest struct {

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

InvokeBindingRequest is the message to send data to output bindings

func (*InvokeBindingRequest) AppendSpanAttributes 

func (x *InvokeBindingRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*InvokeBindingRequest) Descriptor deprecated 

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

Deprecated: Use InvokeBindingRequest.ProtoReflect.Descriptor instead.

func (*InvokeBindingRequest) GetData 

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

func (*InvokeBindingRequest) GetMetadata 

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

func (*InvokeBindingRequest) GetName 

func (x *InvokeBindingRequest) GetName() string

func (*InvokeBindingRequest) GetOperation 

func (x *InvokeBindingRequest) GetOperation() string

func (*InvokeBindingRequest) ProtoMessage 

func (*InvokeBindingRequest) ProtoMessage()

func (*InvokeBindingRequest) ProtoReflect 

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

func (*InvokeBindingRequest) Reset 

func (x *InvokeBindingRequest) Reset()

func (*InvokeBindingRequest) String 

func (x *InvokeBindingRequest) String() string

type InvokeBindingResponse 

type InvokeBindingResponse struct {

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

InvokeBindingResponse is the message returned from an output binding invocation

func (*InvokeBindingResponse) Descriptor deprecated 

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

Deprecated: Use InvokeBindingResponse.ProtoReflect.Descriptor instead.

func (*InvokeBindingResponse) GetData 

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

func (*InvokeBindingResponse) GetMetadata 

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

func (*InvokeBindingResponse) ProtoMessage 

func (*InvokeBindingResponse) ProtoMessage()

func (*InvokeBindingResponse) ProtoReflect 

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

func (*InvokeBindingResponse) Reset 

func (x *InvokeBindingResponse) Reset()

func (*InvokeBindingResponse) String 

func (x *InvokeBindingResponse) String() string

type InvokeServiceRequest 

type InvokeServiceRequest struct {

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

InvokeServiceRequest represents the request message for Service invocation.

func (*InvokeServiceRequest) AppendSpanAttributes 

func (x *InvokeServiceRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*InvokeServiceRequest) Descriptor deprecated 

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

Deprecated: Use InvokeServiceRequest.ProtoReflect.Descriptor instead.

func (*InvokeServiceRequest) GetId 

func (x *InvokeServiceRequest) GetId() string

func (*InvokeServiceRequest) GetMessage 

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

func (*InvokeServiceRequest) ProtoMessage 

func (*InvokeServiceRequest) ProtoMessage()

func (*InvokeServiceRequest) ProtoReflect 

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

func (*InvokeServiceRequest) Reset 

func (x *InvokeServiceRequest) Reset()

func (*InvokeServiceRequest) String 

func (x *InvokeServiceRequest) String() string

type Job 

type Job struct {

	// The unique name for the job.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// schedule is an optional schedule at which the job is to be run.
	// Accepts both systemd timer style cron expressions, as well as human
	// readable '@' prefixed period strings as defined below.
	//
	// Systemd timer style cron accepts 6 fields:
	// seconds | minutes | hours | day of month | month        | day of week
	// 0-59    | 0-59    | 0-23  | 1-31         | 1-12/jan-dec | 0-6/sun-sat
	//
	// "0 30 * * * *" - every hour on the half hour
	// "0 15 3 * * *" - every day at 03:15
	//
	// Period string expressions:
	// Entry                  | Description                                  | Equivalent To
	// -----                  | -----------                                  | -------------
	// @every `<duration>`    | Run every `<duration>` (e.g. '@every 1h30m') | N/A
	// @yearly (or @annually) | Run once a year, midnight, Jan. 1st          | 0 0 0 1 1 *
	// @monthly               | Run once a month, midnight, first of month   | 0 0 0 1 * *
	// @weekly                | Run once a week, midnight on Sunday          | 0 0 0 * * 0
	// @daily (or @midnight)  | Run once a day, midnight                     | 0 0 0 * * *
	// @hourly                | Run once an hour, beginning of hour          | 0 0 * * * *
	Schedule *string `protobuf:"bytes,2,opt,name=schedule,proto3,oneof" json:"schedule,omitempty"`
	// repeats is the optional number of times in which the job should be
	// triggered. If not set, the job will run indefinitely or until expiration.
	Repeats *uint32 `protobuf:"varint,3,opt,name=repeats,proto3,oneof" json:"repeats,omitempty"`
	// due_time is the optional time at which the job should be active, or the
	// "one shot" time if other scheduling type fields are not provided. Accepts
	// a "point in time" string in the format of RFC3339, Go duration string
	// (calculated from job creation time), or non-repeating ISO8601.
	DueTime *string `protobuf:"bytes,4,opt,name=due_time,json=dueTime,proto3,oneof" json:"due_time,omitempty"`
	// ttl is the optional time to live or expiration of the job. Accepts a
	// "point in time" string in the format of RFC3339, Go duration string
	// (calculated from job creation time), or non-repeating ISO8601.
	Ttl *string `protobuf:"bytes,5,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	// payload is the serialized job payload that will be sent to the recipient
	// when the job is triggered.
	Data *anypb.Any `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Job is the definition of a job. At least one of schedule or due_time must be provided but can also be provided together.

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetData 

func (x *Job) GetData() *anypb.Any

func (*Job) GetDueTime 

func (x *Job) GetDueTime() string

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetRepeats 

func (x *Job) GetRepeats() uint32

func (*Job) GetSchedule 

func (x *Job) GetSchedule() string

func (*Job) GetTtl 

func (x *Job) GetTtl() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobEventRequest 

type JobEventRequest struct {

	// Job name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Job data to be sent back to app.
	Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Required. method is a method name which will be invoked by caller.
	Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	// The type of data content.
	//
	// This field is required if data delivers http request body
	// Otherwise, this is optional.
	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// HTTP specific fields if request conveys http-compatible request.
	//
	// This field is required for http-compatible request. Otherwise,
	// this field is optional.
	HttpExtension *v1.HTTPExtension `protobuf:"bytes,5,opt,name=http_extension,json=httpExtension,proto3" json:"http_extension,omitempty"`
	// contains filtered or unexported fields
}

func (*JobEventRequest) Descriptor deprecated 

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

Deprecated: Use JobEventRequest.ProtoReflect.Descriptor instead.

func (*JobEventRequest) GetContentType 

func (x *JobEventRequest) GetContentType() string

func (*JobEventRequest) GetData 

func (x *JobEventRequest) GetData() *anypb.Any

func (*JobEventRequest) GetHttpExtension 

func (x *JobEventRequest) GetHttpExtension() *v1.HTTPExtension

func (*JobEventRequest) GetMethod 

func (x *JobEventRequest) GetMethod() string

func (*JobEventRequest) GetName 

func (x *JobEventRequest) GetName() string

func (*JobEventRequest) ProtoMessage 

func (*JobEventRequest) ProtoMessage()

func (*JobEventRequest) ProtoReflect 

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

func (*JobEventRequest) Reset 

func (x *JobEventRequest) Reset()

func (*JobEventRequest) String 

func (x *JobEventRequest) String() string

type JobEventResponse 

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

JobEventResponse is the response from the app when a job is triggered.

func (*JobEventResponse) Descriptor deprecated 

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

Deprecated: Use JobEventResponse.ProtoReflect.Descriptor instead.

func (*JobEventResponse) ProtoMessage 

func (*JobEventResponse) ProtoMessage()

func (*JobEventResponse) ProtoReflect 

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

func (*JobEventResponse) Reset 

func (x *JobEventResponse) Reset()

func (*JobEventResponse) String 

func (x *JobEventResponse) String() string

type ListInputBindingsResponse 

type ListInputBindingsResponse struct {

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

ListInputBindingsResponse is the message including the list of input bindings.

func (*ListInputBindingsResponse) Descriptor deprecated 

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

Deprecated: Use ListInputBindingsResponse.ProtoReflect.Descriptor instead.

func (*ListInputBindingsResponse) GetBindings 

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

func (*ListInputBindingsResponse) ProtoMessage 

func (*ListInputBindingsResponse) ProtoMessage()

func (*ListInputBindingsResponse) ProtoReflect 

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

func (*ListInputBindingsResponse) Reset 

func (x *ListInputBindingsResponse) Reset()

func (*ListInputBindingsResponse) String 

func (x *ListInputBindingsResponse) String() string

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {

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

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

func (*ListTopicSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

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

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect 

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

func (*ListTopicSubscriptionsResponse) Reset 

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (x *ListTopicSubscriptionsResponse) String() string

type MetadataHTTPEndpoint 

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

func (*MetadataHTTPEndpoint) Descriptor deprecated 

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

Deprecated: Use MetadataHTTPEndpoint.ProtoReflect.Descriptor instead.

func (*MetadataHTTPEndpoint) GetName 

func (x *MetadataHTTPEndpoint) GetName() string

func (*MetadataHTTPEndpoint) ProtoMessage 

func (*MetadataHTTPEndpoint) ProtoMessage()

func (*MetadataHTTPEndpoint) ProtoReflect 

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

func (*MetadataHTTPEndpoint) Reset 

func (x *MetadataHTTPEndpoint) Reset()

func (*MetadataHTTPEndpoint) String 

func (x *MetadataHTTPEndpoint) String() string

type PauseWorkflowRequest 

type PauseWorkflowRequest struct {

	// ID of the workflow instance to pause.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

PauseWorkflowRequest is the request for PauseWorkflowBeta1.

func (*PauseWorkflowRequest) AppendSpanAttributes 

func (*PauseWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*PauseWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use PauseWorkflowRequest.ProtoReflect.Descriptor instead.

func (*PauseWorkflowRequest) GetInstanceId 

func (x *PauseWorkflowRequest) GetInstanceId() string

func (*PauseWorkflowRequest) GetWorkflowComponent 

func (x *PauseWorkflowRequest) GetWorkflowComponent() string

func (*PauseWorkflowRequest) ProtoMessage 

func (*PauseWorkflowRequest) ProtoMessage()

func (*PauseWorkflowRequest) ProtoReflect 

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

func (*PauseWorkflowRequest) Reset 

func (x *PauseWorkflowRequest) Reset()

func (*PauseWorkflowRequest) SetInstanceId 

func (x *PauseWorkflowRequest) SetInstanceId(val string)

func (*PauseWorkflowRequest) SetWorkflowComponent 

func (x *PauseWorkflowRequest) SetWorkflowComponent(val string)

func (*PauseWorkflowRequest) String 

func (x *PauseWorkflowRequest) 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) AppendSpanAttributes 

func (x *PublishEventRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*PublishEventRequest) Descriptor deprecated 

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetData 

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

func (*PublishEventRequest) GetDataContentType 

func (x *PublishEventRequest) GetDataContentType() string

func (*PublishEventRequest) GetMetadata 

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

func (*PublishEventRequest) GetPubsubName 

func (x *PublishEventRequest) GetPubsubName() string

func (*PublishEventRequest) GetTopic 

func (x *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect 

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

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type PubsubSubscription 

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"`
	Type            PubsubSubscriptionType   `protobuf:"varint,6,opt,name=type,proto3,enum=dapr.proto.runtime.v1.PubsubSubscriptionType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*PubsubSubscription) Descriptor deprecated 

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

Deprecated: Use PubsubSubscription.ProtoReflect.Descriptor instead.

func (*PubsubSubscription) GetDeadLetterTopic 

func (x *PubsubSubscription) GetDeadLetterTopic() string

func (*PubsubSubscription) GetMetadata 

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

func (*PubsubSubscription) GetPubsubName 

func (x *PubsubSubscription) GetPubsubName() string

func (*PubsubSubscription) GetRules 

func (x *PubsubSubscription) GetRules() *PubsubSubscriptionRules

func (*PubsubSubscription) GetTopic 

func (x *PubsubSubscription) GetTopic() string

func (*PubsubSubscription) GetType 

func (x *PubsubSubscription) GetType() PubsubSubscriptionType

func (*PubsubSubscription) ProtoMessage 

func (*PubsubSubscription) ProtoMessage()

func (*PubsubSubscription) ProtoReflect 

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

func (*PubsubSubscription) Reset 

func (x *PubsubSubscription) Reset()

func (*PubsubSubscription) String 

func (x *PubsubSubscription) String() string

type PubsubSubscriptionRule 

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 

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

Deprecated: Use PubsubSubscriptionRule.ProtoReflect.Descriptor instead.

func (*PubsubSubscriptionRule) GetMatch 

func (x *PubsubSubscriptionRule) GetMatch() string

func (*PubsubSubscriptionRule) GetPath 

func (x *PubsubSubscriptionRule) GetPath() string

func (*PubsubSubscriptionRule) ProtoMessage 

func (*PubsubSubscriptionRule) ProtoMessage()

func (*PubsubSubscriptionRule) ProtoReflect 

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

func (*PubsubSubscriptionRule) Reset 

func (x *PubsubSubscriptionRule) Reset()

func (*PubsubSubscriptionRule) String 

func (x *PubsubSubscriptionRule) String() string

type PubsubSubscriptionRules 

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

func (*PubsubSubscriptionRules) Descriptor deprecated 

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

Deprecated: Use PubsubSubscriptionRules.ProtoReflect.Descriptor instead.

func (*PubsubSubscriptionRules) GetRules 

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

func (*PubsubSubscriptionRules) ProtoMessage 

func (*PubsubSubscriptionRules) ProtoMessage()

func (*PubsubSubscriptionRules) ProtoReflect 

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

func (*PubsubSubscriptionRules) Reset 

func (x *PubsubSubscriptionRules) Reset()

func (*PubsubSubscriptionRules) String 

func (x *PubsubSubscriptionRules) String() string

type PubsubSubscriptionType 

type PubsubSubscriptionType int32

PubsubSubscriptionType indicates the type of subscription 

const (
	// UNKNOWN is the default value for the subscription type.
	PubsubSubscriptionType_UNKNOWN PubsubSubscriptionType = 0
	// Declarative subscription (k8s CRD)
	PubsubSubscriptionType_DECLARATIVE PubsubSubscriptionType = 1
	// Programmatically created subscription
	PubsubSubscriptionType_PROGRAMMATIC PubsubSubscriptionType = 2
	// Bidirectional Streaming subscription
	PubsubSubscriptionType_STREAMING PubsubSubscriptionType = 3
)

func (PubsubSubscriptionType) Descriptor 

func (PubsubSubscriptionType) Descriptor() protoreflect.EnumDescriptor

func (PubsubSubscriptionType) Enum 

func (x PubsubSubscriptionType) Enum() *PubsubSubscriptionType

func (PubsubSubscriptionType) EnumDescriptor deprecated 

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

Deprecated: Use PubsubSubscriptionType.Descriptor instead.

func (PubsubSubscriptionType) Number 

func (x PubsubSubscriptionType) Number() protoreflect.EnumNumber

func (PubsubSubscriptionType) String 

func (x PubsubSubscriptionType) String() string

func (PubsubSubscriptionType) Type 

func (PubsubSubscriptionType) Type() protoreflect.EnumType

type PurgeWorkflowRequest 

type PurgeWorkflowRequest struct {

	// ID of the workflow instance to purge.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

PurgeWorkflowRequest is the request for PurgeWorkflowBeta1.

func (*PurgeWorkflowRequest) AppendSpanAttributes 

func (*PurgeWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*PurgeWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use PurgeWorkflowRequest.ProtoReflect.Descriptor instead.

func (*PurgeWorkflowRequest) GetInstanceId 

func (x *PurgeWorkflowRequest) GetInstanceId() string

func (*PurgeWorkflowRequest) GetWorkflowComponent 

func (x *PurgeWorkflowRequest) GetWorkflowComponent() string

func (*PurgeWorkflowRequest) ProtoMessage 

func (*PurgeWorkflowRequest) ProtoMessage()

func (*PurgeWorkflowRequest) ProtoReflect 

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

func (*PurgeWorkflowRequest) Reset 

func (x *PurgeWorkflowRequest) Reset()

func (*PurgeWorkflowRequest) SetInstanceId 

func (x *PurgeWorkflowRequest) SetInstanceId(val string)

func (*PurgeWorkflowRequest) SetWorkflowComponent 

func (x *PurgeWorkflowRequest) SetWorkflowComponent(val string)

func (*PurgeWorkflowRequest) String 

func (x *PurgeWorkflowRequest) String() string

type QueryStateItem 

type QueryStateItem struct {

	// The object key.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The object value.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The entity tag which represents the specific version of data.
	// ETag format is defined by the corresponding data store.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// The error message indicating an error in processing of the query result.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryStateItem) Descriptor deprecated 

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

Deprecated: Use QueryStateItem.ProtoReflect.Descriptor instead.

func (*QueryStateItem) GetData 

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

func (*QueryStateItem) GetError 

func (x *QueryStateItem) GetError() string

func (*QueryStateItem) GetEtag 

func (x *QueryStateItem) GetEtag() string

func (*QueryStateItem) GetKey 

func (x *QueryStateItem) GetKey() string

func (*QueryStateItem) ProtoMessage 

func (*QueryStateItem) ProtoMessage()

func (*QueryStateItem) ProtoReflect 

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

func (*QueryStateItem) Reset 

func (x *QueryStateItem) Reset()

func (*QueryStateItem) String 

func (x *QueryStateItem) String() string

type QueryStateRequest 

type QueryStateRequest struct {

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

QueryStateRequest is the message to query state store.

func (*QueryStateRequest) AppendSpanAttributes 

func (*QueryStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*QueryStateRequest) Descriptor deprecated 

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

Deprecated: Use QueryStateRequest.ProtoReflect.Descriptor instead.

func (*QueryStateRequest) GetMetadata 

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

func (*QueryStateRequest) GetQuery 

func (x *QueryStateRequest) GetQuery() string

func (*QueryStateRequest) GetStoreName 

func (x *QueryStateRequest) GetStoreName() string

func (*QueryStateRequest) ProtoMessage 

func (*QueryStateRequest) ProtoMessage()

func (*QueryStateRequest) ProtoReflect 

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

func (*QueryStateRequest) Reset 

func (x *QueryStateRequest) Reset()

func (*QueryStateRequest) String 

func (x *QueryStateRequest) String() string

type QueryStateResponse 

type QueryStateResponse struct {

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

QueryStateResponse is the response conveying the query results.

func (*QueryStateResponse) Descriptor deprecated 

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

Deprecated: Use QueryStateResponse.ProtoReflect.Descriptor instead.

func (*QueryStateResponse) GetMetadata 

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

func (*QueryStateResponse) GetResults 

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

func (*QueryStateResponse) GetToken 

func (x *QueryStateResponse) GetToken() string

func (*QueryStateResponse) ProtoMessage 

func (*QueryStateResponse) ProtoMessage()

func (*QueryStateResponse) ProtoReflect 

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

func (*QueryStateResponse) Reset 

func (x *QueryStateResponse) Reset()

func (*QueryStateResponse) String 

func (x *QueryStateResponse) String() string

type RaiseEventWorkflowRequest 

type RaiseEventWorkflowRequest struct {

	// ID of the workflow instance to raise an event for.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// Name of the event.
	EventName string `protobuf:"bytes,3,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// Data associated with the event.
	EventData []byte `protobuf:"bytes,4,opt,name=event_data,json=eventData,proto3" json:"event_data,omitempty"`
	// contains filtered or unexported fields
}

RaiseEventWorkflowRequest is the request for RaiseEventWorkflowBeta1.

func (*RaiseEventWorkflowRequest) AppendSpanAttributes 

func (*RaiseEventWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*RaiseEventWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use RaiseEventWorkflowRequest.ProtoReflect.Descriptor instead.

func (*RaiseEventWorkflowRequest) GetEventData 

func (x *RaiseEventWorkflowRequest) GetEventData() []byte

func (*RaiseEventWorkflowRequest) GetEventName 

func (x *RaiseEventWorkflowRequest) GetEventName() string

func (*RaiseEventWorkflowRequest) GetInstanceId 

func (x *RaiseEventWorkflowRequest) GetInstanceId() string

func (*RaiseEventWorkflowRequest) GetWorkflowComponent 

func (x *RaiseEventWorkflowRequest) GetWorkflowComponent() string

func (*RaiseEventWorkflowRequest) ProtoMessage 

func (*RaiseEventWorkflowRequest) ProtoMessage()

func (*RaiseEventWorkflowRequest) ProtoReflect 

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

func (*RaiseEventWorkflowRequest) Reset 

func (x *RaiseEventWorkflowRequest) Reset()

func (*RaiseEventWorkflowRequest) String 

func (x *RaiseEventWorkflowRequest) String() string

type RegisterActorReminderRequest 

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

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

func (*RegisterActorReminderRequest) AppendSpanAttributes 

func (*RegisterActorReminderRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*RegisterActorReminderRequest) Descriptor deprecated 

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

Deprecated: Use RegisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorReminderRequest) GetActorId 

func (x *RegisterActorReminderRequest) GetActorId() string

func (*RegisterActorReminderRequest) GetActorType 

func (x *RegisterActorReminderRequest) GetActorType() string

func (*RegisterActorReminderRequest) GetData 

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

func (*RegisterActorReminderRequest) GetDueTime 

func (x *RegisterActorReminderRequest) GetDueTime() string

func (*RegisterActorReminderRequest) GetName 

func (x *RegisterActorReminderRequest) GetName() string

func (*RegisterActorReminderRequest) GetPeriod 

func (x *RegisterActorReminderRequest) GetPeriod() string

func (*RegisterActorReminderRequest) GetTtl 

func (x *RegisterActorReminderRequest) GetTtl() string

func (*RegisterActorReminderRequest) ProtoMessage 

func (*RegisterActorReminderRequest) ProtoMessage()

func (*RegisterActorReminderRequest) ProtoReflect 

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

func (*RegisterActorReminderRequest) Reset 

func (x *RegisterActorReminderRequest) Reset()

func (*RegisterActorReminderRequest) String 

func (x *RegisterActorReminderRequest) String() string

type RegisterActorTimerRequest 

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

func (*RegisterActorTimerRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*RegisterActorTimerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*RegisterActorTimerRequest) GetActorId 

func (x *RegisterActorTimerRequest) GetActorId() string

func (*RegisterActorTimerRequest) GetActorType 

func (x *RegisterActorTimerRequest) GetActorType() string

func (*RegisterActorTimerRequest) GetCallback 

func (x *RegisterActorTimerRequest) GetCallback() string

func (*RegisterActorTimerRequest) GetData 

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

func (*RegisterActorTimerRequest) GetDueTime 

func (x *RegisterActorTimerRequest) GetDueTime() string

func (*RegisterActorTimerRequest) GetName 

func (x *RegisterActorTimerRequest) GetName() string

func (*RegisterActorTimerRequest) GetPeriod 

func (x *RegisterActorTimerRequest) GetPeriod() string

func (*RegisterActorTimerRequest) GetTtl 

func (x *RegisterActorTimerRequest) GetTtl() string

func (*RegisterActorTimerRequest) ProtoMessage 

func (*RegisterActorTimerRequest) ProtoMessage()

func (*RegisterActorTimerRequest) ProtoReflect 

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

func (*RegisterActorTimerRequest) Reset 

func (x *RegisterActorTimerRequest) Reset()

func (*RegisterActorTimerRequest) String 

func (x *RegisterActorTimerRequest) String() string

type RegisteredComponents 

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

func (*RegisteredComponents) Descriptor deprecated 

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

Deprecated: Use RegisteredComponents.ProtoReflect.Descriptor instead.

func (*RegisteredComponents) GetCapabilities 

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

func (*RegisteredComponents) GetName 

func (x *RegisteredComponents) GetName() string

func (*RegisteredComponents) GetType 

func (x *RegisteredComponents) GetType() string

func (*RegisteredComponents) GetVersion 

func (x *RegisteredComponents) GetVersion() string

func (*RegisteredComponents) ProtoMessage 

func (*RegisteredComponents) ProtoMessage()

func (*RegisteredComponents) ProtoReflect 

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

func (*RegisteredComponents) Reset 

func (x *RegisteredComponents) Reset()

func (*RegisteredComponents) String 

func (x *RegisteredComponents) String() string

type ResumeWorkflowRequest 

type ResumeWorkflowRequest struct {

	// ID of the workflow instance to resume.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

ResumeWorkflowRequest is the request for ResumeWorkflowBeta1.

func (*ResumeWorkflowRequest) AppendSpanAttributes 

func (*ResumeWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*ResumeWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use ResumeWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ResumeWorkflowRequest) GetInstanceId 

func (x *ResumeWorkflowRequest) GetInstanceId() string

func (*ResumeWorkflowRequest) GetWorkflowComponent 

func (x *ResumeWorkflowRequest) GetWorkflowComponent() string

func (*ResumeWorkflowRequest) ProtoMessage 

func (*ResumeWorkflowRequest) ProtoMessage()

func (*ResumeWorkflowRequest) ProtoReflect 

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

func (*ResumeWorkflowRequest) Reset 

func (x *ResumeWorkflowRequest) Reset()

func (*ResumeWorkflowRequest) SetInstanceId 

func (x *ResumeWorkflowRequest) SetInstanceId(val string)

func (*ResumeWorkflowRequest) SetWorkflowComponent 

func (x *ResumeWorkflowRequest) SetWorkflowComponent(val string)

func (*ResumeWorkflowRequest) String 

func (x *ResumeWorkflowRequest) 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) AppendSpanAttributes 

func (x *SaveStateRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SaveStateRequest) Descriptor deprecated 

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

Deprecated: Use SaveStateRequest.ProtoReflect.Descriptor instead.

func (*SaveStateRequest) GetStates 

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

func (*SaveStateRequest) GetStoreName 

func (x *SaveStateRequest) GetStoreName() string

func (*SaveStateRequest) ProtoMessage 

func (*SaveStateRequest) ProtoMessage()

func (*SaveStateRequest) ProtoReflect 

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

func (*SaveStateRequest) Reset 

func (x *SaveStateRequest) Reset()

func (*SaveStateRequest) String 

func (x *SaveStateRequest) String() string

type ScheduleJobRequest 

type ScheduleJobRequest struct {

	// The job details.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

ScheduleJobRequest is the message to create/schedule the job.

func (*ScheduleJobRequest) AppendSpanAttributes 

func (*ScheduleJobRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*ScheduleJobRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleJobRequest.ProtoReflect.Descriptor instead.

func (*ScheduleJobRequest) GetJob 

func (x *ScheduleJobRequest) GetJob() *Job

func (*ScheduleJobRequest) ProtoMessage 

func (*ScheduleJobRequest) ProtoMessage()

func (*ScheduleJobRequest) ProtoReflect 

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

func (*ScheduleJobRequest) Reset 

func (x *ScheduleJobRequest) Reset()

func (*ScheduleJobRequest) String 

func (x *ScheduleJobRequest) String() string

type ScheduleJobResponse 

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

ScheduleJobResponse is the message response to create/schedule the job.

func (*ScheduleJobResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleJobResponse.ProtoReflect.Descriptor instead.

func (*ScheduleJobResponse) ProtoMessage 

func (*ScheduleJobResponse) ProtoMessage()

func (*ScheduleJobResponse) ProtoReflect 

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

func (*ScheduleJobResponse) Reset 

func (x *ScheduleJobResponse) Reset()

func (*ScheduleJobResponse) String 

func (x *ScheduleJobResponse) String() string

type SecretResponse 

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

SecretResponse is a map of decrypted string/string values

func (*SecretResponse) Descriptor deprecated 

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

Deprecated: Use SecretResponse.ProtoReflect.Descriptor instead.

func (*SecretResponse) GetSecrets 

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

func (*SecretResponse) ProtoMessage 

func (*SecretResponse) ProtoMessage()

func (*SecretResponse) ProtoReflect 

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

func (*SecretResponse) Reset 

func (x *SecretResponse) Reset()

func (*SecretResponse) String 

func (x *SecretResponse) String() string

type SetMetadataRequest 

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

func (*SetMetadataRequest) AppendSpanAttributes 

func (*SetMetadataRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SetMetadataRequest) Descriptor deprecated 

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

Deprecated: Use SetMetadataRequest.ProtoReflect.Descriptor instead.

func (*SetMetadataRequest) GetKey 

func (x *SetMetadataRequest) GetKey() string

func (*SetMetadataRequest) GetValue 

func (x *SetMetadataRequest) GetValue() string

func (*SetMetadataRequest) ProtoMessage 

func (*SetMetadataRequest) ProtoMessage()

func (*SetMetadataRequest) ProtoReflect 

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

func (*SetMetadataRequest) Reset 

func (x *SetMetadataRequest) Reset()

func (*SetMetadataRequest) String 

func (x *SetMetadataRequest) String() string

type ShutdownRequest 

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

ShutdownRequest is the request for Shutdown.

func (*ShutdownRequest) AppendSpanAttributes 

func (*ShutdownRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type StartWorkflowRequest 

type StartWorkflowRequest struct {

	// The ID to assign to the started workflow instance. If empty, a random ID is generated.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// Name of the workflow.
	WorkflowName string `protobuf:"bytes,3,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	// Additional component-specific options for starting the workflow instance.
	Options map[string]string `` /* 155-byte string literal not displayed */
	// Input data for the workflow instance.
	Input []byte `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

StartWorkflowRequest is the request for StartWorkflowBeta1.

func (*StartWorkflowRequest) AppendSpanAttributes 

func (*StartWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*StartWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowRequest) GetInput 

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

func (*StartWorkflowRequest) GetInstanceId 

func (x *StartWorkflowRequest) GetInstanceId() string

func (*StartWorkflowRequest) GetOptions 

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

func (*StartWorkflowRequest) GetWorkflowComponent 

func (x *StartWorkflowRequest) GetWorkflowComponent() string

func (*StartWorkflowRequest) GetWorkflowName 

func (x *StartWorkflowRequest) GetWorkflowName() string

func (*StartWorkflowRequest) ProtoMessage 

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) ProtoReflect 

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

func (*StartWorkflowRequest) Reset 

func (x *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) String 

func (x *StartWorkflowRequest) String() string

type StartWorkflowResponse 

type StartWorkflowResponse struct {

	// ID of the started workflow instance.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

StartWorkflowResponse is the response for StartWorkflowBeta1.

func (*StartWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use StartWorkflowResponse.ProtoReflect.Descriptor instead.

func (*StartWorkflowResponse) GetInstanceId 

func (x *StartWorkflowResponse) GetInstanceId() string

func (*StartWorkflowResponse) ProtoMessage 

func (*StartWorkflowResponse) ProtoMessage()

func (*StartWorkflowResponse) ProtoReflect 

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

func (*StartWorkflowResponse) Reset 

func (x *StartWorkflowResponse) Reset()

func (*StartWorkflowResponse) String 

func (x *StartWorkflowResponse) String() string

type SubscribeConfigurationRequest 

type SubscribeConfigurationRequest struct {

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

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

func (*SubscribeConfigurationRequest) AppendSpanAttributes 

func (*SubscribeConfigurationRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubscribeConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationRequest) GetKeys 

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

func (*SubscribeConfigurationRequest) GetMetadata 

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

func (*SubscribeConfigurationRequest) GetStoreName 

func (x *SubscribeConfigurationRequest) GetStoreName() string

func (*SubscribeConfigurationRequest) ProtoMessage 

func (*SubscribeConfigurationRequest) ProtoMessage()

func (*SubscribeConfigurationRequest) ProtoReflect 

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

func (*SubscribeConfigurationRequest) Reset 

func (x *SubscribeConfigurationRequest) Reset()

func (*SubscribeConfigurationRequest) String 

func (x *SubscribeConfigurationRequest) String() string

type SubscribeConfigurationResponse 

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 

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

Deprecated: Use SubscribeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationResponse) GetId 

func (x *SubscribeConfigurationResponse) GetId() string

func (*SubscribeConfigurationResponse) GetItems 

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

func (*SubscribeConfigurationResponse) ProtoMessage 

func (*SubscribeConfigurationResponse) ProtoMessage()

func (*SubscribeConfigurationResponse) ProtoReflect 

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

func (*SubscribeConfigurationResponse) Reset 

func (x *SubscribeConfigurationResponse) Reset()

func (*SubscribeConfigurationResponse) String 

func (x *SubscribeConfigurationResponse) String() string

type SubscribeTopicEventsRequestAlpha1 

type SubscribeTopicEventsRequestAlpha1 struct {

	// Types that are assignable to SubscribeTopicEventsRequestType:
	//
	//	*SubscribeTopicEventsRequestAlpha1_InitialRequest
	//	*SubscribeTopicEventsRequestAlpha1_EventProcessed
	SubscribeTopicEventsRequestType isSubscribeTopicEventsRequestAlpha1_SubscribeTopicEventsRequestType `protobuf_oneof:"subscribe_topic_events_request_type"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsRequestAlpha1 is a message containing the details for subscribing to a topic via streaming. The first message must always be the initial request. All subsequent messages must be event processed responses.

func (*SubscribeTopicEventsRequestAlpha1) AppendSpanAttributes 

func (*SubscribeTopicEventsRequestAlpha1) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubscribeTopicEventsRequestAlpha1) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsRequestAlpha1.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsRequestAlpha1) GetEventProcessed 

func (x *SubscribeTopicEventsRequestAlpha1) GetEventProcessed() *SubscribeTopicEventsRequestProcessedAlpha1

func (*SubscribeTopicEventsRequestAlpha1) GetInitialRequest 

func (x *SubscribeTopicEventsRequestAlpha1) GetInitialRequest() *SubscribeTopicEventsRequestInitialAlpha1

func (*SubscribeTopicEventsRequestAlpha1) GetSubscribeTopicEventsRequestType 

func (m *SubscribeTopicEventsRequestAlpha1) GetSubscribeTopicEventsRequestType() isSubscribeTopicEventsRequestAlpha1_SubscribeTopicEventsRequestType

func (*SubscribeTopicEventsRequestAlpha1) ProtoMessage 

func (*SubscribeTopicEventsRequestAlpha1) ProtoMessage()

func (*SubscribeTopicEventsRequestAlpha1) ProtoReflect 

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

func (*SubscribeTopicEventsRequestAlpha1) Reset 

func (x *SubscribeTopicEventsRequestAlpha1) Reset()

func (*SubscribeTopicEventsRequestAlpha1) String 

func (x *SubscribeTopicEventsRequestAlpha1) String() string

type SubscribeTopicEventsRequestAlpha1_EventProcessed 

type SubscribeTopicEventsRequestAlpha1_EventProcessed struct {
	EventProcessed *SubscribeTopicEventsRequestProcessedAlpha1 `protobuf:"bytes,2,opt,name=event_processed,json=eventProcessed,proto3,oneof"`
}

type SubscribeTopicEventsRequestAlpha1_InitialRequest 

type SubscribeTopicEventsRequestAlpha1_InitialRequest struct {
	InitialRequest *SubscribeTopicEventsRequestInitialAlpha1 `protobuf:"bytes,1,opt,name=initial_request,json=initialRequest,proto3,oneof"`
}

func (*SubscribeTopicEventsRequestAlpha1_InitialRequest) AppendSpanAttributes 

func (*SubscribeTopicEventsRequestAlpha1_InitialRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

type SubscribeTopicEventsRequestInitialAlpha1 

type SubscribeTopicEventsRequestInitialAlpha1 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 metadata passing to pub components
	//
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// dead_letter_topic is the topic to which messages that fail to be processed
	// are sent.
	DeadLetterTopic *string `protobuf:"bytes,4,opt,name=dead_letter_topic,json=deadLetterTopic,proto3,oneof" json:"dead_letter_topic,omitempty"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsRequestInitialAlpha1 is the initial message containing the details for subscribing to a topic via streaming.

func (*SubscribeTopicEventsRequestInitialAlpha1) AppendSpanAttributes 

func (*SubscribeTopicEventsRequestInitialAlpha1) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubscribeTopicEventsRequestInitialAlpha1) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsRequestInitialAlpha1.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsRequestInitialAlpha1) GetDeadLetterTopic 

func (x *SubscribeTopicEventsRequestInitialAlpha1) GetDeadLetterTopic() string

func (*SubscribeTopicEventsRequestInitialAlpha1) GetMetadata 

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

func (*SubscribeTopicEventsRequestInitialAlpha1) GetPubsubName 

func (x *SubscribeTopicEventsRequestInitialAlpha1) GetPubsubName() string

func (*SubscribeTopicEventsRequestInitialAlpha1) GetTopic 

func (x *SubscribeTopicEventsRequestInitialAlpha1) GetTopic() string

func (*SubscribeTopicEventsRequestInitialAlpha1) ProtoMessage 

func (*SubscribeTopicEventsRequestInitialAlpha1) ProtoMessage()

func (*SubscribeTopicEventsRequestInitialAlpha1) ProtoReflect 

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

func (*SubscribeTopicEventsRequestInitialAlpha1) Reset 

func (x *SubscribeTopicEventsRequestInitialAlpha1) Reset()

func (*SubscribeTopicEventsRequestInitialAlpha1) String 

func (x *SubscribeTopicEventsRequestInitialAlpha1) String() string

type SubscribeTopicEventsRequestProcessedAlpha1 

type SubscribeTopicEventsRequestProcessedAlpha1 struct {

	// id is the unique identifier for the subscription request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// status is the result of the subscription request.
	Status *TopicEventResponse `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsRequestProcessedAlpha1 is the message containing the subscription to a topic.

func (*SubscribeTopicEventsRequestProcessedAlpha1) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsRequestProcessedAlpha1.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsRequestProcessedAlpha1) GetId 

func (x *SubscribeTopicEventsRequestProcessedAlpha1) GetId() string

func (*SubscribeTopicEventsRequestProcessedAlpha1) GetStatus 

func (x *SubscribeTopicEventsRequestProcessedAlpha1) GetStatus() *TopicEventResponse

func (*SubscribeTopicEventsRequestProcessedAlpha1) ProtoMessage 

func (*SubscribeTopicEventsRequestProcessedAlpha1) ProtoMessage()

func (*SubscribeTopicEventsRequestProcessedAlpha1) ProtoReflect 

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

func (*SubscribeTopicEventsRequestProcessedAlpha1) Reset 

func (x *SubscribeTopicEventsRequestProcessedAlpha1) Reset()

func (*SubscribeTopicEventsRequestProcessedAlpha1) String 

func (x *SubscribeTopicEventsRequestProcessedAlpha1) String() string

type SubscribeTopicEventsResponseAlpha1 

type SubscribeTopicEventsResponseAlpha1 struct {

	// Types that are assignable to SubscribeTopicEventsResponseType:
	//
	//	*SubscribeTopicEventsResponseAlpha1_InitialResponse
	//	*SubscribeTopicEventsResponseAlpha1_EventMessage
	SubscribeTopicEventsResponseType isSubscribeTopicEventsResponseAlpha1_SubscribeTopicEventsResponseType `protobuf_oneof:"subscribe_topic_events_response_type"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsResponseAlpha1 is a message returned from daprd when subscribing to a topic via streaming.

func (*SubscribeTopicEventsResponseAlpha1) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsResponseAlpha1.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsResponseAlpha1) GetEventMessage 

func (x *SubscribeTopicEventsResponseAlpha1) GetEventMessage() *TopicEventRequest

func (*SubscribeTopicEventsResponseAlpha1) GetInitialResponse 

func (x *SubscribeTopicEventsResponseAlpha1) GetInitialResponse() *SubscribeTopicEventsResponseInitialAlpha1

func (*SubscribeTopicEventsResponseAlpha1) GetSubscribeTopicEventsResponseType 

func (m *SubscribeTopicEventsResponseAlpha1) GetSubscribeTopicEventsResponseType() isSubscribeTopicEventsResponseAlpha1_SubscribeTopicEventsResponseType

func (*SubscribeTopicEventsResponseAlpha1) ProtoMessage 

func (*SubscribeTopicEventsResponseAlpha1) ProtoMessage()

func (*SubscribeTopicEventsResponseAlpha1) ProtoReflect 

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

func (*SubscribeTopicEventsResponseAlpha1) Reset 

func (x *SubscribeTopicEventsResponseAlpha1) Reset()

func (*SubscribeTopicEventsResponseAlpha1) String 

func (x *SubscribeTopicEventsResponseAlpha1) String() string

type SubscribeTopicEventsResponseAlpha1_EventMessage 

type SubscribeTopicEventsResponseAlpha1_EventMessage struct {
	EventMessage *TopicEventRequest `protobuf:"bytes,2,opt,name=event_message,json=eventMessage,proto3,oneof"`
}

type SubscribeTopicEventsResponseAlpha1_InitialResponse 

type SubscribeTopicEventsResponseAlpha1_InitialResponse struct {
	InitialResponse *SubscribeTopicEventsResponseInitialAlpha1 `protobuf:"bytes,1,opt,name=initial_response,json=initialResponse,proto3,oneof"`
}

type SubscribeTopicEventsResponseInitialAlpha1 

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

SubscribeTopicEventsResponseInitialAlpha1 is the initial response from daprd when subscribing to a topic.

func (*SubscribeTopicEventsResponseInitialAlpha1) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsResponseInitialAlpha1.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsResponseInitialAlpha1) ProtoMessage 

func (*SubscribeTopicEventsResponseInitialAlpha1) ProtoMessage()

func (*SubscribeTopicEventsResponseInitialAlpha1) ProtoReflect 

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

func (*SubscribeTopicEventsResponseInitialAlpha1) Reset 

func (x *SubscribeTopicEventsResponseInitialAlpha1) Reset()

func (*SubscribeTopicEventsResponseInitialAlpha1) String 

func (x *SubscribeTopicEventsResponseInitialAlpha1) String() string

type SubtleCryptoRequests 

type SubtleCryptoRequests interface {
	// SetComponentName sets the value of the ComponentName property.
	SetComponentName(name string)
}

SubtleCryptoRequests is an interface for all Subtle*Request structs.

type SubtleDecryptRequest 

type SubtleDecryptRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Message to decrypt.
	Ciphertext []byte `protobuf:"bytes,2,opt,name=ciphertext,proto3" json:"ciphertext,omitempty"`
	// Algorithm to use, as in the JWA standard.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Name (or name/version) of the key.
	KeyName string `protobuf:"bytes,4,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// Nonce / initialization vector.
	// Ignored with asymmetric ciphers.
	Nonce []byte `protobuf:"bytes,5,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Authentication tag.
	// This is nil when not using an authenticated cipher.
	Tag []byte `protobuf:"bytes,6,opt,name=tag,proto3" json:"tag,omitempty"`
	// Associated Data when using AEAD ciphers (optional).
	AssociatedData []byte `protobuf:"bytes,7,opt,name=associated_data,json=associatedData,proto3" json:"associated_data,omitempty"`
	// contains filtered or unexported fields
}

SubtleDecryptRequest is the request for SubtleDecryptAlpha1.

func (*SubtleDecryptRequest) AppendSpanAttributes 

func (*SubtleDecryptRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleDecryptRequest) Descriptor deprecated 

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

Deprecated: Use SubtleDecryptRequest.ProtoReflect.Descriptor instead.

func (*SubtleDecryptRequest) GetAlgorithm 

func (x *SubtleDecryptRequest) GetAlgorithm() string

func (*SubtleDecryptRequest) GetAssociatedData 

func (x *SubtleDecryptRequest) GetAssociatedData() []byte

func (*SubtleDecryptRequest) GetCiphertext 

func (x *SubtleDecryptRequest) GetCiphertext() []byte

func (*SubtleDecryptRequest) GetComponentName 

func (x *SubtleDecryptRequest) GetComponentName() string

func (*SubtleDecryptRequest) GetKeyName 

func (x *SubtleDecryptRequest) GetKeyName() string

func (*SubtleDecryptRequest) GetNonce 

func (x *SubtleDecryptRequest) GetNonce() []byte

func (*SubtleDecryptRequest) GetTag 

func (x *SubtleDecryptRequest) GetTag() []byte

func (*SubtleDecryptRequest) ProtoMessage 

func (*SubtleDecryptRequest) ProtoMessage()

func (*SubtleDecryptRequest) ProtoReflect 

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

func (*SubtleDecryptRequest) Reset 

func (x *SubtleDecryptRequest) Reset()

func (*SubtleDecryptRequest) SetComponentName 

func (x *SubtleDecryptRequest) SetComponentName(name string)

func (*SubtleDecryptRequest) String 

func (x *SubtleDecryptRequest) String() string

type SubtleDecryptResponse 

type SubtleDecryptResponse struct {

	// Decrypted plaintext.
	Plaintext []byte `protobuf:"bytes,1,opt,name=plaintext,proto3" json:"plaintext,omitempty"`
	// contains filtered or unexported fields
}

SubtleDecryptResponse is the response for SubtleDecryptAlpha1.

func (*SubtleDecryptResponse) Descriptor deprecated 

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

Deprecated: Use SubtleDecryptResponse.ProtoReflect.Descriptor instead.

func (*SubtleDecryptResponse) GetPlaintext 

func (x *SubtleDecryptResponse) GetPlaintext() []byte

func (*SubtleDecryptResponse) ProtoMessage 

func (*SubtleDecryptResponse) ProtoMessage()

func (*SubtleDecryptResponse) ProtoReflect 

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

func (*SubtleDecryptResponse) Reset 

func (x *SubtleDecryptResponse) Reset()

func (*SubtleDecryptResponse) String 

func (x *SubtleDecryptResponse) String() string

type SubtleEncryptRequest 

type SubtleEncryptRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Message to encrypt.
	Plaintext []byte `protobuf:"bytes,2,opt,name=plaintext,proto3" json:"plaintext,omitempty"`
	// Algorithm to use, as in the JWA standard.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Name (or name/version) of the key.
	KeyName string `protobuf:"bytes,4,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// Nonce / initialization vector.
	// Ignored with asymmetric ciphers.
	Nonce []byte `protobuf:"bytes,5,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Associated Data when using AEAD ciphers (optional).
	AssociatedData []byte `protobuf:"bytes,6,opt,name=associated_data,json=associatedData,proto3" json:"associated_data,omitempty"`
	// contains filtered or unexported fields
}

SubtleEncryptRequest is the request for SubtleEncryptAlpha1.

func (*SubtleEncryptRequest) AppendSpanAttributes 

func (*SubtleEncryptRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleEncryptRequest) Descriptor deprecated 

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

Deprecated: Use SubtleEncryptRequest.ProtoReflect.Descriptor instead.

func (*SubtleEncryptRequest) GetAlgorithm 

func (x *SubtleEncryptRequest) GetAlgorithm() string

func (*SubtleEncryptRequest) GetAssociatedData 

func (x *SubtleEncryptRequest) GetAssociatedData() []byte

func (*SubtleEncryptRequest) GetComponentName 

func (x *SubtleEncryptRequest) GetComponentName() string

func (*SubtleEncryptRequest) GetKeyName 

func (x *SubtleEncryptRequest) GetKeyName() string

func (*SubtleEncryptRequest) GetNonce 

func (x *SubtleEncryptRequest) GetNonce() []byte

func (*SubtleEncryptRequest) GetPlaintext 

func (x *SubtleEncryptRequest) GetPlaintext() []byte

func (*SubtleEncryptRequest) ProtoMessage 

func (*SubtleEncryptRequest) ProtoMessage()

func (*SubtleEncryptRequest) ProtoReflect 

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

func (*SubtleEncryptRequest) Reset 

func (x *SubtleEncryptRequest) Reset()

func (*SubtleEncryptRequest) SetComponentName 

func (x *SubtleEncryptRequest) SetComponentName(name string)

func (*SubtleEncryptRequest) String 

func (x *SubtleEncryptRequest) String() string

type SubtleEncryptResponse 

type SubtleEncryptResponse struct {

	// Encrypted ciphertext.
	Ciphertext []byte `protobuf:"bytes,1,opt,name=ciphertext,proto3" json:"ciphertext,omitempty"`
	// Authentication tag.
	// This is nil when not using an authenticated cipher.
	Tag []byte `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

SubtleEncryptResponse is the response for SubtleEncryptAlpha1.

func (*SubtleEncryptResponse) Descriptor deprecated 

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

Deprecated: Use SubtleEncryptResponse.ProtoReflect.Descriptor instead.

func (*SubtleEncryptResponse) GetCiphertext 

func (x *SubtleEncryptResponse) GetCiphertext() []byte

func (*SubtleEncryptResponse) GetTag 

func (x *SubtleEncryptResponse) GetTag() []byte

func (*SubtleEncryptResponse) ProtoMessage 

func (*SubtleEncryptResponse) ProtoMessage()

func (*SubtleEncryptResponse) ProtoReflect 

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

func (*SubtleEncryptResponse) Reset 

func (x *SubtleEncryptResponse) Reset()

func (*SubtleEncryptResponse) String 

func (x *SubtleEncryptResponse) String() string

type SubtleGetKeyRequest 

type SubtleGetKeyRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Name (or name/version) of the key to use in the key vault
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Response format
	Format SubtleGetKeyRequest_KeyFormat `protobuf:"varint,3,opt,name=format,proto3,enum=dapr.proto.runtime.v1.SubtleGetKeyRequest_KeyFormat" json:"format,omitempty"`
	// contains filtered or unexported fields
}

SubtleGetKeyRequest is the request object for SubtleGetKeyAlpha1.

func (*SubtleGetKeyRequest) AppendSpanAttributes 

func (*SubtleGetKeyRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleGetKeyRequest) Descriptor deprecated 

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

Deprecated: Use SubtleGetKeyRequest.ProtoReflect.Descriptor instead.

func (*SubtleGetKeyRequest) GetComponentName 

func (x *SubtleGetKeyRequest) GetComponentName() string

func (*SubtleGetKeyRequest) GetFormat 

func (x *SubtleGetKeyRequest) GetFormat() SubtleGetKeyRequest_KeyFormat

func (*SubtleGetKeyRequest) GetName 

func (x *SubtleGetKeyRequest) GetName() string

func (*SubtleGetKeyRequest) ProtoMessage 

func (*SubtleGetKeyRequest) ProtoMessage()

func (*SubtleGetKeyRequest) ProtoReflect 

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

func (*SubtleGetKeyRequest) Reset 

func (x *SubtleGetKeyRequest) Reset()

func (*SubtleGetKeyRequest) SetComponentName 

func (x *SubtleGetKeyRequest) SetComponentName(name string)

func (*SubtleGetKeyRequest) String 

func (x *SubtleGetKeyRequest) String() string

type SubtleGetKeyRequest_KeyFormat 

type SubtleGetKeyRequest_KeyFormat int32
const (
	// PEM (PKIX) (default)
	SubtleGetKeyRequest_PEM SubtleGetKeyRequest_KeyFormat = 0
	// JSON (JSON Web Key) as string
	SubtleGetKeyRequest_JSON SubtleGetKeyRequest_KeyFormat = 1
)

func (SubtleGetKeyRequest_KeyFormat) Descriptor 

func (SubtleGetKeyRequest_KeyFormat) Descriptor() protoreflect.EnumDescriptor

func (SubtleGetKeyRequest_KeyFormat) Enum 

func (x SubtleGetKeyRequest_KeyFormat) Enum() *SubtleGetKeyRequest_KeyFormat

func (SubtleGetKeyRequest_KeyFormat) EnumDescriptor deprecated 

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

Deprecated: Use SubtleGetKeyRequest_KeyFormat.Descriptor instead.

func (SubtleGetKeyRequest_KeyFormat) Number 

func (x SubtleGetKeyRequest_KeyFormat) Number() protoreflect.EnumNumber

func (SubtleGetKeyRequest_KeyFormat) String 

func (x SubtleGetKeyRequest_KeyFormat) String() string

func (SubtleGetKeyRequest_KeyFormat) Type 

func (SubtleGetKeyRequest_KeyFormat) Type() protoreflect.EnumType

type SubtleGetKeyResponse 

type SubtleGetKeyResponse struct {

	// Name (or name/version) of the key.
	// This is returned as response too in case there is a version.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Public key, encoded in the requested format
	PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

SubtleGetKeyResponse is the response for SubtleGetKeyAlpha1.

func (*SubtleGetKeyResponse) Descriptor deprecated 

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

Deprecated: Use SubtleGetKeyResponse.ProtoReflect.Descriptor instead.

func (*SubtleGetKeyResponse) GetName 

func (x *SubtleGetKeyResponse) GetName() string

func (*SubtleGetKeyResponse) GetPublicKey 

func (x *SubtleGetKeyResponse) GetPublicKey() string

func (*SubtleGetKeyResponse) ProtoMessage 

func (*SubtleGetKeyResponse) ProtoMessage()

func (*SubtleGetKeyResponse) ProtoReflect 

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

func (*SubtleGetKeyResponse) Reset 

func (x *SubtleGetKeyResponse) Reset()

func (*SubtleGetKeyResponse) String 

func (x *SubtleGetKeyResponse) String() string

type SubtleSignRequest 

type SubtleSignRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Digest to sign.
	Digest []byte `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	// Algorithm to use, as in the JWA standard.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Name (or name/version) of the key.
	KeyName string `protobuf:"bytes,4,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// contains filtered or unexported fields
}

SubtleSignRequest is the request for SubtleSignAlpha1.

func (*SubtleSignRequest) AppendSpanAttributes 

func (*SubtleSignRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleSignRequest) Descriptor deprecated 

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

Deprecated: Use SubtleSignRequest.ProtoReflect.Descriptor instead.

func (*SubtleSignRequest) GetAlgorithm 

func (x *SubtleSignRequest) GetAlgorithm() string

func (*SubtleSignRequest) GetComponentName 

func (x *SubtleSignRequest) GetComponentName() string

func (*SubtleSignRequest) GetDigest 

func (x *SubtleSignRequest) GetDigest() []byte

func (*SubtleSignRequest) GetKeyName 

func (x *SubtleSignRequest) GetKeyName() string

func (*SubtleSignRequest) ProtoMessage 

func (*SubtleSignRequest) ProtoMessage()

func (*SubtleSignRequest) ProtoReflect 

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

func (*SubtleSignRequest) Reset 

func (x *SubtleSignRequest) Reset()

func (*SubtleSignRequest) SetComponentName 

func (x *SubtleSignRequest) SetComponentName(name string)

func (*SubtleSignRequest) String 

func (x *SubtleSignRequest) String() string

type SubtleSignResponse 

type SubtleSignResponse struct {

	// The signature that was computed
	Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

SubtleSignResponse is the response for SubtleSignAlpha1.

func (*SubtleSignResponse) Descriptor deprecated 

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

Deprecated: Use SubtleSignResponse.ProtoReflect.Descriptor instead.

func (*SubtleSignResponse) GetSignature 

func (x *SubtleSignResponse) GetSignature() []byte

func (*SubtleSignResponse) ProtoMessage 

func (*SubtleSignResponse) ProtoMessage()

func (*SubtleSignResponse) ProtoReflect 

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

func (*SubtleSignResponse) Reset 

func (x *SubtleSignResponse) Reset()

func (*SubtleSignResponse) String 

func (x *SubtleSignResponse) String() string

type SubtleUnwrapKeyRequest 

type SubtleUnwrapKeyRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Wrapped key.
	WrappedKey []byte `protobuf:"bytes,2,opt,name=wrapped_key,json=wrappedKey,proto3" json:"wrapped_key,omitempty"`
	// Algorithm to use, as in the JWA standard.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Name (or name/version) of the key.
	KeyName string `protobuf:"bytes,4,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// Nonce / initialization vector.
	// Ignored with asymmetric ciphers.
	Nonce []byte `protobuf:"bytes,5,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Authentication tag.
	// This is nil when not using an authenticated cipher.
	Tag []byte `protobuf:"bytes,6,opt,name=tag,proto3" json:"tag,omitempty"`
	// Associated Data when using AEAD ciphers (optional).
	AssociatedData []byte `protobuf:"bytes,7,opt,name=associated_data,json=associatedData,proto3" json:"associated_data,omitempty"`
	// contains filtered or unexported fields
}

SubtleUnwrapKeyRequest is the request for SubtleUnwrapKeyAlpha1.

func (*SubtleUnwrapKeyRequest) AppendSpanAttributes 

func (*SubtleUnwrapKeyRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleUnwrapKeyRequest) Descriptor deprecated 

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

Deprecated: Use SubtleUnwrapKeyRequest.ProtoReflect.Descriptor instead.

func (*SubtleUnwrapKeyRequest) GetAlgorithm 

func (x *SubtleUnwrapKeyRequest) GetAlgorithm() string

func (*SubtleUnwrapKeyRequest) GetAssociatedData 

func (x *SubtleUnwrapKeyRequest) GetAssociatedData() []byte

func (*SubtleUnwrapKeyRequest) GetComponentName 

func (x *SubtleUnwrapKeyRequest) GetComponentName() string

func (*SubtleUnwrapKeyRequest) GetKeyName 

func (x *SubtleUnwrapKeyRequest) GetKeyName() string

func (*SubtleUnwrapKeyRequest) GetNonce 

func (x *SubtleUnwrapKeyRequest) GetNonce() []byte

func (*SubtleUnwrapKeyRequest) GetTag 

func (x *SubtleUnwrapKeyRequest) GetTag() []byte

func (*SubtleUnwrapKeyRequest) GetWrappedKey 

func (x *SubtleUnwrapKeyRequest) GetWrappedKey() []byte

func (*SubtleUnwrapKeyRequest) ProtoMessage 

func (*SubtleUnwrapKeyRequest) ProtoMessage()

func (*SubtleUnwrapKeyRequest) ProtoReflect 

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

func (*SubtleUnwrapKeyRequest) Reset 

func (x *SubtleUnwrapKeyRequest) Reset()

func (*SubtleUnwrapKeyRequest) SetComponentName 

func (x *SubtleUnwrapKeyRequest) SetComponentName(name string)

func (*SubtleUnwrapKeyRequest) String 

func (x *SubtleUnwrapKeyRequest) String() string

type SubtleUnwrapKeyResponse 

type SubtleUnwrapKeyResponse struct {

	// Key in plaintext
	PlaintextKey []byte `protobuf:"bytes,1,opt,name=plaintext_key,json=plaintextKey,proto3" json:"plaintext_key,omitempty"`
	// contains filtered or unexported fields
}

SubtleUnwrapKeyResponse is the response for SubtleUnwrapKeyAlpha1.

func (*SubtleUnwrapKeyResponse) Descriptor deprecated 

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

Deprecated: Use SubtleUnwrapKeyResponse.ProtoReflect.Descriptor instead.

func (*SubtleUnwrapKeyResponse) GetPlaintextKey 

func (x *SubtleUnwrapKeyResponse) GetPlaintextKey() []byte

func (*SubtleUnwrapKeyResponse) ProtoMessage 

func (*SubtleUnwrapKeyResponse) ProtoMessage()

func (*SubtleUnwrapKeyResponse) ProtoReflect 

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

func (*SubtleUnwrapKeyResponse) Reset 

func (x *SubtleUnwrapKeyResponse) Reset()

func (*SubtleUnwrapKeyResponse) String 

func (x *SubtleUnwrapKeyResponse) String() string

type SubtleVerifyRequest 

type SubtleVerifyRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Digest of the message.
	Digest []byte `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	// Algorithm to use, as in the JWA standard.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Name (or name/version) of the key.
	KeyName string `protobuf:"bytes,4,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// Signature to verify.
	Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

SubtleVerifyRequest is the request for SubtleVerifyAlpha1.

func (*SubtleVerifyRequest) AppendSpanAttributes 

func (*SubtleVerifyRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleVerifyRequest) Descriptor deprecated 

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

Deprecated: Use SubtleVerifyRequest.ProtoReflect.Descriptor instead.

func (*SubtleVerifyRequest) GetAlgorithm 

func (x *SubtleVerifyRequest) GetAlgorithm() string

func (*SubtleVerifyRequest) GetComponentName 

func (x *SubtleVerifyRequest) GetComponentName() string

func (*SubtleVerifyRequest) GetDigest 

func (x *SubtleVerifyRequest) GetDigest() []byte

func (*SubtleVerifyRequest) GetKeyName 

func (x *SubtleVerifyRequest) GetKeyName() string

func (*SubtleVerifyRequest) GetSignature 

func (x *SubtleVerifyRequest) GetSignature() []byte

func (*SubtleVerifyRequest) ProtoMessage 

func (*SubtleVerifyRequest) ProtoMessage()

func (*SubtleVerifyRequest) ProtoReflect 

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

func (*SubtleVerifyRequest) Reset 

func (x *SubtleVerifyRequest) Reset()

func (*SubtleVerifyRequest) SetComponentName 

func (x *SubtleVerifyRequest) SetComponentName(name string)

func (*SubtleVerifyRequest) String 

func (x *SubtleVerifyRequest) String() string

type SubtleVerifyResponse 

type SubtleVerifyResponse struct {

	// True if the signature is valid.
	Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

SubtleVerifyResponse is the response for SubtleVerifyAlpha1.

func (*SubtleVerifyResponse) Descriptor deprecated 

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

Deprecated: Use SubtleVerifyResponse.ProtoReflect.Descriptor instead.

func (*SubtleVerifyResponse) GetValid 

func (x *SubtleVerifyResponse) GetValid() bool

func (*SubtleVerifyResponse) ProtoMessage 

func (*SubtleVerifyResponse) ProtoMessage()

func (*SubtleVerifyResponse) ProtoReflect 

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

func (*SubtleVerifyResponse) Reset 

func (x *SubtleVerifyResponse) Reset()

func (*SubtleVerifyResponse) String 

func (x *SubtleVerifyResponse) String() string

type SubtleWrapKeyRequest 

type SubtleWrapKeyRequest struct {

	// Name of the component
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Key to wrap
	PlaintextKey []byte `protobuf:"bytes,2,opt,name=plaintext_key,json=plaintextKey,proto3" json:"plaintext_key,omitempty"`
	// Algorithm to use, as in the JWA standard.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Name (or name/version) of the key.
	KeyName string `protobuf:"bytes,4,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// Nonce / initialization vector.
	// Ignored with asymmetric ciphers.
	Nonce []byte `protobuf:"bytes,5,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Associated Data when using AEAD ciphers (optional).
	AssociatedData []byte `protobuf:"bytes,6,opt,name=associated_data,json=associatedData,proto3" json:"associated_data,omitempty"`
	// contains filtered or unexported fields
}

SubtleWrapKeyRequest is the request for SubtleWrapKeyAlpha1.

func (*SubtleWrapKeyRequest) AppendSpanAttributes 

func (*SubtleWrapKeyRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*SubtleWrapKeyRequest) Descriptor deprecated 

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

Deprecated: Use SubtleWrapKeyRequest.ProtoReflect.Descriptor instead.

func (*SubtleWrapKeyRequest) GetAlgorithm 

func (x *SubtleWrapKeyRequest) GetAlgorithm() string

func (*SubtleWrapKeyRequest) GetAssociatedData 

func (x *SubtleWrapKeyRequest) GetAssociatedData() []byte

func (*SubtleWrapKeyRequest) GetComponentName 

func (x *SubtleWrapKeyRequest) GetComponentName() string

func (*SubtleWrapKeyRequest) GetKeyName 

func (x *SubtleWrapKeyRequest) GetKeyName() string

func (*SubtleWrapKeyRequest) GetNonce 

func (x *SubtleWrapKeyRequest) GetNonce() []byte

func (*SubtleWrapKeyRequest) GetPlaintextKey 

func (x *SubtleWrapKeyRequest) GetPlaintextKey() []byte

func (*SubtleWrapKeyRequest) ProtoMessage 

func (*SubtleWrapKeyRequest) ProtoMessage()

func (*SubtleWrapKeyRequest) ProtoReflect 

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

func (*SubtleWrapKeyRequest) Reset 

func (x *SubtleWrapKeyRequest) Reset()

func (*SubtleWrapKeyRequest) SetComponentName 

func (x *SubtleWrapKeyRequest) SetComponentName(name string)

func (*SubtleWrapKeyRequest) String 

func (x *SubtleWrapKeyRequest) String() string

type SubtleWrapKeyResponse 

type SubtleWrapKeyResponse struct {

	// Wrapped key.
	WrappedKey []byte `protobuf:"bytes,1,opt,name=wrapped_key,json=wrappedKey,proto3" json:"wrapped_key,omitempty"`
	// Authentication tag.
	// This is nil when not using an authenticated cipher.
	Tag []byte `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

SubtleWrapKeyResponse is the response for SubtleWrapKeyAlpha1.

func (*SubtleWrapKeyResponse) Descriptor deprecated 

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

Deprecated: Use SubtleWrapKeyResponse.ProtoReflect.Descriptor instead.

func (*SubtleWrapKeyResponse) GetTag 

func (x *SubtleWrapKeyResponse) GetTag() []byte

func (*SubtleWrapKeyResponse) GetWrappedKey 

func (x *SubtleWrapKeyResponse) GetWrappedKey() []byte

func (*SubtleWrapKeyResponse) ProtoMessage 

func (*SubtleWrapKeyResponse) ProtoMessage()

func (*SubtleWrapKeyResponse) ProtoReflect 

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

func (*SubtleWrapKeyResponse) Reset 

func (x *SubtleWrapKeyResponse) Reset()

func (*SubtleWrapKeyResponse) String 

func (x *SubtleWrapKeyResponse) String() string

type TerminateWorkflowRequest 

type TerminateWorkflowRequest struct {

	// ID of the workflow instance to terminate.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceID,proto3" json:"instance_id,omitempty"`
	// Name of the workflow component.
	WorkflowComponent string `protobuf:"bytes,2,opt,name=workflow_component,json=workflowComponent,proto3" json:"workflow_component,omitempty"`
	// contains filtered or unexported fields
}

TerminateWorkflowRequest is the request for TerminateWorkflowBeta1.

func (*TerminateWorkflowRequest) AppendSpanAttributes 

func (*TerminateWorkflowRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*TerminateWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use TerminateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowRequest) GetInstanceId 

func (x *TerminateWorkflowRequest) GetInstanceId() string

func (*TerminateWorkflowRequest) GetWorkflowComponent 

func (x *TerminateWorkflowRequest) GetWorkflowComponent() string

func (*TerminateWorkflowRequest) ProtoMessage 

func (*TerminateWorkflowRequest) ProtoMessage()

func (*TerminateWorkflowRequest) ProtoReflect 

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

func (*TerminateWorkflowRequest) Reset 

func (x *TerminateWorkflowRequest) Reset()

func (*TerminateWorkflowRequest) SetInstanceId 

func (x *TerminateWorkflowRequest) SetInstanceId(val string)

func (*TerminateWorkflowRequest) SetWorkflowComponent 

func (x *TerminateWorkflowRequest) SetWorkflowComponent(val string)

func (*TerminateWorkflowRequest) String 

func (x *TerminateWorkflowRequest) String() string

type TopicEventBulkRequest 

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 

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

Deprecated: Use TopicEventBulkRequest.ProtoReflect.Descriptor instead.

func (*TopicEventBulkRequest) GetEntries 

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

func (*TopicEventBulkRequest) GetId 

func (x *TopicEventBulkRequest) GetId() string

func (*TopicEventBulkRequest) GetMetadata 

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

func (*TopicEventBulkRequest) GetPath 

func (x *TopicEventBulkRequest) GetPath() string

func (*TopicEventBulkRequest) GetPubsubName 

func (x *TopicEventBulkRequest) GetPubsubName() string

func (*TopicEventBulkRequest) GetTopic 

func (x *TopicEventBulkRequest) GetTopic() string

func (*TopicEventBulkRequest) GetType 

func (x *TopicEventBulkRequest) GetType() string

func (*TopicEventBulkRequest) ProtoMessage 

func (*TopicEventBulkRequest) ProtoMessage()

func (*TopicEventBulkRequest) ProtoReflect 

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

func (*TopicEventBulkRequest) Reset 

func (x *TopicEventBulkRequest) Reset()

func (*TopicEventBulkRequest) String 

func (x *TopicEventBulkRequest) String() string

type TopicEventBulkRequestEntry 

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 

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

Deprecated: Use TopicEventBulkRequestEntry.ProtoReflect.Descriptor instead.

func (*TopicEventBulkRequestEntry) GetBytes 

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

func (*TopicEventBulkRequestEntry) GetCloudEvent 

func (x *TopicEventBulkRequestEntry) GetCloudEvent() *TopicEventCERequest

func (*TopicEventBulkRequestEntry) GetContentType 

func (x *TopicEventBulkRequestEntry) GetContentType() string

func (*TopicEventBulkRequestEntry) GetEntryId 

func (x *TopicEventBulkRequestEntry) GetEntryId() string

func (*TopicEventBulkRequestEntry) GetEvent 

func (m *TopicEventBulkRequestEntry) GetEvent() isTopicEventBulkRequestEntry_Event

func (*TopicEventBulkRequestEntry) GetMetadata 

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

func (*TopicEventBulkRequestEntry) ProtoMessage 

func (*TopicEventBulkRequestEntry) ProtoMessage()

func (*TopicEventBulkRequestEntry) ProtoReflect 

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

func (*TopicEventBulkRequestEntry) Reset 

func (x *TopicEventBulkRequestEntry) Reset()

func (*TopicEventBulkRequestEntry) String 

func (x *TopicEventBulkRequestEntry) String() string

type TopicEventBulkRequestEntry_Bytes 

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

type TopicEventBulkRequestEntry_CloudEvent 

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

type TopicEventBulkResponse 

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 

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

Deprecated: Use TopicEventBulkResponse.ProtoReflect.Descriptor instead.

func (*TopicEventBulkResponse) GetStatuses 

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

func (*TopicEventBulkResponse) ProtoMessage 

func (*TopicEventBulkResponse) ProtoMessage()

func (*TopicEventBulkResponse) ProtoReflect 

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

func (*TopicEventBulkResponse) Reset 

func (x *TopicEventBulkResponse) Reset()

func (*TopicEventBulkResponse) String 

func (x *TopicEventBulkResponse) String() string

type TopicEventBulkResponseEntry 

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 

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

Deprecated: Use TopicEventBulkResponseEntry.ProtoReflect.Descriptor instead.

func (*TopicEventBulkResponseEntry) GetEntryId 

func (x *TopicEventBulkResponseEntry) GetEntryId() string

func (*TopicEventBulkResponseEntry) GetStatus 

func (x *TopicEventBulkResponseEntry) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventBulkResponseEntry) ProtoMessage 

func (*TopicEventBulkResponseEntry) ProtoMessage()

func (*TopicEventBulkResponseEntry) ProtoReflect 

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

func (*TopicEventBulkResponseEntry) Reset 

func (x *TopicEventBulkResponseEntry) Reset()

func (*TopicEventBulkResponseEntry) String 

func (x *TopicEventBulkResponseEntry) String() string

type TopicEventCERequest 

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 

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

Deprecated: Use TopicEventCERequest.ProtoReflect.Descriptor instead.

func (*TopicEventCERequest) GetData 

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

func (*TopicEventCERequest) GetDataContentType 

func (x *TopicEventCERequest) GetDataContentType() string

func (*TopicEventCERequest) GetExtensions 

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

func (*TopicEventCERequest) GetId 

func (x *TopicEventCERequest) GetId() string

func (*TopicEventCERequest) GetSource 

func (x *TopicEventCERequest) GetSource() string

func (*TopicEventCERequest) GetSpecVersion 

func (x *TopicEventCERequest) GetSpecVersion() string

func (*TopicEventCERequest) GetType 

func (x *TopicEventCERequest) GetType() string

func (*TopicEventCERequest) ProtoMessage 

func (*TopicEventCERequest) ProtoMessage()

func (*TopicEventCERequest) ProtoReflect 

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

func (*TopicEventCERequest) Reset 

func (x *TopicEventCERequest) Reset()

func (*TopicEventCERequest) String 

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 

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

func (*TopicEventRequest) GetId 

func (x *TopicEventRequest) GetId() string

func (*TopicEventRequest) GetPath 

func (x *TopicEventRequest) GetPath() string

func (*TopicEventRequest) GetPubsubName 

func (x *TopicEventRequest) GetPubsubName() string

func (*TopicEventRequest) GetSource 

func (x *TopicEventRequest) GetSource() string

func (*TopicEventRequest) GetSpecVersion 

func (x *TopicEventRequest) GetSpecVersion() string

func (*TopicEventRequest) GetTopic 

func (x *TopicEventRequest) GetTopic() string

func (*TopicEventRequest) GetType 

func (x *TopicEventRequest) GetType() string

func (*TopicEventRequest) ProtoMessage 

func (*TopicEventRequest) ProtoMessage()

func (*TopicEventRequest) ProtoReflect 

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

func (*TopicEventRequest) Reset 

func (x *TopicEventRequest) Reset()

func (*TopicEventRequest) String 

func (x *TopicEventRequest) String() string

type TopicEventResponse 

type TopicEventResponse struct {

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

TopicEventResponse is response from app on published message

func (*TopicEventResponse) Descriptor deprecated 

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

Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.

func (*TopicEventResponse) GetStatus 

func (x *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventResponse) ProtoMessage 

func (*TopicEventResponse) ProtoMessage()

func (*TopicEventResponse) ProtoReflect 

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

func (*TopicEventResponse) Reset 

func (x *TopicEventResponse) Reset()

func (*TopicEventResponse) String 

func (x *TopicEventResponse) String() string

type TopicEventResponse_TopicEventResponseStatus 

type TopicEventResponse_TopicEventResponseStatus int32

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

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

func (TopicEventResponse_TopicEventResponseStatus) Descriptor 

func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (TopicEventResponse_TopicEventResponseStatus) Enum 

func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

func (TopicEventResponse_TopicEventResponseStatus) EnumDescriptor deprecated 

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

Deprecated: Use TopicEventResponse_TopicEventResponseStatus.Descriptor instead.

func (TopicEventResponse_TopicEventResponseStatus) Number 

func (x TopicEventResponse_TopicEventResponseStatus) Number() protoreflect.EnumNumber

func (TopicEventResponse_TopicEventResponseStatus) String 

func (x TopicEventResponse_TopicEventResponseStatus) String() string

func (TopicEventResponse_TopicEventResponseStatus) Type 

func (TopicEventResponse_TopicEventResponseStatus) Type() protoreflect.EnumType

type TopicRoutes 

type TopicRoutes struct {

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

func (*TopicRoutes) Descriptor deprecated 

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

Deprecated: Use TopicRoutes.ProtoReflect.Descriptor instead.

func (*TopicRoutes) GetDefault 

func (x *TopicRoutes) GetDefault() string

func (*TopicRoutes) GetRules 

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

func (*TopicRoutes) ProtoMessage 

func (*TopicRoutes) ProtoMessage()

func (*TopicRoutes) ProtoReflect 

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

func (*TopicRoutes) Reset 

func (x *TopicRoutes) Reset()

func (*TopicRoutes) String 

func (x *TopicRoutes) String() string

type TopicRule 

type TopicRule struct {

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

func (*TopicRule) Descriptor deprecated 

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

Deprecated: Use TopicRule.ProtoReflect.Descriptor instead.

func (*TopicRule) GetMatch 

func (x *TopicRule) GetMatch() string

func (*TopicRule) GetPath 

func (x *TopicRule) GetPath() string

func (*TopicRule) ProtoMessage 

func (*TopicRule) ProtoMessage()

func (*TopicRule) ProtoReflect 

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

func (*TopicRule) Reset 

func (x *TopicRule) Reset()

func (*TopicRule) String 

func (x *TopicRule) String() string

type TopicSubscription 

type TopicSubscription struct {

	// Required. The name of the pubsub containing the topic below to subscribe to.
	PubsubName string `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// Required. The name of topic which will be subscribed
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The optional properties used for this topic's subscription e.g. session id
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The optional routing rules to match against. In the gRPC interface, OnTopicEvent
	// is still invoked but the matching path is sent in the TopicEventRequest.
	Routes *TopicRoutes `protobuf:"bytes,5,opt,name=routes,proto3" json:"routes,omitempty"`
	// 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 

func (x *TopicSubscription) GetBulkSubscribe() *BulkSubscribeConfig

func (*TopicSubscription) GetDeadLetterTopic 

func (x *TopicSubscription) GetDeadLetterTopic() string

func (*TopicSubscription) GetMetadata 

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

func (*TopicSubscription) GetPubsubName 

func (x *TopicSubscription) GetPubsubName() string

func (*TopicSubscription) GetRoutes 

func (x *TopicSubscription) GetRoutes() *TopicRoutes

func (*TopicSubscription) GetTopic 

func (x *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage 

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect 

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

func (*TopicSubscription) Reset 

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String 

func (x *TopicSubscription) String() string

type TransactionalActorStateOperation 

type TransactionalActorStateOperation struct {
	OperationType string     `protobuf:"bytes,1,opt,name=operationType,proto3" json:"operationType,omitempty"`
	Key           string     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value         *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// The metadata used for transactional operations.
	//
	// Common metadata property:
	// - ttlInSeconds : the time to live in seconds for the stored value.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*TransactionalActorStateOperation) Descriptor deprecated 

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

Deprecated: Use TransactionalActorStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalActorStateOperation) GetKey 

func (x *TransactionalActorStateOperation) GetKey() string

func (*TransactionalActorStateOperation) GetMetadata 

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

func (*TransactionalActorStateOperation) GetOperationType 

func (x *TransactionalActorStateOperation) GetOperationType() string

func (*TransactionalActorStateOperation) GetValue 

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

func (*TransactionalActorStateOperation) ProtoMessage 

func (*TransactionalActorStateOperation) ProtoMessage()

func (*TransactionalActorStateOperation) ProtoReflect 

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

func (*TransactionalActorStateOperation) Reset 

func (x *TransactionalActorStateOperation) Reset()

func (*TransactionalActorStateOperation) String 

func (x *TransactionalActorStateOperation) String() string

type TransactionalStateOperation 

type TransactionalStateOperation struct {

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

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

func (*TransactionalStateOperation) Descriptor deprecated 

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

Deprecated: Use TransactionalStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalStateOperation) GetOperationType 

func (x *TransactionalStateOperation) GetOperationType() string

func (*TransactionalStateOperation) GetRequest 

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

func (*TransactionalStateOperation) ProtoMessage 

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect 

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

func (*TransactionalStateOperation) Reset 

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String 

func (x *TransactionalStateOperation) String() string

type TryLockRequest 

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=expiry_in_seconds,json=expiryInSeconds,proto3" json:"expiry_in_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*TryLockRequest) AppendSpanAttributes 

func (*TryLockRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*TryLockRequest) Descriptor deprecated 

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

Deprecated: Use TryLockRequest.ProtoReflect.Descriptor instead.

func (*TryLockRequest) GetExpiryInSeconds 

func (x *TryLockRequest) GetExpiryInSeconds() int32

func (*TryLockRequest) GetLockOwner 

func (x *TryLockRequest) GetLockOwner() string

func (*TryLockRequest) GetResourceId 

func (x *TryLockRequest) GetResourceId() string

func (*TryLockRequest) GetStoreName 

func (x *TryLockRequest) GetStoreName() string

func (*TryLockRequest) ProtoMessage 

func (*TryLockRequest) ProtoMessage()

func (*TryLockRequest) ProtoReflect 

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

func (*TryLockRequest) Reset 

func (x *TryLockRequest) Reset()

func (*TryLockRequest) String 

func (x *TryLockRequest) String() string

type TryLockResponse 

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

func (*TryLockResponse) Descriptor deprecated 

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

Deprecated: Use TryLockResponse.ProtoReflect.Descriptor instead.

func (*TryLockResponse) GetSuccess 

func (x *TryLockResponse) GetSuccess() bool

func (*TryLockResponse) ProtoMessage 

func (*TryLockResponse) ProtoMessage()

func (*TryLockResponse) ProtoReflect 

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

func (*TryLockResponse) Reset 

func (x *TryLockResponse) Reset()

func (*TryLockResponse) String 

func (x *TryLockResponse) String() string

type UnimplementedAppCallbackAlphaServer 

type UnimplementedAppCallbackAlphaServer struct {
}

UnimplementedAppCallbackAlphaServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackAlphaServer) OnBulkTopicEventAlpha1 

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

func (UnimplementedAppCallbackAlphaServer) OnJobEventAlpha1 

func (UnimplementedAppCallbackAlphaServer) OnJobEventAlpha1(context.Context, *JobEventRequest) (*JobEventResponse, error)

type UnimplementedAppCallbackHealthCheckServer 

type UnimplementedAppCallbackHealthCheckServer struct {
}

UnimplementedAppCallbackHealthCheckServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackHealthCheckServer) HealthCheck 

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 

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

func (UnimplementedDaprServer) ConverseAlpha1 

func (UnimplementedDaprServer) ConverseAlpha1(context.Context, *ConversationRequest) (*ConversationResponse, error)

func (UnimplementedDaprServer) DecryptAlpha1 

func (UnimplementedDaprServer) DecryptAlpha1(Dapr_DecryptAlpha1Server) error

func (UnimplementedDaprServer) DeleteBulkState 

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

func (UnimplementedDaprServer) DeleteJobAlpha1 

func (UnimplementedDaprServer) DeleteJobAlpha1(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)

func (UnimplementedDaprServer) DeleteState 

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

func (UnimplementedDaprServer) EncryptAlpha1 

func (UnimplementedDaprServer) EncryptAlpha1(Dapr_EncryptAlpha1Server) error

func (UnimplementedDaprServer) ExecuteActorStateTransaction 

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

func (UnimplementedDaprServer) ExecuteStateTransaction 

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

func (UnimplementedDaprServer) GetActorState 

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

func (UnimplementedDaprServer) GetBulkSecret 

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

func (UnimplementedDaprServer) GetBulkState 

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

func (UnimplementedDaprServer) GetConfiguration 

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

func (UnimplementedDaprServer) GetConfigurationAlpha1 

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

func (UnimplementedDaprServer) GetJobAlpha1 

func (UnimplementedDaprServer) GetJobAlpha1(context.Context, *GetJobRequest) (*GetJobResponse, error)

func (UnimplementedDaprServer) GetMetadata 

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

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

func (UnimplementedDaprServer) GetWorkflowBeta1 

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

func (UnimplementedDaprServer) InvokeActor 

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

func (UnimplementedDaprServer) InvokeBinding 

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

func (UnimplementedDaprServer) InvokeService 

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

func (UnimplementedDaprServer) PauseWorkflowAlpha1 

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

func (UnimplementedDaprServer) PauseWorkflowBeta1 

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

func (UnimplementedDaprServer) PublishEvent 

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

func (UnimplementedDaprServer) PurgeWorkflowAlpha1 

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

func (UnimplementedDaprServer) PurgeWorkflowBeta1 

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

func (UnimplementedDaprServer) QueryStateAlpha1 

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

func (UnimplementedDaprServer) RaiseEventWorkflowAlpha1 

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

func (UnimplementedDaprServer) RaiseEventWorkflowBeta1 

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

func (UnimplementedDaprServer) RegisterActorReminder 

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

func (UnimplementedDaprServer) RegisterActorTimer 

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

func (UnimplementedDaprServer) ResumeWorkflowAlpha1 

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

func (UnimplementedDaprServer) ResumeWorkflowBeta1 

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

func (UnimplementedDaprServer) SaveState 

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

func (UnimplementedDaprServer) ScheduleJobAlpha1 

func (UnimplementedDaprServer) ScheduleJobAlpha1(context.Context, *ScheduleJobRequest) (*ScheduleJobResponse, error)

func (UnimplementedDaprServer) SetMetadata 

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

func (UnimplementedDaprServer) Shutdown 

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

func (UnimplementedDaprServer) StartWorkflowAlpha1 

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

func (UnimplementedDaprServer) StartWorkflowBeta1 

func (UnimplementedDaprServer) StartWorkflowBeta1(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)

func (UnimplementedDaprServer) SubscribeConfiguration 

func (UnimplementedDaprServer) SubscribeConfiguration(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationServer) error

func (UnimplementedDaprServer) SubscribeConfigurationAlpha1 

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

func (UnimplementedDaprServer) SubscribeTopicEventsAlpha1 

func (UnimplementedDaprServer) SubscribeTopicEventsAlpha1(Dapr_SubscribeTopicEventsAlpha1Server) error

func (UnimplementedDaprServer) SubtleDecryptAlpha1 

func (UnimplementedDaprServer) SubtleDecryptAlpha1(context.Context, *SubtleDecryptRequest) (*SubtleDecryptResponse, error)

func (UnimplementedDaprServer) SubtleEncryptAlpha1 

func (UnimplementedDaprServer) SubtleEncryptAlpha1(context.Context, *SubtleEncryptRequest) (*SubtleEncryptResponse, error)

func (UnimplementedDaprServer) SubtleGetKeyAlpha1 

func (UnimplementedDaprServer) SubtleGetKeyAlpha1(context.Context, *SubtleGetKeyRequest) (*SubtleGetKeyResponse, error)

func (UnimplementedDaprServer) SubtleSignAlpha1 

func (UnimplementedDaprServer) SubtleSignAlpha1(context.Context, *SubtleSignRequest) (*SubtleSignResponse, error)

func (UnimplementedDaprServer) SubtleUnwrapKeyAlpha1 

func (UnimplementedDaprServer) SubtleUnwrapKeyAlpha1(context.Context, *SubtleUnwrapKeyRequest) (*SubtleUnwrapKeyResponse, error)

func (UnimplementedDaprServer) SubtleVerifyAlpha1 

func (UnimplementedDaprServer) SubtleVerifyAlpha1(context.Context, *SubtleVerifyRequest) (*SubtleVerifyResponse, error)

func (UnimplementedDaprServer) SubtleWrapKeyAlpha1 

func (UnimplementedDaprServer) SubtleWrapKeyAlpha1(context.Context, *SubtleWrapKeyRequest) (*SubtleWrapKeyResponse, error)

func (UnimplementedDaprServer) TerminateWorkflowAlpha1 

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

func (UnimplementedDaprServer) TerminateWorkflowBeta1 

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

func (UnimplementedDaprServer) TryLockAlpha1 

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

func (UnimplementedDaprServer) UnlockAlpha1 

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

func (UnimplementedDaprServer) UnregisterActorReminder 

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

func (UnimplementedDaprServer) UnregisterActorTimer 

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

func (UnimplementedDaprServer) UnsubscribeConfiguration 

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

func (UnimplementedDaprServer) UnsubscribeConfigurationAlpha1 

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

type UnlockRequest 

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) AppendSpanAttributes 

func (*UnlockRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*UnlockRequest) Descriptor deprecated 

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

Deprecated: Use UnlockRequest.ProtoReflect.Descriptor instead.

func (*UnlockRequest) GetLockOwner 

func (x *UnlockRequest) GetLockOwner() string

func (*UnlockRequest) GetResourceId 

func (x *UnlockRequest) GetResourceId() string

func (*UnlockRequest) GetStoreName 

func (x *UnlockRequest) GetStoreName() string

func (*UnlockRequest) ProtoMessage 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) ProtoReflect 

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

func (*UnlockRequest) Reset 

func (x *UnlockRequest) Reset()

func (*UnlockRequest) String 

func (x *UnlockRequest) String() string

type UnlockResponse 

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 

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

Deprecated: Use UnlockResponse.ProtoReflect.Descriptor instead.

func (*UnlockResponse) GetStatus 

func (x *UnlockResponse) GetStatus() UnlockResponse_Status

func (*UnlockResponse) ProtoMessage 

func (*UnlockResponse) ProtoMessage()

func (*UnlockResponse) ProtoReflect 

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

func (*UnlockResponse) Reset 

func (x *UnlockResponse) Reset()

func (*UnlockResponse) String 

func (x *UnlockResponse) String() string

type UnlockResponse_Status 

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 

func (UnlockResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (UnlockResponse_Status) Enum 

func (x UnlockResponse_Status) Enum() *UnlockResponse_Status

func (UnlockResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use UnlockResponse_Status.Descriptor instead.

func (UnlockResponse_Status) Number 

func (x UnlockResponse_Status) Number() protoreflect.EnumNumber

func (UnlockResponse_Status) String 

func (x UnlockResponse_Status) String() string

func (UnlockResponse_Status) Type 

func (UnlockResponse_Status) Type() protoreflect.EnumType

type UnregisterActorReminderRequest 

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

UnregisterActorReminderRequest is the message to unregister an actor reminder.

func (*UnregisterActorReminderRequest) AppendSpanAttributes 

func (*UnregisterActorReminderRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*UnregisterActorReminderRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterActorReminderRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorReminderRequest) GetActorId 

func (x *UnregisterActorReminderRequest) GetActorId() string

func (*UnregisterActorReminderRequest) GetActorType 

func (x *UnregisterActorReminderRequest) GetActorType() string

func (*UnregisterActorReminderRequest) GetName 

func (x *UnregisterActorReminderRequest) GetName() string

func (*UnregisterActorReminderRequest) ProtoMessage 

func (*UnregisterActorReminderRequest) ProtoMessage()

func (*UnregisterActorReminderRequest) ProtoReflect 

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

func (*UnregisterActorReminderRequest) Reset 

func (x *UnregisterActorReminderRequest) Reset()

func (*UnregisterActorReminderRequest) String 

func (x *UnregisterActorReminderRequest) String() string

type UnregisterActorTimerRequest 

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

UnregisterActorTimerRequest is the message to unregister an actor timer

func (*UnregisterActorTimerRequest) AppendSpanAttributes 

func (*UnregisterActorTimerRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*UnregisterActorTimerRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterActorTimerRequest.ProtoReflect.Descriptor instead.

func (*UnregisterActorTimerRequest) GetActorId 

func (x *UnregisterActorTimerRequest) GetActorId() string

func (*UnregisterActorTimerRequest) GetActorType 

func (x *UnregisterActorTimerRequest) GetActorType() string

func (*UnregisterActorTimerRequest) GetName 

func (x *UnregisterActorTimerRequest) GetName() string

func (*UnregisterActorTimerRequest) ProtoMessage 

func (*UnregisterActorTimerRequest) ProtoMessage()

func (*UnregisterActorTimerRequest) ProtoReflect 

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

func (*UnregisterActorTimerRequest) Reset 

func (x *UnregisterActorTimerRequest) Reset()

func (*UnregisterActorTimerRequest) String 

func (x *UnregisterActorTimerRequest) String() string

type UnsafeAppCallbackAlphaServer 

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 

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 

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

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

type UnsafeDaprServer 

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

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

type UnsubscribeConfigurationRequest 

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) AppendSpanAttributes 

func (*UnsubscribeConfigurationRequest) AppendSpanAttributes(rpcMethod string, m map[string]string)

func (*UnsubscribeConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use UnsubscribeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeConfigurationRequest) GetId 

func (x *UnsubscribeConfigurationRequest) GetId() string

func (*UnsubscribeConfigurationRequest) GetStoreName 

func (x *UnsubscribeConfigurationRequest) GetStoreName() string

func (*UnsubscribeConfigurationRequest) ProtoMessage 

func (*UnsubscribeConfigurationRequest) ProtoMessage()

func (*UnsubscribeConfigurationRequest) ProtoReflect 

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

func (*UnsubscribeConfigurationRequest) Reset 

func (x *UnsubscribeConfigurationRequest) Reset()

func (*UnsubscribeConfigurationRequest) String 

func (x *UnsubscribeConfigurationRequest) String() string

type UnsubscribeConfigurationResponse 

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 

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

Deprecated: Use UnsubscribeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*UnsubscribeConfigurationResponse) GetMessage 

func (x *UnsubscribeConfigurationResponse) GetMessage() string

func (*UnsubscribeConfigurationResponse) GetOk 

func (x *UnsubscribeConfigurationResponse) GetOk() bool

func (*UnsubscribeConfigurationResponse) ProtoMessage 

func (*UnsubscribeConfigurationResponse) ProtoMessage()

func (*UnsubscribeConfigurationResponse) ProtoReflect 

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

func (*UnsubscribeConfigurationResponse) Reset 

func (x *UnsubscribeConfigurationResponse) Reset()

func (*UnsubscribeConfigurationResponse) String 

func (x *UnsubscribeConfigurationResponse) String() string

type WorkflowRequests 

type WorkflowRequests interface {
	// SetWorkflowComponent sets the value of the WorkflowComponent property.
	SetWorkflowComponent(val string)
	// SetInstanceId sets the value of the InstanceId property.
	SetInstanceId(val string)
}

WorkflowRequests is an interface for all a number of *WorkflowRequest structs.

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.