Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

runtime

package

Go to main page

Versions in this module

v0

v0.5.0

Nov 4, 2022

v0.5.0-rc

Oct 20, 2022

v0.4.0

May 12, 2022

Changes in this version

+ var AppCallback_ServiceDesc = grpc.ServiceDesc

+ var BindingEventResponse_BindingEventConcurrency_name = map[int32]string

+ var BindingEventResponse_BindingEventConcurrency_value = map[string]int32

+ var Dapr_ServiceDesc = grpc.ServiceDesc

+ var File_dapr_proto_runtime_v1_appcallback_proto protoreflect.FileDescriptor

+ var File_dapr_proto_runtime_v1_dapr_proto protoreflect.FileDescriptor

+ var TopicEventResponse_TopicEventResponseStatus_name = map[int32]string

+ var TopicEventResponse_TopicEventResponseStatus_value = map[string]int32

+ func RegisterAppCallbackServer(s grpc.ServiceRegistrar, srv AppCallbackServer)

+ func RegisterDaprServer(s grpc.ServiceRegistrar, srv DaprServer)

+ type ActiveActorsCount struct

+ Count int32

+ Type string

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

+ func (*ActiveActorsCount) ProtoMessage()

+ func (x *ActiveActorsCount) GetCount() int32

+ func (x *ActiveActorsCount) GetType() string

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

+ func (x *ActiveActorsCount) Reset()

+ func (x *ActiveActorsCount) String() string

+ type AppCallbackClient interface

+ ListInputBindings func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListInputBindingsResponse, error)

+ ListTopicSubscriptions func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)

+ OnBindingEvent func(ctx context.Context, in *BindingEventRequest, opts ...grpc.CallOption) (*BindingEventResponse, error)

+ OnInvoke func(ctx context.Context, in *v1.InvokeRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)

+ OnTopicEvent func(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error)

+ func NewAppCallbackClient(cc grpc.ClientConnInterface) AppCallbackClient

+ type AppCallbackServer interface

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

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

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

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

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

+ type BindingEventRequest struct

+ Data []byte

+ Metadata map[string]string

+ Name string

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

+ func (*BindingEventRequest) ProtoMessage()

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

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

+ func (x *BindingEventRequest) GetName() string

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

+ func (x *BindingEventRequest) Reset()

+ func (x *BindingEventRequest) String() string

+ type BindingEventResponse struct

+ Concurrency BindingEventResponse_BindingEventConcurrency

+ Data []byte

+ States []*v1.StateItem

+ StoreName string

+ To []string

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

+ func (*BindingEventResponse) ProtoMessage()

+ func (x *BindingEventResponse) GetConcurrency() BindingEventResponse_BindingEventConcurrency

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

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

+ func (x *BindingEventResponse) GetStoreName() string

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

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

+ func (x *BindingEventResponse) Reset()

+ func (x *BindingEventResponse) String() string

+ type BindingEventResponse_BindingEventConcurrency int32

+ const BindingEventResponse_PARALLEL

+ const BindingEventResponse_SEQUENTIAL

+ func (BindingEventResponse_BindingEventConcurrency) Descriptor() protoreflect.EnumDescriptor

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

+ func (BindingEventResponse_BindingEventConcurrency) Type() protoreflect.EnumType

+ func (x BindingEventResponse_BindingEventConcurrency) Enum() *BindingEventResponse_BindingEventConcurrency

+ func (x BindingEventResponse_BindingEventConcurrency) Number() protoreflect.EnumNumber

+ func (x BindingEventResponse_BindingEventConcurrency) String() string

+ type BulkStateItem struct

+ Data []byte

+ Error string

+ Etag string

+ Key string

+ Metadata map[string]string

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

+ func (*BulkStateItem) ProtoMessage()

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

+ func (x *BulkStateItem) GetError() string

+ func (x *BulkStateItem) GetEtag() string

+ func (x *BulkStateItem) GetKey() string

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

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

+ func (x *BulkStateItem) Reset()

+ func (x *BulkStateItem) String() string

+ type DaprClient interface

+ DeleteBulkState func(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteState func(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ExecuteActorStateTransaction func(ctx context.Context, in *ExecuteActorStateTransactionRequest, ...) (*emptypb.Empty, error)

+ ExecuteStateTransaction func(ctx context.Context, in *ExecuteStateTransactionRequest, ...) (*emptypb.Empty, error)

+ GetActorState func(ctx context.Context, in *GetActorStateRequest, opts ...grpc.CallOption) (*GetActorStateResponse, error)

+ GetBulkSecret func(ctx context.Context, in *GetBulkSecretRequest, opts ...grpc.CallOption) (*GetBulkSecretResponse, error)

+ GetBulkState func(ctx context.Context, in *GetBulkStateRequest, opts ...grpc.CallOption) (*GetBulkStateResponse, error)

+ GetConfigurationAlpha1 func(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)

+ GetMetadata func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMetadataResponse, error)

+ GetSecret func(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)

+ GetState func(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)

+ InvokeActor func(ctx context.Context, in *InvokeActorRequest, opts ...grpc.CallOption) (*InvokeActorResponse, error)

+ InvokeBinding func(ctx context.Context, in *InvokeBindingRequest, opts ...grpc.CallOption) (*InvokeBindingResponse, error)

+ InvokeService func(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*v1.InvokeResponse, error)

+ PublishEvent func(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ QueryStateAlpha1 func(ctx context.Context, in *QueryStateRequest, opts ...grpc.CallOption) (*QueryStateResponse, error)

+ RegisterActorReminder func(ctx context.Context, in *RegisterActorReminderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ RegisterActorTimer func(ctx context.Context, in *RegisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ SaveState func(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ SetMetadata func(ctx context.Context, in *SetMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Shutdown func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ SubscribeConfigurationAlpha1 func(ctx context.Context, in *SubscribeConfigurationRequest, ...) (Dapr_SubscribeConfigurationAlpha1Client, error)

+ UnregisterActorReminder func(ctx context.Context, in *UnregisterActorReminderRequest, ...) (*emptypb.Empty, error)

+ UnregisterActorTimer func(ctx context.Context, in *UnregisterActorTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewDaprClient(cc grpc.ClientConnInterface) DaprClient

+ type DaprServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ SubscribeConfigurationAlpha1 func(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationAlpha1Server) error

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

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

+ type Dapr_SubscribeConfigurationAlpha1Client interface

+ Recv func() (*SubscribeConfigurationResponse, error)

+ type Dapr_SubscribeConfigurationAlpha1Server interface

+ Send func(*SubscribeConfigurationResponse) error

+ type DeleteBulkStateRequest struct

+ States []*v1.StateItem

+ StoreName string

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

+ func (*DeleteBulkStateRequest) ProtoMessage()

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

+ func (x *DeleteBulkStateRequest) GetStoreName() string

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

+ func (x *DeleteBulkStateRequest) Reset()

+ func (x *DeleteBulkStateRequest) String() string

+ type DeleteStateRequest struct

+ Etag *v1.Etag

+ Key string

+ Metadata map[string]string

+ Options *v1.StateOptions

+ StoreName string

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

+ func (*DeleteStateRequest) ProtoMessage()

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

+ func (x *DeleteStateRequest) GetKey() string

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

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

+ func (x *DeleteStateRequest) GetStoreName() string

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

+ func (x *DeleteStateRequest) Reset()

+ func (x *DeleteStateRequest) String() string

+ type ExecuteActorStateTransactionRequest struct

+ ActorId string

+ ActorType string

+ Operations []*TransactionalActorStateOperation

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

+ func (*ExecuteActorStateTransactionRequest) ProtoMessage()

+ func (x *ExecuteActorStateTransactionRequest) GetActorId() string

+ func (x *ExecuteActorStateTransactionRequest) GetActorType() string

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

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

+ func (x *ExecuteActorStateTransactionRequest) Reset()

+ func (x *ExecuteActorStateTransactionRequest) String() string

+ type ExecuteStateTransactionRequest struct

+ Metadata map[string]string

+ Operations []*TransactionalStateOperation

+ StoreName string

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

+ func (*ExecuteStateTransactionRequest) ProtoMessage()

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

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

+ func (x *ExecuteStateTransactionRequest) GetStoreName() string

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

+ func (x *ExecuteStateTransactionRequest) Reset()

+ func (x *ExecuteStateTransactionRequest) String() string

+ type GetActorStateRequest struct

+ ActorId string

+ ActorType string

+ Key string

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

+ func (*GetActorStateRequest) ProtoMessage()

+ func (x *GetActorStateRequest) GetActorId() string

+ func (x *GetActorStateRequest) GetActorType() string

+ func (x *GetActorStateRequest) GetKey() string

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

+ func (x *GetActorStateRequest) Reset()

+ func (x *GetActorStateRequest) String() string

+ type GetActorStateResponse struct

+ Data []byte

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

+ func (*GetActorStateResponse) ProtoMessage()

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

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

+ func (x *GetActorStateResponse) Reset()

+ func (x *GetActorStateResponse) String() string

+ type GetBulkSecretRequest struct

+ Metadata map[string]string

+ StoreName string

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

+ func (*GetBulkSecretRequest) ProtoMessage()

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

+ func (x *GetBulkSecretRequest) GetStoreName() string

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

+ func (x *GetBulkSecretRequest) Reset()

+ func (x *GetBulkSecretRequest) String() string

+ type GetBulkSecretResponse struct

+ Data map[string]*SecretResponse

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

+ func (*GetBulkSecretResponse) ProtoMessage()

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

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

+ func (x *GetBulkSecretResponse) Reset()

+ func (x *GetBulkSecretResponse) String() string

+ type GetBulkStateRequest struct

+ Keys []string

+ Metadata map[string]string

+ Parallelism int32

+ StoreName string

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

+ func (*GetBulkStateRequest) ProtoMessage()

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

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

+ func (x *GetBulkStateRequest) GetParallelism() int32

+ func (x *GetBulkStateRequest) GetStoreName() string

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

+ func (x *GetBulkStateRequest) Reset()

+ func (x *GetBulkStateRequest) String() string

+ type GetBulkStateResponse struct

+ Items []*BulkStateItem

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

+ func (*GetBulkStateResponse) ProtoMessage()

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

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

+ func (x *GetBulkStateResponse) Reset()

+ func (x *GetBulkStateResponse) String() string

+ type GetConfigurationRequest struct

+ Keys []string

+ Metadata map[string]string

+ StoreName string

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

+ func (*GetConfigurationRequest) ProtoMessage()

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

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

+ func (x *GetConfigurationRequest) GetStoreName() string

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

+ func (x *GetConfigurationRequest) Reset()

+ func (x *GetConfigurationRequest) String() string

+ type GetConfigurationResponse struct

+ Items []*v1.ConfigurationItem

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

+ func (*GetConfigurationResponse) ProtoMessage()

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

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

+ func (x *GetConfigurationResponse) Reset()

+ func (x *GetConfigurationResponse) String() string

+ type GetMetadataResponse struct

+ ActiveActorsCount []*ActiveActorsCount

+ ExtendedMetadata map[string]string

+ Id string

+ RegisteredComponents []*RegisteredComponents

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

+ func (*GetMetadataResponse) ProtoMessage()

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

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

+ func (x *GetMetadataResponse) GetId() string

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

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

+ func (x *GetMetadataResponse) Reset()

+ func (x *GetMetadataResponse) String() string

+ type GetSecretRequest struct

+ Key string

+ Metadata map[string]string

+ StoreName string

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

+ func (*GetSecretRequest) ProtoMessage()

+ func (x *GetSecretRequest) GetKey() string

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

+ func (x *GetSecretRequest) GetStoreName() string

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

+ func (x *GetSecretRequest) Reset()

+ func (x *GetSecretRequest) String() string

+ type GetSecretResponse struct

+ Data map[string]string

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

+ func (*GetSecretResponse) ProtoMessage()

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

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

+ func (x *GetSecretResponse) Reset()

+ func (x *GetSecretResponse) String() string

+ type GetStateRequest struct

+ Consistency v1.StateOptions_StateConsistency

+ Key string

+ Metadata map[string]string

+ StoreName string

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

+ func (*GetStateRequest) ProtoMessage()

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

+ func (x *GetStateRequest) GetKey() string

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

+ func (x *GetStateRequest) GetStoreName() string

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

+ func (x *GetStateRequest) Reset()

+ func (x *GetStateRequest) String() string

+ type GetStateResponse struct

+ Data []byte

+ Etag string

+ Metadata map[string]string

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

+ func (*GetStateResponse) ProtoMessage()

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

+ func (x *GetStateResponse) GetEtag() string

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

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

+ func (x *GetStateResponse) Reset()

+ func (x *GetStateResponse) String() string

+ type InvokeActorRequest struct

+ ActorId string

+ ActorType string

+ Data []byte

+ Method string

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

+ func (*InvokeActorRequest) ProtoMessage()

+ func (x *InvokeActorRequest) GetActorId() string

+ func (x *InvokeActorRequest) GetActorType() string

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

+ func (x *InvokeActorRequest) GetMethod() string

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

+ func (x *InvokeActorRequest) Reset()

+ func (x *InvokeActorRequest) String() string

+ type InvokeActorResponse struct

+ Data []byte

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

+ func (*InvokeActorResponse) ProtoMessage()

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

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

+ func (x *InvokeActorResponse) Reset()

+ func (x *InvokeActorResponse) String() string

+ type InvokeBindingRequest struct

+ Data []byte

+ Metadata map[string]string

+ Name string

+ Operation string

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

+ func (*InvokeBindingRequest) ProtoMessage()

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

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

+ func (x *InvokeBindingRequest) GetName() string

+ func (x *InvokeBindingRequest) GetOperation() string

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

+ func (x *InvokeBindingRequest) Reset()

+ func (x *InvokeBindingRequest) String() string

+ type InvokeBindingResponse struct

+ Data []byte

+ Metadata map[string]string

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

+ func (*InvokeBindingResponse) ProtoMessage()

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

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

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

+ func (x *InvokeBindingResponse) Reset()

+ func (x *InvokeBindingResponse) String() string

+ type InvokeServiceRequest struct

+ Id string

+ Message *v1.InvokeRequest

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

+ func (*InvokeServiceRequest) ProtoMessage()

+ func (x *InvokeServiceRequest) GetId() string

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

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

+ func (x *InvokeServiceRequest) Reset()

+ func (x *InvokeServiceRequest) String() string

+ type ListInputBindingsResponse struct

+ Bindings []string

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

+ func (*ListInputBindingsResponse) ProtoMessage()

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

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

+ func (x *ListInputBindingsResponse) Reset()

+ func (x *ListInputBindingsResponse) String() string

+ type ListTopicSubscriptionsResponse struct

+ Subscriptions []*TopicSubscription

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

+ func (*ListTopicSubscriptionsResponse) ProtoMessage()

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

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

+ func (x *ListTopicSubscriptionsResponse) Reset()

+ func (x *ListTopicSubscriptionsResponse) String() string

+ type PublishEventRequest struct

+ Data []byte

+ DataContentType string

+ Metadata map[string]string

+ PubsubName string

+ Topic string

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

+ func (*PublishEventRequest) ProtoMessage()

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

+ func (x *PublishEventRequest) GetDataContentType() string

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

+ func (x *PublishEventRequest) GetPubsubName() string

+ func (x *PublishEventRequest) GetTopic() string

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

+ func (x *PublishEventRequest) Reset()

+ func (x *PublishEventRequest) String() string

+ type QueryStateItem struct

+ Data []byte

+ Error string

+ Etag string

+ Key string

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

+ func (*QueryStateItem) ProtoMessage()

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

+ func (x *QueryStateItem) GetError() string

+ func (x *QueryStateItem) GetEtag() string

+ func (x *QueryStateItem) GetKey() string

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

+ func (x *QueryStateItem) Reset()

+ func (x *QueryStateItem) String() string

+ type QueryStateRequest struct

+ Metadata map[string]string

+ Query string

+ StoreName string

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

+ func (*QueryStateRequest) ProtoMessage()

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

+ func (x *QueryStateRequest) GetQuery() string

+ func (x *QueryStateRequest) GetStoreName() string

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

+ func (x *QueryStateRequest) Reset()

+ func (x *QueryStateRequest) String() string

+ type QueryStateResponse struct

+ Metadata map[string]string

+ Results []*QueryStateItem

+ Token string

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

+ func (*QueryStateResponse) ProtoMessage()

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

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

+ func (x *QueryStateResponse) GetToken() string

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

+ func (x *QueryStateResponse) Reset()

+ func (x *QueryStateResponse) String() string

+ type RegisterActorReminderRequest struct

+ ActorId string

+ ActorType string

+ Data []byte

+ DueTime string

+ Name string

+ Period string

+ Ttl string

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

+ func (*RegisterActorReminderRequest) ProtoMessage()

+ func (x *RegisterActorReminderRequest) GetActorId() string

+ func (x *RegisterActorReminderRequest) GetActorType() string

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

+ func (x *RegisterActorReminderRequest) GetDueTime() string

+ func (x *RegisterActorReminderRequest) GetName() string

+ func (x *RegisterActorReminderRequest) GetPeriod() string

+ func (x *RegisterActorReminderRequest) GetTtl() string

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

+ func (x *RegisterActorReminderRequest) Reset()

+ func (x *RegisterActorReminderRequest) String() string

+ type RegisterActorTimerRequest struct

+ ActorId string

+ ActorType string

+ Callback string

+ Data []byte

+ DueTime string

+ Name string

+ Period string

+ Ttl string

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

+ func (*RegisterActorTimerRequest) ProtoMessage()

+ func (x *RegisterActorTimerRequest) GetActorId() string

+ func (x *RegisterActorTimerRequest) GetActorType() string

+ func (x *RegisterActorTimerRequest) GetCallback() string

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

+ func (x *RegisterActorTimerRequest) GetDueTime() string

+ func (x *RegisterActorTimerRequest) GetName() string

+ func (x *RegisterActorTimerRequest) GetPeriod() string

+ func (x *RegisterActorTimerRequest) GetTtl() string

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

+ func (x *RegisterActorTimerRequest) Reset()

+ func (x *RegisterActorTimerRequest) String() string

+ type RegisteredComponents struct

+ Name string

+ Type string

+ Version string

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

+ func (*RegisteredComponents) ProtoMessage()

+ func (x *RegisteredComponents) GetName() string

+ func (x *RegisteredComponents) GetType() string

+ func (x *RegisteredComponents) GetVersion() string

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

+ func (x *RegisteredComponents) Reset()

+ func (x *RegisteredComponents) String() string

+ type SaveStateRequest struct

+ States []*v1.StateItem

+ StoreName string

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

+ func (*SaveStateRequest) ProtoMessage()

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

+ func (x *SaveStateRequest) GetStoreName() string

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

+ func (x *SaveStateRequest) Reset()

+ func (x *SaveStateRequest) String() string

+ type SecretResponse struct

+ Secrets map[string]string

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

+ func (*SecretResponse) ProtoMessage()

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

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

+ func (x *SecretResponse) Reset()

+ func (x *SecretResponse) String() string

+ type SetMetadataRequest struct

+ Key string

+ Value string

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

+ func (*SetMetadataRequest) ProtoMessage()

+ func (x *SetMetadataRequest) GetKey() string

+ func (x *SetMetadataRequest) GetValue() string

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

+ func (x *SetMetadataRequest) Reset()

+ func (x *SetMetadataRequest) String() string

+ type SubscribeConfigurationRequest struct

+ Keys []string

+ Metadata map[string]string

+ StoreName string

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

+ func (*SubscribeConfigurationRequest) ProtoMessage()

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

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

+ func (x *SubscribeConfigurationRequest) GetStoreName() string

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

+ func (x *SubscribeConfigurationRequest) Reset()

+ func (x *SubscribeConfigurationRequest) String() string

+ type SubscribeConfigurationResponse struct

+ Items []*v1.ConfigurationItem

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

+ func (*SubscribeConfigurationResponse) ProtoMessage()

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

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

+ func (x *SubscribeConfigurationResponse) Reset()

+ func (x *SubscribeConfigurationResponse) String() string

+ type TopicEventRequest struct

+ Data []byte

+ DataContentType string

+ Id string

+ Path string

+ PubsubName string

+ Source string

+ SpecVersion string

+ Topic string

+ Type string

+ func (*TopicEventRequest) Descriptor() ([]byte, []int)

+ func (*TopicEventRequest) ProtoMessage()

+ func (x *TopicEventRequest) GetData() []byte

+ func (x *TopicEventRequest) GetDataContentType() string

+ func (x *TopicEventRequest) GetId() string

+ func (x *TopicEventRequest) GetPath() string

+ func (x *TopicEventRequest) GetPubsubName() string

+ func (x *TopicEventRequest) GetSource() string

+ func (x *TopicEventRequest) GetSpecVersion() string

+ func (x *TopicEventRequest) GetTopic() string

+ func (x *TopicEventRequest) GetType() string

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

+ func (x *TopicEventRequest) Reset()

+ func (x *TopicEventRequest) String() string

+ type TopicEventResponse struct

+ Status TopicEventResponse_TopicEventResponseStatus

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

+ func (*TopicEventResponse) ProtoMessage()

+ func (x *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

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

+ func (x *TopicEventResponse) Reset()

+ func (x *TopicEventResponse) String() string

+ type TopicEventResponse_TopicEventResponseStatus int32

+ const TopicEventResponse_DROP

+ const TopicEventResponse_RETRY

+ const TopicEventResponse_SUCCESS

+ func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (TopicEventResponse_TopicEventResponseStatus) Type() protoreflect.EnumType

+ func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

+ func (x TopicEventResponse_TopicEventResponseStatus) Number() protoreflect.EnumNumber

+ func (x TopicEventResponse_TopicEventResponseStatus) String() string

+ type TopicRoutes struct

+ Default string

+ Rules []*TopicRule

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

+ func (*TopicRoutes) ProtoMessage()

+ func (x *TopicRoutes) GetDefault() string

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

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

+ func (x *TopicRoutes) Reset()

+ func (x *TopicRoutes) String() string

+ type TopicRule struct

+ Match string

+ Path string

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

+ func (*TopicRule) ProtoMessage()

+ func (x *TopicRule) GetMatch() string

+ func (x *TopicRule) GetPath() string

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

+ func (x *TopicRule) Reset()

+ func (x *TopicRule) String() string

+ type TopicSubscription struct

+ Metadata map[string]string

+ PubsubName string

+ Routes *TopicRoutes

+ Topic string

+ func (*TopicSubscription) Descriptor() ([]byte, []int)

+ func (*TopicSubscription) ProtoMessage()

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

+ func (x *TopicSubscription) GetPubsubName() string

+ func (x *TopicSubscription) GetRoutes() *TopicRoutes

+ func (x *TopicSubscription) GetTopic() string

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

+ func (x *TopicSubscription) Reset()

+ func (x *TopicSubscription) String() string

+ type TransactionalActorStateOperation struct

+ Key string

+ OperationType string

+ Value *anypb.Any

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

+ func (*TransactionalActorStateOperation) ProtoMessage()

+ func (x *TransactionalActorStateOperation) GetKey() string

+ func (x *TransactionalActorStateOperation) GetOperationType() string

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

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

+ func (x *TransactionalActorStateOperation) Reset()

+ func (x *TransactionalActorStateOperation) String() string

+ type TransactionalStateOperation struct

+ OperationType string

+ Request *v1.StateItem

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

+ func (*TransactionalStateOperation) ProtoMessage()

+ func (x *TransactionalStateOperation) GetOperationType() string

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

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

+ func (x *TransactionalStateOperation) Reset()

+ func (x *TransactionalStateOperation) String() string

+ type UnimplementedAppCallbackServer struct

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

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

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

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

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

+ type UnimplementedDaprServer struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type UnregisterActorReminderRequest struct

+ ActorId string

+ ActorType string

+ Name string

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

+ func (*UnregisterActorReminderRequest) ProtoMessage()

+ func (x *UnregisterActorReminderRequest) GetActorId() string

+ func (x *UnregisterActorReminderRequest) GetActorType() string

+ func (x *UnregisterActorReminderRequest) GetName() string

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

+ func (x *UnregisterActorReminderRequest) Reset()

+ func (x *UnregisterActorReminderRequest) String() string

+ type UnregisterActorTimerRequest struct

+ ActorId string

+ ActorType string

+ Name string

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

+ func (*UnregisterActorTimerRequest) ProtoMessage()

+ func (x *UnregisterActorTimerRequest) GetActorId() string

+ func (x *UnregisterActorTimerRequest) GetActorType() string

+ func (x *UnregisterActorTimerRequest) GetName() string

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

+ func (x *UnregisterActorTimerRequest) Reset()

+ func (x *UnregisterActorTimerRequest) String() string

+ type UnsafeAppCallbackServer interface

+ type UnsafeDaprServer interface

v0.4.0-rc

Apr 1, 2022