runtimeconnect

package
v1.17.8 Latest Latest
Warning

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

 Go to latest Published: May 28, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AppCallbackName is the fully-qualified name of the AppCallback service.
	AppCallbackName = "dapr.proto.runtime.v1.AppCallback"
	// AppCallbackHealthCheckName is the fully-qualified name of the AppCallbackHealthCheck service.
	AppCallbackHealthCheckName = "dapr.proto.runtime.v1.AppCallbackHealthCheck"
	// AppCallbackAlphaName is the fully-qualified name of the AppCallbackAlpha service.
	AppCallbackAlphaName = "dapr.proto.runtime.v1.AppCallbackAlpha"
)
View Source 
const (
	// AppCallbackOnInvokeProcedure is the fully-qualified name of the AppCallback's OnInvoke RPC.
	AppCallbackOnInvokeProcedure = "/dapr.proto.runtime.v1.AppCallback/OnInvoke"
	// AppCallbackListTopicSubscriptionsProcedure is the fully-qualified name of the AppCallback's
	// ListTopicSubscriptions RPC.
	AppCallbackListTopicSubscriptionsProcedure = "/dapr.proto.runtime.v1.AppCallback/ListTopicSubscriptions"
	// AppCallbackOnTopicEventProcedure is the fully-qualified name of the AppCallback's OnTopicEvent
	// RPC.
	AppCallbackOnTopicEventProcedure = "/dapr.proto.runtime.v1.AppCallback/OnTopicEvent"
	// AppCallbackListInputBindingsProcedure is the fully-qualified name of the AppCallback's
	// ListInputBindings RPC.
	AppCallbackListInputBindingsProcedure = "/dapr.proto.runtime.v1.AppCallback/ListInputBindings"
	// AppCallbackOnBindingEventProcedure is the fully-qualified name of the AppCallback's
	// OnBindingEvent RPC.
	AppCallbackOnBindingEventProcedure = "/dapr.proto.runtime.v1.AppCallback/OnBindingEvent"
	// AppCallbackOnBulkTopicEventProcedure is the fully-qualified name of the AppCallback's
	// OnBulkTopicEvent RPC.
	AppCallbackOnBulkTopicEventProcedure = "/dapr.proto.runtime.v1.AppCallback/OnBulkTopicEvent"
	// AppCallbackHealthCheckHealthCheckProcedure is the fully-qualified name of the
	// AppCallbackHealthCheck's HealthCheck RPC.
	AppCallbackHealthCheckHealthCheckProcedure = "/dapr.proto.runtime.v1.AppCallbackHealthCheck/HealthCheck"
	// AppCallbackAlphaOnBulkTopicEventAlpha1Procedure is the fully-qualified name of the
	// AppCallbackAlpha's OnBulkTopicEventAlpha1 RPC.
	AppCallbackAlphaOnBulkTopicEventAlpha1Procedure = "/dapr.proto.runtime.v1.AppCallbackAlpha/OnBulkTopicEventAlpha1"
	// AppCallbackAlphaOnJobEventAlpha1Procedure is the fully-qualified name of the AppCallbackAlpha's
	// OnJobEventAlpha1 RPC.
	AppCallbackAlphaOnJobEventAlpha1Procedure = "/dapr.proto.runtime.v1.AppCallbackAlpha/OnJobEventAlpha1"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// DaprInvokeServiceProcedure is the fully-qualified name of the Dapr's InvokeService RPC.
	DaprInvokeServiceProcedure = "/dapr.proto.runtime.v1.Dapr/InvokeService"
	// DaprGetStateProcedure is the fully-qualified name of the Dapr's GetState RPC.
	DaprGetStateProcedure = "/dapr.proto.runtime.v1.Dapr/GetState"
	// DaprGetBulkStateProcedure is the fully-qualified name of the Dapr's GetBulkState RPC.
	DaprGetBulkStateProcedure = "/dapr.proto.runtime.v1.Dapr/GetBulkState"
	// DaprSaveStateProcedure is the fully-qualified name of the Dapr's SaveState RPC.
	DaprSaveStateProcedure = "/dapr.proto.runtime.v1.Dapr/SaveState"
	// DaprQueryStateAlpha1Procedure is the fully-qualified name of the Dapr's QueryStateAlpha1 RPC.
	DaprQueryStateAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/QueryStateAlpha1"
	// DaprDeleteStateProcedure is the fully-qualified name of the Dapr's DeleteState RPC.
	DaprDeleteStateProcedure = "/dapr.proto.runtime.v1.Dapr/DeleteState"
	// DaprDeleteBulkStateProcedure is the fully-qualified name of the Dapr's DeleteBulkState RPC.
	DaprDeleteBulkStateProcedure = "/dapr.proto.runtime.v1.Dapr/DeleteBulkState"
	// DaprExecuteStateTransactionProcedure is the fully-qualified name of the Dapr's
	// ExecuteStateTransaction RPC.
	DaprExecuteStateTransactionProcedure = "/dapr.proto.runtime.v1.Dapr/ExecuteStateTransaction"
	// DaprPublishEventProcedure is the fully-qualified name of the Dapr's PublishEvent RPC.
	DaprPublishEventProcedure = "/dapr.proto.runtime.v1.Dapr/PublishEvent"
	// DaprBulkPublishEventAlpha1Procedure is the fully-qualified name of the Dapr's
	// BulkPublishEventAlpha1 RPC.
	DaprBulkPublishEventAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/BulkPublishEventAlpha1"
	// DaprBulkPublishEventProcedure is the fully-qualified name of the Dapr's BulkPublishEvent RPC.
	DaprBulkPublishEventProcedure = "/dapr.proto.runtime.v1.Dapr/BulkPublishEvent"
	// DaprSubscribeTopicEventsAlpha1Procedure is the fully-qualified name of the Dapr's
	// SubscribeTopicEventsAlpha1 RPC.
	DaprSubscribeTopicEventsAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubscribeTopicEventsAlpha1"
	// DaprInvokeBindingProcedure is the fully-qualified name of the Dapr's InvokeBinding RPC.
	DaprInvokeBindingProcedure = "/dapr.proto.runtime.v1.Dapr/InvokeBinding"
	// DaprGetSecretProcedure is the fully-qualified name of the Dapr's GetSecret RPC.
	DaprGetSecretProcedure = "/dapr.proto.runtime.v1.Dapr/GetSecret"
	// DaprGetBulkSecretProcedure is the fully-qualified name of the Dapr's GetBulkSecret RPC.
	DaprGetBulkSecretProcedure = "/dapr.proto.runtime.v1.Dapr/GetBulkSecret"
	// DaprRegisterActorTimerProcedure is the fully-qualified name of the Dapr's RegisterActorTimer RPC.
	DaprRegisterActorTimerProcedure = "/dapr.proto.runtime.v1.Dapr/RegisterActorTimer"
	// DaprUnregisterActorTimerProcedure is the fully-qualified name of the Dapr's UnregisterActorTimer
	// RPC.
	DaprUnregisterActorTimerProcedure = "/dapr.proto.runtime.v1.Dapr/UnregisterActorTimer"
	// DaprRegisterActorReminderProcedure is the fully-qualified name of the Dapr's
	// RegisterActorReminder RPC.
	DaprRegisterActorReminderProcedure = "/dapr.proto.runtime.v1.Dapr/RegisterActorReminder"
	// DaprUnregisterActorReminderProcedure is the fully-qualified name of the Dapr's
	// UnregisterActorReminder RPC.
	DaprUnregisterActorReminderProcedure = "/dapr.proto.runtime.v1.Dapr/UnregisterActorReminder"
	// DaprUnregisterActorRemindersByTypeProcedure is the fully-qualified name of the Dapr's
	// UnregisterActorRemindersByType RPC.
	DaprUnregisterActorRemindersByTypeProcedure = "/dapr.proto.runtime.v1.Dapr/UnregisterActorRemindersByType"
	// DaprListActorRemindersProcedure is the fully-qualified name of the Dapr's ListActorReminders RPC.
	DaprListActorRemindersProcedure = "/dapr.proto.runtime.v1.Dapr/ListActorReminders"
	// DaprGetActorStateProcedure is the fully-qualified name of the Dapr's GetActorState RPC.
	DaprGetActorStateProcedure = "/dapr.proto.runtime.v1.Dapr/GetActorState"
	// DaprGetActorReminderProcedure is the fully-qualified name of the Dapr's GetActorReminder RPC.
	DaprGetActorReminderProcedure = "/dapr.proto.runtime.v1.Dapr/GetActorReminder"
	// DaprExecuteActorStateTransactionProcedure is the fully-qualified name of the Dapr's
	// ExecuteActorStateTransaction RPC.
	DaprExecuteActorStateTransactionProcedure = "/dapr.proto.runtime.v1.Dapr/ExecuteActorStateTransaction"
	// DaprInvokeActorProcedure is the fully-qualified name of the Dapr's InvokeActor RPC.
	DaprInvokeActorProcedure = "/dapr.proto.runtime.v1.Dapr/InvokeActor"
	// DaprGetConfigurationAlpha1Procedure is the fully-qualified name of the Dapr's
	// GetConfigurationAlpha1 RPC.
	DaprGetConfigurationAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/GetConfigurationAlpha1"
	// DaprGetConfigurationProcedure is the fully-qualified name of the Dapr's GetConfiguration RPC.
	DaprGetConfigurationProcedure = "/dapr.proto.runtime.v1.Dapr/GetConfiguration"
	// DaprSubscribeConfigurationAlpha1Procedure is the fully-qualified name of the Dapr's
	// SubscribeConfigurationAlpha1 RPC.
	DaprSubscribeConfigurationAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubscribeConfigurationAlpha1"
	// DaprSubscribeConfigurationProcedure is the fully-qualified name of the Dapr's
	// SubscribeConfiguration RPC.
	DaprSubscribeConfigurationProcedure = "/dapr.proto.runtime.v1.Dapr/SubscribeConfiguration"
	// DaprUnsubscribeConfigurationAlpha1Procedure is the fully-qualified name of the Dapr's
	// UnsubscribeConfigurationAlpha1 RPC.
	DaprUnsubscribeConfigurationAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/UnsubscribeConfigurationAlpha1"
	// DaprUnsubscribeConfigurationProcedure is the fully-qualified name of the Dapr's
	// UnsubscribeConfiguration RPC.
	DaprUnsubscribeConfigurationProcedure = "/dapr.proto.runtime.v1.Dapr/UnsubscribeConfiguration"
	// DaprTryLockAlpha1Procedure is the fully-qualified name of the Dapr's TryLockAlpha1 RPC.
	DaprTryLockAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/TryLockAlpha1"
	// DaprUnlockAlpha1Procedure is the fully-qualified name of the Dapr's UnlockAlpha1 RPC.
	DaprUnlockAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/UnlockAlpha1"
	// DaprEncryptAlpha1Procedure is the fully-qualified name of the Dapr's EncryptAlpha1 RPC.
	DaprEncryptAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/EncryptAlpha1"
	// DaprDecryptAlpha1Procedure is the fully-qualified name of the Dapr's DecryptAlpha1 RPC.
	DaprDecryptAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/DecryptAlpha1"
	// DaprGetMetadataProcedure is the fully-qualified name of the Dapr's GetMetadata RPC.
	DaprGetMetadataProcedure = "/dapr.proto.runtime.v1.Dapr/GetMetadata"
	// DaprSetMetadataProcedure is the fully-qualified name of the Dapr's SetMetadata RPC.
	DaprSetMetadataProcedure = "/dapr.proto.runtime.v1.Dapr/SetMetadata"
	// DaprSubtleGetKeyAlpha1Procedure is the fully-qualified name of the Dapr's SubtleGetKeyAlpha1 RPC.
	DaprSubtleGetKeyAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleGetKeyAlpha1"
	// DaprSubtleEncryptAlpha1Procedure is the fully-qualified name of the Dapr's SubtleEncryptAlpha1
	// RPC.
	DaprSubtleEncryptAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleEncryptAlpha1"
	// DaprSubtleDecryptAlpha1Procedure is the fully-qualified name of the Dapr's SubtleDecryptAlpha1
	// RPC.
	DaprSubtleDecryptAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleDecryptAlpha1"
	// DaprSubtleWrapKeyAlpha1Procedure is the fully-qualified name of the Dapr's SubtleWrapKeyAlpha1
	// RPC.
	DaprSubtleWrapKeyAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleWrapKeyAlpha1"
	// DaprSubtleUnwrapKeyAlpha1Procedure is the fully-qualified name of the Dapr's
	// SubtleUnwrapKeyAlpha1 RPC.
	DaprSubtleUnwrapKeyAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleUnwrapKeyAlpha1"
	// DaprSubtleSignAlpha1Procedure is the fully-qualified name of the Dapr's SubtleSignAlpha1 RPC.
	DaprSubtleSignAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleSignAlpha1"
	// DaprSubtleVerifyAlpha1Procedure is the fully-qualified name of the Dapr's SubtleVerifyAlpha1 RPC.
	DaprSubtleVerifyAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/SubtleVerifyAlpha1"
	// DaprStartWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's StartWorkflowAlpha1
	// RPC.
	DaprStartWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/StartWorkflowAlpha1"
	// DaprGetWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's GetWorkflowAlpha1 RPC.
	DaprGetWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/GetWorkflowAlpha1"
	// DaprPurgeWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's PurgeWorkflowAlpha1
	// RPC.
	DaprPurgeWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/PurgeWorkflowAlpha1"
	// DaprTerminateWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's
	// TerminateWorkflowAlpha1 RPC.
	DaprTerminateWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/TerminateWorkflowAlpha1"
	// DaprPauseWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's PauseWorkflowAlpha1
	// RPC.
	DaprPauseWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/PauseWorkflowAlpha1"
	// DaprResumeWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's ResumeWorkflowAlpha1
	// RPC.
	DaprResumeWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/ResumeWorkflowAlpha1"
	// DaprRaiseEventWorkflowAlpha1Procedure is the fully-qualified name of the Dapr's
	// RaiseEventWorkflowAlpha1 RPC.
	DaprRaiseEventWorkflowAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/RaiseEventWorkflowAlpha1"
	// DaprStartWorkflowBeta1Procedure is the fully-qualified name of the Dapr's StartWorkflowBeta1 RPC.
	DaprStartWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/StartWorkflowBeta1"
	// DaprGetWorkflowBeta1Procedure is the fully-qualified name of the Dapr's GetWorkflowBeta1 RPC.
	DaprGetWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/GetWorkflowBeta1"
	// DaprPurgeWorkflowBeta1Procedure is the fully-qualified name of the Dapr's PurgeWorkflowBeta1 RPC.
	DaprPurgeWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/PurgeWorkflowBeta1"
	// DaprTerminateWorkflowBeta1Procedure is the fully-qualified name of the Dapr's
	// TerminateWorkflowBeta1 RPC.
	DaprTerminateWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/TerminateWorkflowBeta1"
	// DaprPauseWorkflowBeta1Procedure is the fully-qualified name of the Dapr's PauseWorkflowBeta1 RPC.
	DaprPauseWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/PauseWorkflowBeta1"
	// DaprResumeWorkflowBeta1Procedure is the fully-qualified name of the Dapr's ResumeWorkflowBeta1
	// RPC.
	DaprResumeWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/ResumeWorkflowBeta1"
	// DaprRaiseEventWorkflowBeta1Procedure is the fully-qualified name of the Dapr's
	// RaiseEventWorkflowBeta1 RPC.
	DaprRaiseEventWorkflowBeta1Procedure = "/dapr.proto.runtime.v1.Dapr/RaiseEventWorkflowBeta1"
	// DaprShutdownProcedure is the fully-qualified name of the Dapr's Shutdown RPC.
	DaprShutdownProcedure = "/dapr.proto.runtime.v1.Dapr/Shutdown"
	// DaprScheduleJobAlpha1Procedure is the fully-qualified name of the Dapr's ScheduleJobAlpha1 RPC.
	DaprScheduleJobAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/ScheduleJobAlpha1"
	// DaprGetJobAlpha1Procedure is the fully-qualified name of the Dapr's GetJobAlpha1 RPC.
	DaprGetJobAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/GetJobAlpha1"
	// DaprDeleteJobAlpha1Procedure is the fully-qualified name of the Dapr's DeleteJobAlpha1 RPC.
	DaprDeleteJobAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/DeleteJobAlpha1"
	// DaprDeleteJobsByPrefixAlpha1Procedure is the fully-qualified name of the Dapr's
	// DeleteJobsByPrefixAlpha1 RPC.
	DaprDeleteJobsByPrefixAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/DeleteJobsByPrefixAlpha1"
	// DaprListJobsAlpha1Procedure is the fully-qualified name of the Dapr's ListJobsAlpha1 RPC.
	DaprListJobsAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/ListJobsAlpha1"
	// DaprConverseAlpha1Procedure is the fully-qualified name of the Dapr's ConverseAlpha1 RPC.
	DaprConverseAlpha1Procedure = "/dapr.proto.runtime.v1.Dapr/ConverseAlpha1"
	// DaprConverseAlpha2Procedure is the fully-qualified name of the Dapr's ConverseAlpha2 RPC.
	DaprConverseAlpha2Procedure = "/dapr.proto.runtime.v1.Dapr/ConverseAlpha2"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// DaprName is the fully-qualified name of the Dapr service.
	DaprName = "dapr.proto.runtime.v1.Dapr"
)

Variables

This section is empty.

Functions

func NewAppCallbackAlphaHandler 

func NewAppCallbackAlphaHandler(svc AppCallbackAlphaHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAppCallbackAlphaHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewAppCallbackHandler 

func NewAppCallbackHandler(svc AppCallbackHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAppCallbackHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewAppCallbackHealthCheckHandler 

func NewAppCallbackHealthCheckHandler(svc AppCallbackHealthCheckHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAppCallbackHealthCheckHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewDaprHandler 

func NewDaprHandler(svc DaprHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDaprHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type AppCallbackAlphaClient 

type AppCallbackAlphaClient interface {
	// Subscribes bulk events from Pubsub
	//
	// Deprecated: do not use.
	OnBulkTopicEventAlpha1(context.Context, *connect.Request[v11.TopicEventBulkRequest]) (*connect.Response[v11.TopicEventBulkResponse], error)
	// Sends job back to the app's endpoint at trigger time.
	OnJobEventAlpha1(context.Context, *connect.Request[v11.JobEventRequest]) (*connect.Response[v11.JobEventResponse], error)
}

AppCallbackAlphaClient is a client for the dapr.proto.runtime.v1.AppCallbackAlpha service.

func NewAppCallbackAlphaClient 

func NewAppCallbackAlphaClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AppCallbackAlphaClient

NewAppCallbackAlphaClient constructs a client for the dapr.proto.runtime.v1.AppCallbackAlpha service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AppCallbackAlphaHandler 

type AppCallbackAlphaHandler interface {
	// Subscribes bulk events from Pubsub
	//
	// Deprecated: do not use.
	OnBulkTopicEventAlpha1(context.Context, *connect.Request[v11.TopicEventBulkRequest]) (*connect.Response[v11.TopicEventBulkResponse], error)
	// Sends job back to the app's endpoint at trigger time.
	OnJobEventAlpha1(context.Context, *connect.Request[v11.JobEventRequest]) (*connect.Response[v11.JobEventResponse], error)
}

AppCallbackAlphaHandler is an implementation of the dapr.proto.runtime.v1.AppCallbackAlpha service.

type AppCallbackClient 

type AppCallbackClient interface {
	// Invokes service method with InvokeRequest.
	OnInvoke(context.Context, *connect.Request[v1.InvokeRequest]) (*connect.Response[v1.InvokeResponse], error)
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.ListTopicSubscriptionsResponse], error)
	// Subscribes events from Pubsub
	OnTopicEvent(context.Context, *connect.Request[v11.TopicEventRequest]) (*connect.Response[v11.TopicEventResponse], error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.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, *connect.Request[v11.BindingEventRequest]) (*connect.Response[v11.BindingEventResponse], error)
	// Subscribes bulk events from Pubsub
	OnBulkTopicEvent(context.Context, *connect.Request[v11.TopicEventBulkRequest]) (*connect.Response[v11.TopicEventBulkResponse], error)
}

AppCallbackClient is a client for the dapr.proto.runtime.v1.AppCallback service.

func NewAppCallbackClient 

func NewAppCallbackClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AppCallbackClient

NewAppCallbackClient constructs a client for the dapr.proto.runtime.v1.AppCallback service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AppCallbackHandler 

type AppCallbackHandler interface {
	// Invokes service method with InvokeRequest.
	OnInvoke(context.Context, *connect.Request[v1.InvokeRequest]) (*connect.Response[v1.InvokeResponse], error)
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.ListTopicSubscriptionsResponse], error)
	// Subscribes events from Pubsub
	OnTopicEvent(context.Context, *connect.Request[v11.TopicEventRequest]) (*connect.Response[v11.TopicEventResponse], error)
	// Lists all input bindings subscribed by this app.
	ListInputBindings(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.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, *connect.Request[v11.BindingEventRequest]) (*connect.Response[v11.BindingEventResponse], error)
	// Subscribes bulk events from Pubsub
	OnBulkTopicEvent(context.Context, *connect.Request[v11.TopicEventBulkRequest]) (*connect.Response[v11.TopicEventBulkResponse], error)
}

AppCallbackHandler is an implementation of the dapr.proto.runtime.v1.AppCallback service.

type AppCallbackHealthCheckClient 

type AppCallbackHealthCheckClient interface {
	// Health check.
	HealthCheck(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.HealthCheckResponse], error)
}

AppCallbackHealthCheckClient is a client for the dapr.proto.runtime.v1.AppCallbackHealthCheck service.

func NewAppCallbackHealthCheckClient 

func NewAppCallbackHealthCheckClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AppCallbackHealthCheckClient

NewAppCallbackHealthCheckClient constructs a client for the dapr.proto.runtime.v1.AppCallbackHealthCheck service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AppCallbackHealthCheckHandler 

type AppCallbackHealthCheckHandler interface {
	// Health check.
	HealthCheck(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.HealthCheckResponse], error)
}

AppCallbackHealthCheckHandler is an implementation of the dapr.proto.runtime.v1.AppCallbackHealthCheck service.

type DaprClient 

type DaprClient interface {
	// Invokes a method on a remote Dapr app.
	// Deprecated: Use proxy mode service invocation instead.
	InvokeService(context.Context, *connect.Request[v1.InvokeServiceRequest]) (*connect.Response[v11.InvokeResponse], error)
	// Gets the state for a specific key.
	GetState(context.Context, *connect.Request[v1.GetStateRequest]) (*connect.Response[v1.GetStateResponse], error)
	// Gets a bulk of state items for a list of keys
	GetBulkState(context.Context, *connect.Request[v1.GetBulkStateRequest]) (*connect.Response[v1.GetBulkStateResponse], error)
	// Saves the state for a specific key.
	SaveState(context.Context, *connect.Request[v1.SaveStateRequest]) (*connect.Response[emptypb.Empty], error)
	// Queries the state.
	QueryStateAlpha1(context.Context, *connect.Request[v1.QueryStateRequest]) (*connect.Response[v1.QueryStateResponse], error)
	// Deletes the state for a specific key.
	DeleteState(context.Context, *connect.Request[v1.DeleteStateRequest]) (*connect.Response[emptypb.Empty], error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(context.Context, *connect.Request[v1.DeleteBulkStateRequest]) (*connect.Response[emptypb.Empty], error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(context.Context, *connect.Request[v1.ExecuteStateTransactionRequest]) (*connect.Response[emptypb.Empty], error)
	// Publishes events to the specific topic.
	PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[emptypb.Empty], error)
	// Deprecated: Bulk Publishes multiple events to the specified topic.
	//
	// Deprecated: do not use.
	BulkPublishEventAlpha1(context.Context, *connect.Request[v1.BulkPublishRequest]) (*connect.Response[v1.BulkPublishResponse], error)
	// Bulk Publishes multiple events to the specified topic.
	BulkPublishEvent(context.Context, *connect.Request[v1.BulkPublishRequest]) (*connect.Response[v1.BulkPublishResponse], error)
	// SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
	// events from it.
	SubscribeTopicEventsAlpha1(context.Context) *connect.BidiStreamForClient[v1.SubscribeTopicEventsRequestAlpha1, v1.SubscribeTopicEventsResponseAlpha1]
	// Invokes binding data to specific output bindings
	InvokeBinding(context.Context, *connect.Request[v1.InvokeBindingRequest]) (*connect.Response[v1.InvokeBindingResponse], error)
	// Gets secrets from secret stores.
	GetSecret(context.Context, *connect.Request[v1.GetSecretRequest]) (*connect.Response[v1.GetSecretResponse], error)
	// Gets a bulk of secrets
	GetBulkSecret(context.Context, *connect.Request[v1.GetBulkSecretRequest]) (*connect.Response[v1.GetBulkSecretResponse], error)
	// Register an actor timer.
	RegisterActorTimer(context.Context, *connect.Request[v1.RegisterActorTimerRequest]) (*connect.Response[emptypb.Empty], error)
	// Unregister an actor timer.
	UnregisterActorTimer(context.Context, *connect.Request[v1.UnregisterActorTimerRequest]) (*connect.Response[emptypb.Empty], error)
	// Register an actor reminder.
	RegisterActorReminder(context.Context, *connect.Request[v1.RegisterActorReminderRequest]) (*connect.Response[emptypb.Empty], error)
	// Unregister an actor reminder.
	UnregisterActorReminder(context.Context, *connect.Request[v1.UnregisterActorReminderRequest]) (*connect.Response[emptypb.Empty], error)
	UnregisterActorRemindersByType(context.Context, *connect.Request[v1.UnregisterActorRemindersByTypeRequest]) (*connect.Response[v1.UnregisterActorRemindersByTypeResponse], error)
	ListActorReminders(context.Context, *connect.Request[v1.ListActorRemindersRequest]) (*connect.Response[v1.ListActorRemindersResponse], error)
	// Gets the state for a specific actor.
	GetActorState(context.Context, *connect.Request[v1.GetActorStateRequest]) (*connect.Response[v1.GetActorStateResponse], error)
	// Gets an actor reminder.
	GetActorReminder(context.Context, *connect.Request[v1.GetActorReminderRequest]) (*connect.Response[v1.GetActorReminderResponse], error)
	// Executes state transactions for a specified actor
	ExecuteActorStateTransaction(context.Context, *connect.Request[v1.ExecuteActorStateTransactionRequest]) (*connect.Response[emptypb.Empty], error)
	// InvokeActor calls a method on an actor.
	InvokeActor(context.Context, *connect.Request[v1.InvokeActorRequest]) (*connect.Response[v1.InvokeActorResponse], error)
	// GetConfiguration gets configuration from configuration store.
	GetConfigurationAlpha1(context.Context, *connect.Request[v1.GetConfigurationRequest]) (*connect.Response[v1.GetConfigurationResponse], error)
	// GetConfiguration gets configuration from configuration store.
	GetConfiguration(context.Context, *connect.Request[v1.GetConfigurationRequest]) (*connect.Response[v1.GetConfigurationResponse], error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfigurationAlpha1(context.Context, *connect.Request[v1.SubscribeConfigurationRequest]) (*connect.ServerStreamForClient[v1.SubscribeConfigurationResponse], error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfiguration(context.Context, *connect.Request[v1.SubscribeConfigurationRequest]) (*connect.ServerStreamForClient[v1.SubscribeConfigurationResponse], error)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfigurationAlpha1(context.Context, *connect.Request[v1.UnsubscribeConfigurationRequest]) (*connect.Response[v1.UnsubscribeConfigurationResponse], error)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfiguration(context.Context, *connect.Request[v1.UnsubscribeConfigurationRequest]) (*connect.Response[v1.UnsubscribeConfigurationResponse], error)
	// TryLockAlpha1 tries to get a lock with an expiry.
	TryLockAlpha1(context.Context, *connect.Request[v1.TryLockRequest]) (*connect.Response[v1.TryLockResponse], error)
	// UnlockAlpha1 unlocks a lock.
	UnlockAlpha1(context.Context, *connect.Request[v1.UnlockRequest]) (*connect.Response[v1.UnlockResponse], error)
	// EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
	EncryptAlpha1(context.Context) *connect.BidiStreamForClient[v1.EncryptRequest, v1.EncryptResponse]
	// DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
	DecryptAlpha1(context.Context) *connect.BidiStreamForClient[v1.DecryptRequest, v1.DecryptResponse]
	// Gets metadata of the sidecar
	GetMetadata(context.Context, *connect.Request[v1.GetMetadataRequest]) (*connect.Response[v1.GetMetadataResponse], error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(context.Context, *connect.Request[v1.SetMetadataRequest]) (*connect.Response[emptypb.Empty], error)
	// SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
	SubtleGetKeyAlpha1(context.Context, *connect.Request[v1.SubtleGetKeyRequest]) (*connect.Response[v1.SubtleGetKeyResponse], error)
	// SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
	SubtleEncryptAlpha1(context.Context, *connect.Request[v1.SubtleEncryptRequest]) (*connect.Response[v1.SubtleEncryptResponse], error)
	// SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
	SubtleDecryptAlpha1(context.Context, *connect.Request[v1.SubtleDecryptRequest]) (*connect.Response[v1.SubtleDecryptResponse], error)
	// SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
	SubtleWrapKeyAlpha1(context.Context, *connect.Request[v1.SubtleWrapKeyRequest]) (*connect.Response[v1.SubtleWrapKeyResponse], error)
	// SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
	SubtleUnwrapKeyAlpha1(context.Context, *connect.Request[v1.SubtleUnwrapKeyRequest]) (*connect.Response[v1.SubtleUnwrapKeyResponse], error)
	// SubtleSignAlpha1 signs a message using a key stored in the vault.
	SubtleSignAlpha1(context.Context, *connect.Request[v1.SubtleSignRequest]) (*connect.Response[v1.SubtleSignResponse], error)
	// SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
	SubtleVerifyAlpha1(context.Context, *connect.Request[v1.SubtleVerifyRequest]) (*connect.Response[v1.SubtleVerifyResponse], error)
	// Starts a new instance of a workflow
	//
	// Deprecated: do not use.
	StartWorkflowAlpha1(context.Context, *connect.Request[v1.StartWorkflowRequest]) (*connect.Response[v1.StartWorkflowResponse], error)
	// Gets details about a started workflow instance
	//
	// Deprecated: do not use.
	GetWorkflowAlpha1(context.Context, *connect.Request[v1.GetWorkflowRequest]) (*connect.Response[v1.GetWorkflowResponse], error)
	// Purge Workflow
	//
	// Deprecated: do not use.
	PurgeWorkflowAlpha1(context.Context, *connect.Request[v1.PurgeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Terminates a running workflow instance
	//
	// Deprecated: do not use.
	TerminateWorkflowAlpha1(context.Context, *connect.Request[v1.TerminateWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Pauses a running workflow instance
	//
	// Deprecated: do not use.
	PauseWorkflowAlpha1(context.Context, *connect.Request[v1.PauseWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Resumes a paused workflow instance
	//
	// Deprecated: do not use.
	ResumeWorkflowAlpha1(context.Context, *connect.Request[v1.ResumeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Raise an event to a running workflow instance
	//
	// Deprecated: do not use.
	RaiseEventWorkflowAlpha1(context.Context, *connect.Request[v1.RaiseEventWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Starts a new instance of a workflow
	StartWorkflowBeta1(context.Context, *connect.Request[v1.StartWorkflowRequest]) (*connect.Response[v1.StartWorkflowResponse], error)
	// Gets details about a started workflow instance
	GetWorkflowBeta1(context.Context, *connect.Request[v1.GetWorkflowRequest]) (*connect.Response[v1.GetWorkflowResponse], error)
	// Purge Workflow
	PurgeWorkflowBeta1(context.Context, *connect.Request[v1.PurgeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Terminates a running workflow instance
	TerminateWorkflowBeta1(context.Context, *connect.Request[v1.TerminateWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Pauses a running workflow instance
	PauseWorkflowBeta1(context.Context, *connect.Request[v1.PauseWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Resumes a paused workflow instance
	ResumeWorkflowBeta1(context.Context, *connect.Request[v1.ResumeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Raise an event to a running workflow instance
	RaiseEventWorkflowBeta1(context.Context, *connect.Request[v1.RaiseEventWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Shutdown the sidecar
	Shutdown(context.Context, *connect.Request[v1.ShutdownRequest]) (*connect.Response[emptypb.Empty], error)
	// Create and schedule a job
	ScheduleJobAlpha1(context.Context, *connect.Request[v1.ScheduleJobRequest]) (*connect.Response[v1.ScheduleJobResponse], error)
	// Gets a scheduled job
	GetJobAlpha1(context.Context, *connect.Request[v1.GetJobRequest]) (*connect.Response[v1.GetJobResponse], error)
	// Delete a job
	DeleteJobAlpha1(context.Context, *connect.Request[v1.DeleteJobRequest]) (*connect.Response[v1.DeleteJobResponse], error)
	DeleteJobsByPrefixAlpha1(context.Context, *connect.Request[v1.DeleteJobsByPrefixRequestAlpha1]) (*connect.Response[v1.DeleteJobsByPrefixResponseAlpha1], error)
	ListJobsAlpha1(context.Context, *connect.Request[v1.ListJobsRequestAlpha1]) (*connect.Response[v1.ListJobsResponseAlpha1], error)
	// Converse with a LLM service
	ConverseAlpha1(context.Context, *connect.Request[v1.ConversationRequest]) (*connect.Response[v1.ConversationResponse], error)
	// Converse with a LLM service via alpha2 api
	ConverseAlpha2(context.Context, *connect.Request[v1.ConversationRequestAlpha2]) (*connect.Response[v1.ConversationResponseAlpha2], error)
}

DaprClient is a client for the dapr.proto.runtime.v1.Dapr service.

func NewDaprClient 

func NewDaprClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DaprClient

NewDaprClient constructs a client for the dapr.proto.runtime.v1.Dapr service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type DaprHandler 

type DaprHandler interface {
	// Invokes a method on a remote Dapr app.
	// Deprecated: Use proxy mode service invocation instead.
	InvokeService(context.Context, *connect.Request[v1.InvokeServiceRequest]) (*connect.Response[v11.InvokeResponse], error)
	// Gets the state for a specific key.
	GetState(context.Context, *connect.Request[v1.GetStateRequest]) (*connect.Response[v1.GetStateResponse], error)
	// Gets a bulk of state items for a list of keys
	GetBulkState(context.Context, *connect.Request[v1.GetBulkStateRequest]) (*connect.Response[v1.GetBulkStateResponse], error)
	// Saves the state for a specific key.
	SaveState(context.Context, *connect.Request[v1.SaveStateRequest]) (*connect.Response[emptypb.Empty], error)
	// Queries the state.
	QueryStateAlpha1(context.Context, *connect.Request[v1.QueryStateRequest]) (*connect.Response[v1.QueryStateResponse], error)
	// Deletes the state for a specific key.
	DeleteState(context.Context, *connect.Request[v1.DeleteStateRequest]) (*connect.Response[emptypb.Empty], error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(context.Context, *connect.Request[v1.DeleteBulkStateRequest]) (*connect.Response[emptypb.Empty], error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(context.Context, *connect.Request[v1.ExecuteStateTransactionRequest]) (*connect.Response[emptypb.Empty], error)
	// Publishes events to the specific topic.
	PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[emptypb.Empty], error)
	// Deprecated: Bulk Publishes multiple events to the specified topic.
	//
	// Deprecated: do not use.
	BulkPublishEventAlpha1(context.Context, *connect.Request[v1.BulkPublishRequest]) (*connect.Response[v1.BulkPublishResponse], error)
	// Bulk Publishes multiple events to the specified topic.
	BulkPublishEvent(context.Context, *connect.Request[v1.BulkPublishRequest]) (*connect.Response[v1.BulkPublishResponse], error)
	// SubscribeTopicEventsAlpha1 subscribes to a PubSub topic and receives topic
	// events from it.
	SubscribeTopicEventsAlpha1(context.Context, *connect.BidiStream[v1.SubscribeTopicEventsRequestAlpha1, v1.SubscribeTopicEventsResponseAlpha1]) error
	// Invokes binding data to specific output bindings
	InvokeBinding(context.Context, *connect.Request[v1.InvokeBindingRequest]) (*connect.Response[v1.InvokeBindingResponse], error)
	// Gets secrets from secret stores.
	GetSecret(context.Context, *connect.Request[v1.GetSecretRequest]) (*connect.Response[v1.GetSecretResponse], error)
	// Gets a bulk of secrets
	GetBulkSecret(context.Context, *connect.Request[v1.GetBulkSecretRequest]) (*connect.Response[v1.GetBulkSecretResponse], error)
	// Register an actor timer.
	RegisterActorTimer(context.Context, *connect.Request[v1.RegisterActorTimerRequest]) (*connect.Response[emptypb.Empty], error)
	// Unregister an actor timer.
	UnregisterActorTimer(context.Context, *connect.Request[v1.UnregisterActorTimerRequest]) (*connect.Response[emptypb.Empty], error)
	// Register an actor reminder.
	RegisterActorReminder(context.Context, *connect.Request[v1.RegisterActorReminderRequest]) (*connect.Response[emptypb.Empty], error)
	// Unregister an actor reminder.
	UnregisterActorReminder(context.Context, *connect.Request[v1.UnregisterActorReminderRequest]) (*connect.Response[emptypb.Empty], error)
	UnregisterActorRemindersByType(context.Context, *connect.Request[v1.UnregisterActorRemindersByTypeRequest]) (*connect.Response[v1.UnregisterActorRemindersByTypeResponse], error)
	ListActorReminders(context.Context, *connect.Request[v1.ListActorRemindersRequest]) (*connect.Response[v1.ListActorRemindersResponse], error)
	// Gets the state for a specific actor.
	GetActorState(context.Context, *connect.Request[v1.GetActorStateRequest]) (*connect.Response[v1.GetActorStateResponse], error)
	// Gets an actor reminder.
	GetActorReminder(context.Context, *connect.Request[v1.GetActorReminderRequest]) (*connect.Response[v1.GetActorReminderResponse], error)
	// Executes state transactions for a specified actor
	ExecuteActorStateTransaction(context.Context, *connect.Request[v1.ExecuteActorStateTransactionRequest]) (*connect.Response[emptypb.Empty], error)
	// InvokeActor calls a method on an actor.
	InvokeActor(context.Context, *connect.Request[v1.InvokeActorRequest]) (*connect.Response[v1.InvokeActorResponse], error)
	// GetConfiguration gets configuration from configuration store.
	GetConfigurationAlpha1(context.Context, *connect.Request[v1.GetConfigurationRequest]) (*connect.Response[v1.GetConfigurationResponse], error)
	// GetConfiguration gets configuration from configuration store.
	GetConfiguration(context.Context, *connect.Request[v1.GetConfigurationRequest]) (*connect.Response[v1.GetConfigurationResponse], error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfigurationAlpha1(context.Context, *connect.Request[v1.SubscribeConfigurationRequest], *connect.ServerStream[v1.SubscribeConfigurationResponse]) error
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates event by grpc stream
	SubscribeConfiguration(context.Context, *connect.Request[v1.SubscribeConfigurationRequest], *connect.ServerStream[v1.SubscribeConfigurationResponse]) error
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfigurationAlpha1(context.Context, *connect.Request[v1.UnsubscribeConfigurationRequest]) (*connect.Response[v1.UnsubscribeConfigurationResponse], error)
	// UnSubscribeConfiguration unsubscribe the subscription of configuration
	UnsubscribeConfiguration(context.Context, *connect.Request[v1.UnsubscribeConfigurationRequest]) (*connect.Response[v1.UnsubscribeConfigurationResponse], error)
	// TryLockAlpha1 tries to get a lock with an expiry.
	TryLockAlpha1(context.Context, *connect.Request[v1.TryLockRequest]) (*connect.Response[v1.TryLockResponse], error)
	// UnlockAlpha1 unlocks a lock.
	UnlockAlpha1(context.Context, *connect.Request[v1.UnlockRequest]) (*connect.Response[v1.UnlockResponse], error)
	// EncryptAlpha1 encrypts a message using the Dapr encryption scheme and a key stored in the vault.
	EncryptAlpha1(context.Context, *connect.BidiStream[v1.EncryptRequest, v1.EncryptResponse]) error
	// DecryptAlpha1 decrypts a message using the Dapr encryption scheme and a key stored in the vault.
	DecryptAlpha1(context.Context, *connect.BidiStream[v1.DecryptRequest, v1.DecryptResponse]) error
	// Gets metadata of the sidecar
	GetMetadata(context.Context, *connect.Request[v1.GetMetadataRequest]) (*connect.Response[v1.GetMetadataResponse], error)
	// Sets value in extended metadata of the sidecar
	SetMetadata(context.Context, *connect.Request[v1.SetMetadataRequest]) (*connect.Response[emptypb.Empty], error)
	// SubtleGetKeyAlpha1 returns the public part of an asymmetric key stored in the vault.
	SubtleGetKeyAlpha1(context.Context, *connect.Request[v1.SubtleGetKeyRequest]) (*connect.Response[v1.SubtleGetKeyResponse], error)
	// SubtleEncryptAlpha1 encrypts a small message using a key stored in the vault.
	SubtleEncryptAlpha1(context.Context, *connect.Request[v1.SubtleEncryptRequest]) (*connect.Response[v1.SubtleEncryptResponse], error)
	// SubtleDecryptAlpha1 decrypts a small message using a key stored in the vault.
	SubtleDecryptAlpha1(context.Context, *connect.Request[v1.SubtleDecryptRequest]) (*connect.Response[v1.SubtleDecryptResponse], error)
	// SubtleWrapKeyAlpha1 wraps a key using a key stored in the vault.
	SubtleWrapKeyAlpha1(context.Context, *connect.Request[v1.SubtleWrapKeyRequest]) (*connect.Response[v1.SubtleWrapKeyResponse], error)
	// SubtleUnwrapKeyAlpha1 unwraps a key using a key stored in the vault.
	SubtleUnwrapKeyAlpha1(context.Context, *connect.Request[v1.SubtleUnwrapKeyRequest]) (*connect.Response[v1.SubtleUnwrapKeyResponse], error)
	// SubtleSignAlpha1 signs a message using a key stored in the vault.
	SubtleSignAlpha1(context.Context, *connect.Request[v1.SubtleSignRequest]) (*connect.Response[v1.SubtleSignResponse], error)
	// SubtleVerifyAlpha1 verifies the signature of a message using a key stored in the vault.
	SubtleVerifyAlpha1(context.Context, *connect.Request[v1.SubtleVerifyRequest]) (*connect.Response[v1.SubtleVerifyResponse], error)
	// Starts a new instance of a workflow
	//
	// Deprecated: do not use.
	StartWorkflowAlpha1(context.Context, *connect.Request[v1.StartWorkflowRequest]) (*connect.Response[v1.StartWorkflowResponse], error)
	// Gets details about a started workflow instance
	//
	// Deprecated: do not use.
	GetWorkflowAlpha1(context.Context, *connect.Request[v1.GetWorkflowRequest]) (*connect.Response[v1.GetWorkflowResponse], error)
	// Purge Workflow
	//
	// Deprecated: do not use.
	PurgeWorkflowAlpha1(context.Context, *connect.Request[v1.PurgeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Terminates a running workflow instance
	//
	// Deprecated: do not use.
	TerminateWorkflowAlpha1(context.Context, *connect.Request[v1.TerminateWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Pauses a running workflow instance
	//
	// Deprecated: do not use.
	PauseWorkflowAlpha1(context.Context, *connect.Request[v1.PauseWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Resumes a paused workflow instance
	//
	// Deprecated: do not use.
	ResumeWorkflowAlpha1(context.Context, *connect.Request[v1.ResumeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Raise an event to a running workflow instance
	//
	// Deprecated: do not use.
	RaiseEventWorkflowAlpha1(context.Context, *connect.Request[v1.RaiseEventWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Starts a new instance of a workflow
	StartWorkflowBeta1(context.Context, *connect.Request[v1.StartWorkflowRequest]) (*connect.Response[v1.StartWorkflowResponse], error)
	// Gets details about a started workflow instance
	GetWorkflowBeta1(context.Context, *connect.Request[v1.GetWorkflowRequest]) (*connect.Response[v1.GetWorkflowResponse], error)
	// Purge Workflow
	PurgeWorkflowBeta1(context.Context, *connect.Request[v1.PurgeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Terminates a running workflow instance
	TerminateWorkflowBeta1(context.Context, *connect.Request[v1.TerminateWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Pauses a running workflow instance
	PauseWorkflowBeta1(context.Context, *connect.Request[v1.PauseWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Resumes a paused workflow instance
	ResumeWorkflowBeta1(context.Context, *connect.Request[v1.ResumeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Raise an event to a running workflow instance
	RaiseEventWorkflowBeta1(context.Context, *connect.Request[v1.RaiseEventWorkflowRequest]) (*connect.Response[emptypb.Empty], error)
	// Shutdown the sidecar
	Shutdown(context.Context, *connect.Request[v1.ShutdownRequest]) (*connect.Response[emptypb.Empty], error)
	// Create and schedule a job
	ScheduleJobAlpha1(context.Context, *connect.Request[v1.ScheduleJobRequest]) (*connect.Response[v1.ScheduleJobResponse], error)
	// Gets a scheduled job
	GetJobAlpha1(context.Context, *connect.Request[v1.GetJobRequest]) (*connect.Response[v1.GetJobResponse], error)
	// Delete a job
	DeleteJobAlpha1(context.Context, *connect.Request[v1.DeleteJobRequest]) (*connect.Response[v1.DeleteJobResponse], error)
	DeleteJobsByPrefixAlpha1(context.Context, *connect.Request[v1.DeleteJobsByPrefixRequestAlpha1]) (*connect.Response[v1.DeleteJobsByPrefixResponseAlpha1], error)
	ListJobsAlpha1(context.Context, *connect.Request[v1.ListJobsRequestAlpha1]) (*connect.Response[v1.ListJobsResponseAlpha1], error)
	// Converse with a LLM service
	ConverseAlpha1(context.Context, *connect.Request[v1.ConversationRequest]) (*connect.Response[v1.ConversationResponse], error)
	// Converse with a LLM service via alpha2 api
	ConverseAlpha2(context.Context, *connect.Request[v1.ConversationRequestAlpha2]) (*connect.Response[v1.ConversationResponseAlpha2], error)
}

DaprHandler is an implementation of the dapr.proto.runtime.v1.Dapr service.

type UnimplementedAppCallbackAlphaHandler 

type UnimplementedAppCallbackAlphaHandler struct{}

UnimplementedAppCallbackAlphaHandler returns CodeUnimplemented from all methods.

func (UnimplementedAppCallbackAlphaHandler) OnBulkTopicEventAlpha1 

func (UnimplementedAppCallbackAlphaHandler) OnBulkTopicEventAlpha1(context.Context, *connect.Request[v11.TopicEventBulkRequest]) (*connect.Response[v11.TopicEventBulkResponse], error)

func (UnimplementedAppCallbackAlphaHandler) OnJobEventAlpha1 

func (UnimplementedAppCallbackAlphaHandler) OnJobEventAlpha1(context.Context, *connect.Request[v11.JobEventRequest]) (*connect.Response[v11.JobEventResponse], error)

type UnimplementedAppCallbackHandler 

type UnimplementedAppCallbackHandler struct{}

UnimplementedAppCallbackHandler returns CodeUnimplemented from all methods.

func (UnimplementedAppCallbackHandler) ListInputBindings 

func (UnimplementedAppCallbackHandler) ListInputBindings(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.ListInputBindingsResponse], error)

func (UnimplementedAppCallbackHandler) ListTopicSubscriptions 

func (UnimplementedAppCallbackHandler) ListTopicSubscriptions(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.ListTopicSubscriptionsResponse], error)

func (UnimplementedAppCallbackHandler) OnBindingEvent 

func (UnimplementedAppCallbackHandler) OnBindingEvent(context.Context, *connect.Request[v11.BindingEventRequest]) (*connect.Response[v11.BindingEventResponse], error)

func (UnimplementedAppCallbackHandler) OnBulkTopicEvent 

func (UnimplementedAppCallbackHandler) OnBulkTopicEvent(context.Context, *connect.Request[v11.TopicEventBulkRequest]) (*connect.Response[v11.TopicEventBulkResponse], error)

func (UnimplementedAppCallbackHandler) OnInvoke 

func (UnimplementedAppCallbackHandler) OnInvoke(context.Context, *connect.Request[v1.InvokeRequest]) (*connect.Response[v1.InvokeResponse], error)

func (UnimplementedAppCallbackHandler) OnTopicEvent 

func (UnimplementedAppCallbackHandler) OnTopicEvent(context.Context, *connect.Request[v11.TopicEventRequest]) (*connect.Response[v11.TopicEventResponse], error)

type UnimplementedAppCallbackHealthCheckHandler 

type UnimplementedAppCallbackHealthCheckHandler struct{}

UnimplementedAppCallbackHealthCheckHandler returns CodeUnimplemented from all methods.

func (UnimplementedAppCallbackHealthCheckHandler) HealthCheck 

func (UnimplementedAppCallbackHealthCheckHandler) HealthCheck(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v11.HealthCheckResponse], error)

type UnimplementedDaprHandler 

type UnimplementedDaprHandler struct{}

UnimplementedDaprHandler returns CodeUnimplemented from all methods.

func (UnimplementedDaprHandler) BulkPublishEvent 

func (UnimplementedDaprHandler) BulkPublishEvent(context.Context, *connect.Request[v1.BulkPublishRequest]) (*connect.Response[v1.BulkPublishResponse], error)

func (UnimplementedDaprHandler) BulkPublishEventAlpha1 

func (UnimplementedDaprHandler) BulkPublishEventAlpha1(context.Context, *connect.Request[v1.BulkPublishRequest]) (*connect.Response[v1.BulkPublishResponse], error)

func (UnimplementedDaprHandler) ConverseAlpha1 

func (UnimplementedDaprHandler) ConverseAlpha1(context.Context, *connect.Request[v1.ConversationRequest]) (*connect.Response[v1.ConversationResponse], error)

func (UnimplementedDaprHandler) ConverseAlpha2 

func (UnimplementedDaprHandler) ConverseAlpha2(context.Context, *connect.Request[v1.ConversationRequestAlpha2]) (*connect.Response[v1.ConversationResponseAlpha2], error)

func (UnimplementedDaprHandler) DecryptAlpha1 

func (UnimplementedDaprHandler) DecryptAlpha1(context.Context, *connect.BidiStream[v1.DecryptRequest, v1.DecryptResponse]) error

func (UnimplementedDaprHandler) DeleteBulkState 

func (UnimplementedDaprHandler) DeleteBulkState(context.Context, *connect.Request[v1.DeleteBulkStateRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) DeleteJobAlpha1 

func (UnimplementedDaprHandler) DeleteJobAlpha1(context.Context, *connect.Request[v1.DeleteJobRequest]) (*connect.Response[v1.DeleteJobResponse], error)

func (UnimplementedDaprHandler) DeleteJobsByPrefixAlpha1 

func (UnimplementedDaprHandler) DeleteJobsByPrefixAlpha1(context.Context, *connect.Request[v1.DeleteJobsByPrefixRequestAlpha1]) (*connect.Response[v1.DeleteJobsByPrefixResponseAlpha1], error)

func (UnimplementedDaprHandler) DeleteState 

func (UnimplementedDaprHandler) DeleteState(context.Context, *connect.Request[v1.DeleteStateRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) EncryptAlpha1 

func (UnimplementedDaprHandler) EncryptAlpha1(context.Context, *connect.BidiStream[v1.EncryptRequest, v1.EncryptResponse]) error

func (UnimplementedDaprHandler) ExecuteActorStateTransaction 

func (UnimplementedDaprHandler) ExecuteActorStateTransaction(context.Context, *connect.Request[v1.ExecuteActorStateTransactionRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) ExecuteStateTransaction 

func (UnimplementedDaprHandler) ExecuteStateTransaction(context.Context, *connect.Request[v1.ExecuteStateTransactionRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) GetActorReminder 

func (UnimplementedDaprHandler) GetActorReminder(context.Context, *connect.Request[v1.GetActorReminderRequest]) (*connect.Response[v1.GetActorReminderResponse], error)

func (UnimplementedDaprHandler) GetActorState 

func (UnimplementedDaprHandler) GetActorState(context.Context, *connect.Request[v1.GetActorStateRequest]) (*connect.Response[v1.GetActorStateResponse], error)

func (UnimplementedDaprHandler) GetBulkSecret 

func (UnimplementedDaprHandler) GetBulkSecret(context.Context, *connect.Request[v1.GetBulkSecretRequest]) (*connect.Response[v1.GetBulkSecretResponse], error)

func (UnimplementedDaprHandler) GetBulkState 

func (UnimplementedDaprHandler) GetBulkState(context.Context, *connect.Request[v1.GetBulkStateRequest]) (*connect.Response[v1.GetBulkStateResponse], error)

func (UnimplementedDaprHandler) GetConfiguration 

func (UnimplementedDaprHandler) GetConfiguration(context.Context, *connect.Request[v1.GetConfigurationRequest]) (*connect.Response[v1.GetConfigurationResponse], error)

func (UnimplementedDaprHandler) GetConfigurationAlpha1 

func (UnimplementedDaprHandler) GetConfigurationAlpha1(context.Context, *connect.Request[v1.GetConfigurationRequest]) (*connect.Response[v1.GetConfigurationResponse], error)

func (UnimplementedDaprHandler) GetJobAlpha1 

func (UnimplementedDaprHandler) GetJobAlpha1(context.Context, *connect.Request[v1.GetJobRequest]) (*connect.Response[v1.GetJobResponse], error)

func (UnimplementedDaprHandler) GetMetadata 

func (UnimplementedDaprHandler) GetMetadata(context.Context, *connect.Request[v1.GetMetadataRequest]) (*connect.Response[v1.GetMetadataResponse], error)

func (UnimplementedDaprHandler) GetSecret 

func (UnimplementedDaprHandler) GetSecret(context.Context, *connect.Request[v1.GetSecretRequest]) (*connect.Response[v1.GetSecretResponse], error)

func (UnimplementedDaprHandler) GetState 

func (UnimplementedDaprHandler) GetState(context.Context, *connect.Request[v1.GetStateRequest]) (*connect.Response[v1.GetStateResponse], error)

func (UnimplementedDaprHandler) GetWorkflowAlpha1 

func (UnimplementedDaprHandler) GetWorkflowAlpha1(context.Context, *connect.Request[v1.GetWorkflowRequest]) (*connect.Response[v1.GetWorkflowResponse], error)

func (UnimplementedDaprHandler) GetWorkflowBeta1 

func (UnimplementedDaprHandler) GetWorkflowBeta1(context.Context, *connect.Request[v1.GetWorkflowRequest]) (*connect.Response[v1.GetWorkflowResponse], error)

func (UnimplementedDaprHandler) InvokeActor 

func (UnimplementedDaprHandler) InvokeActor(context.Context, *connect.Request[v1.InvokeActorRequest]) (*connect.Response[v1.InvokeActorResponse], error)

func (UnimplementedDaprHandler) InvokeBinding 

func (UnimplementedDaprHandler) InvokeBinding(context.Context, *connect.Request[v1.InvokeBindingRequest]) (*connect.Response[v1.InvokeBindingResponse], error)

func (UnimplementedDaprHandler) InvokeService 

func (UnimplementedDaprHandler) InvokeService(context.Context, *connect.Request[v1.InvokeServiceRequest]) (*connect.Response[v11.InvokeResponse], error)

func (UnimplementedDaprHandler) ListActorReminders 

func (UnimplementedDaprHandler) ListActorReminders(context.Context, *connect.Request[v1.ListActorRemindersRequest]) (*connect.Response[v1.ListActorRemindersResponse], error)

func (UnimplementedDaprHandler) ListJobsAlpha1 

func (UnimplementedDaprHandler) ListJobsAlpha1(context.Context, *connect.Request[v1.ListJobsRequestAlpha1]) (*connect.Response[v1.ListJobsResponseAlpha1], error)

func (UnimplementedDaprHandler) PauseWorkflowAlpha1 

func (UnimplementedDaprHandler) PauseWorkflowAlpha1(context.Context, *connect.Request[v1.PauseWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) PauseWorkflowBeta1 

func (UnimplementedDaprHandler) PauseWorkflowBeta1(context.Context, *connect.Request[v1.PauseWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) PublishEvent 

func (UnimplementedDaprHandler) PublishEvent(context.Context, *connect.Request[v1.PublishEventRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) PurgeWorkflowAlpha1 

func (UnimplementedDaprHandler) PurgeWorkflowAlpha1(context.Context, *connect.Request[v1.PurgeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) PurgeWorkflowBeta1 

func (UnimplementedDaprHandler) PurgeWorkflowBeta1(context.Context, *connect.Request[v1.PurgeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) QueryStateAlpha1 

func (UnimplementedDaprHandler) QueryStateAlpha1(context.Context, *connect.Request[v1.QueryStateRequest]) (*connect.Response[v1.QueryStateResponse], error)

func (UnimplementedDaprHandler) RaiseEventWorkflowAlpha1 

func (UnimplementedDaprHandler) RaiseEventWorkflowAlpha1(context.Context, *connect.Request[v1.RaiseEventWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) RaiseEventWorkflowBeta1 

func (UnimplementedDaprHandler) RaiseEventWorkflowBeta1(context.Context, *connect.Request[v1.RaiseEventWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) RegisterActorReminder 

func (UnimplementedDaprHandler) RegisterActorReminder(context.Context, *connect.Request[v1.RegisterActorReminderRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) RegisterActorTimer 

func (UnimplementedDaprHandler) RegisterActorTimer(context.Context, *connect.Request[v1.RegisterActorTimerRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) ResumeWorkflowAlpha1 

func (UnimplementedDaprHandler) ResumeWorkflowAlpha1(context.Context, *connect.Request[v1.ResumeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) ResumeWorkflowBeta1 

func (UnimplementedDaprHandler) ResumeWorkflowBeta1(context.Context, *connect.Request[v1.ResumeWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) SaveState 

func (UnimplementedDaprHandler) SaveState(context.Context, *connect.Request[v1.SaveStateRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) ScheduleJobAlpha1 

func (UnimplementedDaprHandler) ScheduleJobAlpha1(context.Context, *connect.Request[v1.ScheduleJobRequest]) (*connect.Response[v1.ScheduleJobResponse], error)

func (UnimplementedDaprHandler) SetMetadata 

func (UnimplementedDaprHandler) SetMetadata(context.Context, *connect.Request[v1.SetMetadataRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) Shutdown 

func (UnimplementedDaprHandler) Shutdown(context.Context, *connect.Request[v1.ShutdownRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) StartWorkflowAlpha1 

func (UnimplementedDaprHandler) StartWorkflowAlpha1(context.Context, *connect.Request[v1.StartWorkflowRequest]) (*connect.Response[v1.StartWorkflowResponse], error)

func (UnimplementedDaprHandler) StartWorkflowBeta1 

func (UnimplementedDaprHandler) StartWorkflowBeta1(context.Context, *connect.Request[v1.StartWorkflowRequest]) (*connect.Response[v1.StartWorkflowResponse], error)

func (UnimplementedDaprHandler) SubscribeConfiguration 

func (UnimplementedDaprHandler) SubscribeConfiguration(context.Context, *connect.Request[v1.SubscribeConfigurationRequest], *connect.ServerStream[v1.SubscribeConfigurationResponse]) error

func (UnimplementedDaprHandler) SubscribeConfigurationAlpha1 

func (UnimplementedDaprHandler) SubscribeConfigurationAlpha1(context.Context, *connect.Request[v1.SubscribeConfigurationRequest], *connect.ServerStream[v1.SubscribeConfigurationResponse]) error

func (UnimplementedDaprHandler) SubscribeTopicEventsAlpha1 

func (UnimplementedDaprHandler) SubscribeTopicEventsAlpha1(context.Context, *connect.BidiStream[v1.SubscribeTopicEventsRequestAlpha1, v1.SubscribeTopicEventsResponseAlpha1]) error

func (UnimplementedDaprHandler) SubtleDecryptAlpha1 

func (UnimplementedDaprHandler) SubtleDecryptAlpha1(context.Context, *connect.Request[v1.SubtleDecryptRequest]) (*connect.Response[v1.SubtleDecryptResponse], error)

func (UnimplementedDaprHandler) SubtleEncryptAlpha1 

func (UnimplementedDaprHandler) SubtleEncryptAlpha1(context.Context, *connect.Request[v1.SubtleEncryptRequest]) (*connect.Response[v1.SubtleEncryptResponse], error)

func (UnimplementedDaprHandler) SubtleGetKeyAlpha1 

func (UnimplementedDaprHandler) SubtleGetKeyAlpha1(context.Context, *connect.Request[v1.SubtleGetKeyRequest]) (*connect.Response[v1.SubtleGetKeyResponse], error)

func (UnimplementedDaprHandler) SubtleSignAlpha1 

func (UnimplementedDaprHandler) SubtleSignAlpha1(context.Context, *connect.Request[v1.SubtleSignRequest]) (*connect.Response[v1.SubtleSignResponse], error)

func (UnimplementedDaprHandler) SubtleUnwrapKeyAlpha1 

func (UnimplementedDaprHandler) SubtleUnwrapKeyAlpha1(context.Context, *connect.Request[v1.SubtleUnwrapKeyRequest]) (*connect.Response[v1.SubtleUnwrapKeyResponse], error)

func (UnimplementedDaprHandler) SubtleVerifyAlpha1 

func (UnimplementedDaprHandler) SubtleVerifyAlpha1(context.Context, *connect.Request[v1.SubtleVerifyRequest]) (*connect.Response[v1.SubtleVerifyResponse], error)

func (UnimplementedDaprHandler) SubtleWrapKeyAlpha1 

func (UnimplementedDaprHandler) SubtleWrapKeyAlpha1(context.Context, *connect.Request[v1.SubtleWrapKeyRequest]) (*connect.Response[v1.SubtleWrapKeyResponse], error)

func (UnimplementedDaprHandler) TerminateWorkflowAlpha1 

func (UnimplementedDaprHandler) TerminateWorkflowAlpha1(context.Context, *connect.Request[v1.TerminateWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) TerminateWorkflowBeta1 

func (UnimplementedDaprHandler) TerminateWorkflowBeta1(context.Context, *connect.Request[v1.TerminateWorkflowRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) TryLockAlpha1 

func (UnimplementedDaprHandler) TryLockAlpha1(context.Context, *connect.Request[v1.TryLockRequest]) (*connect.Response[v1.TryLockResponse], error)

func (UnimplementedDaprHandler) UnlockAlpha1 

func (UnimplementedDaprHandler) UnlockAlpha1(context.Context, *connect.Request[v1.UnlockRequest]) (*connect.Response[v1.UnlockResponse], error)

func (UnimplementedDaprHandler) UnregisterActorReminder 

func (UnimplementedDaprHandler) UnregisterActorReminder(context.Context, *connect.Request[v1.UnregisterActorReminderRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) UnregisterActorRemindersByType 

func (UnimplementedDaprHandler) UnregisterActorRemindersByType(context.Context, *connect.Request[v1.UnregisterActorRemindersByTypeRequest]) (*connect.Response[v1.UnregisterActorRemindersByTypeResponse], error)

func (UnimplementedDaprHandler) UnregisterActorTimer 

func (UnimplementedDaprHandler) UnregisterActorTimer(context.Context, *connect.Request[v1.UnregisterActorTimerRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedDaprHandler) UnsubscribeConfiguration 

func (UnimplementedDaprHandler) UnsubscribeConfiguration(context.Context, *connect.Request[v1.UnsubscribeConfigurationRequest]) (*connect.Response[v1.UnsubscribeConfigurationResponse], error)

func (UnimplementedDaprHandler) UnsubscribeConfigurationAlpha1 

func (UnimplementedDaprHandler) UnsubscribeConfigurationAlpha1(context.Context, *connect.Request[v1.UnsubscribeConfigurationRequest]) (*connect.Response[v1.UnsubscribeConfigurationResponse], error)

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.