runtime

Aug 14, 2024

Changes in this version

+ const AppCallbackAlpha_OnBulkTopicEventAlpha1_FullMethodName

+ const AppCallbackAlpha_OnJobEventAlpha1_FullMethodName

+ const AppCallbackHealthCheck_HealthCheck_FullMethodName

+ const AppCallback_ListInputBindings_FullMethodName

+ const AppCallback_ListTopicSubscriptions_FullMethodName

+ const AppCallback_OnBindingEvent_FullMethodName

+ const AppCallback_OnInvoke_FullMethodName

+ const AppCallback_OnTopicEvent_FullMethodName

+ const Dapr_BulkPublishEventAlpha1_FullMethodName

+ const Dapr_DecryptAlpha1_FullMethodName

+ const Dapr_DeleteBulkState_FullMethodName

+ const Dapr_DeleteJobAlpha1_FullMethodName

+ const Dapr_DeleteState_FullMethodName

+ const Dapr_EncryptAlpha1_FullMethodName

+ const Dapr_ExecuteActorStateTransaction_FullMethodName

+ const Dapr_ExecuteStateTransaction_FullMethodName

+ const Dapr_GetActorState_FullMethodName

+ const Dapr_GetBulkSecret_FullMethodName

+ const Dapr_GetBulkState_FullMethodName

+ const Dapr_GetConfigurationAlpha1_FullMethodName

+ const Dapr_GetConfiguration_FullMethodName

+ const Dapr_GetJobAlpha1_FullMethodName

+ const Dapr_GetMetadata_FullMethodName

+ const Dapr_GetSecret_FullMethodName

+ const Dapr_GetState_FullMethodName

+ const Dapr_GetWorkflowAlpha1_FullMethodName

+ const Dapr_GetWorkflowBeta1_FullMethodName

+ const Dapr_InvokeActor_FullMethodName

+ const Dapr_InvokeBinding_FullMethodName

+ const Dapr_InvokeService_FullMethodName

+ const Dapr_PauseWorkflowAlpha1_FullMethodName

+ const Dapr_PauseWorkflowBeta1_FullMethodName

+ const Dapr_PublishEvent_FullMethodName

+ const Dapr_PurgeWorkflowAlpha1_FullMethodName

+ const Dapr_PurgeWorkflowBeta1_FullMethodName

+ const Dapr_QueryStateAlpha1_FullMethodName

+ const Dapr_RaiseEventWorkflowAlpha1_FullMethodName

+ const Dapr_RaiseEventWorkflowBeta1_FullMethodName

+ const Dapr_RegisterActorReminder_FullMethodName

+ const Dapr_RegisterActorTimer_FullMethodName

+ const Dapr_ResumeWorkflowAlpha1_FullMethodName

+ const Dapr_ResumeWorkflowBeta1_FullMethodName

+ const Dapr_SaveState_FullMethodName

+ const Dapr_ScheduleJobAlpha1_FullMethodName

+ const Dapr_SetMetadata_FullMethodName

+ const Dapr_Shutdown_FullMethodName

+ const Dapr_StartWorkflowAlpha1_FullMethodName

+ const Dapr_StartWorkflowBeta1_FullMethodName

+ const Dapr_SubscribeConfigurationAlpha1_FullMethodName

+ const Dapr_SubscribeConfiguration_FullMethodName

+ const Dapr_SubscribeTopicEventsAlpha1_FullMethodName

+ const Dapr_SubtleDecryptAlpha1_FullMethodName

+ const Dapr_SubtleEncryptAlpha1_FullMethodName

+ const Dapr_SubtleGetKeyAlpha1_FullMethodName

+ const Dapr_SubtleSignAlpha1_FullMethodName

+ const Dapr_SubtleUnwrapKeyAlpha1_FullMethodName

+ const Dapr_SubtleVerifyAlpha1_FullMethodName

+ const Dapr_SubtleWrapKeyAlpha1_FullMethodName

+ const Dapr_TerminateWorkflowAlpha1_FullMethodName

+ const Dapr_TerminateWorkflowBeta1_FullMethodName

+ const Dapr_TryLockAlpha1_FullMethodName

+ const Dapr_UnlockAlpha1_FullMethodName

+ const Dapr_UnregisterActorReminder_FullMethodName

+ const Dapr_UnregisterActorTimer_FullMethodName

+ const Dapr_UnsubscribeConfigurationAlpha1_FullMethodName

+ const Dapr_UnsubscribeConfiguration_FullMethodName

+ var PubsubSubscriptionType_name = map[int32]string

+ var PubsubSubscriptionType_value = map[string]int32

type AppCallbackAlphaClient

+ OnJobEventAlpha1 func(ctx context.Context, in *JobEventRequest, opts ...grpc.CallOption) (*JobEventResponse, error)

type AppCallbackAlphaServer

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

type DaprClient

+ DeleteJobAlpha1 func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)

+ GetJobAlpha1 func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)

+ ScheduleJobAlpha1 func(ctx context.Context, in *ScheduleJobRequest, opts ...grpc.CallOption) (*ScheduleJobResponse, error)

+ SubscribeTopicEventsAlpha1 func(ctx context.Context, opts ...grpc.CallOption) (Dapr_SubscribeTopicEventsAlpha1Client, error)

type DaprServer

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

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

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

+ SubscribeTopicEventsAlpha1 func(Dapr_SubscribeTopicEventsAlpha1Server) error

+ type Dapr_SubscribeTopicEventsAlpha1Client interface

+ Recv func() (*SubscribeTopicEventsResponseAlpha1, error)

+ Send func(*SubscribeTopicEventsRequestAlpha1) error

+ type Dapr_SubscribeTopicEventsAlpha1Server interface

+ Recv func() (*SubscribeTopicEventsRequestAlpha1, error)

+ Send func(*SubscribeTopicEventsResponseAlpha1) error

+ type DeleteJobRequest struct

+ Name string

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

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

+ func (*DeleteJobRequest) ProtoMessage()

+ func (x *DeleteJobRequest) GetName() string

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

+ func (x *DeleteJobRequest) Reset()

+ func (x *DeleteJobRequest) String() string

+ type DeleteJobResponse struct

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

+ func (*DeleteJobResponse) ProtoMessage()

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

+ func (x *DeleteJobResponse) Reset()

+ func (x *DeleteJobResponse) String() string

+ type GetJobRequest struct

+ Name string

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

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

+ func (*GetJobRequest) ProtoMessage()

+ func (x *GetJobRequest) GetName() string

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

+ func (x *GetJobRequest) Reset()

+ func (x *GetJobRequest) String() string

+ type GetJobResponse struct

+ Job *Job

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

+ func (*GetJobResponse) ProtoMessage()

+ func (x *GetJobResponse) GetJob() *Job

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

+ func (x *GetJobResponse) Reset()

+ func (x *GetJobResponse) String() string

+ type Job struct

+ Data *anypb.Any

+ DueTime *string

+ Name string

+ Repeats *uint32

+ Schedule *string

+ Ttl *string

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

+ func (*Job) ProtoMessage()

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

+ func (x *Job) GetDueTime() string

+ func (x *Job) GetName() string

+ func (x *Job) GetRepeats() uint32

+ func (x *Job) GetSchedule() string

+ func (x *Job) GetTtl() string

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

+ func (x *Job) Reset()

+ func (x *Job) String() string

+ type JobEventRequest struct

+ ContentType string

+ Data *anypb.Any

+ HttpExtension *v1.HTTPExtension

+ Method string

+ Name string

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

+ func (*JobEventRequest) ProtoMessage()

+ func (x *JobEventRequest) GetContentType() string

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

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

+ func (x *JobEventRequest) GetMethod() string

+ func (x *JobEventRequest) GetName() string

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

+ func (x *JobEventRequest) Reset()

+ func (x *JobEventRequest) String() string

+ type JobEventResponse struct

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

+ func (*JobEventResponse) ProtoMessage()

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

+ func (x *JobEventResponse) Reset()

+ func (x *JobEventResponse) String() string

type PubsubSubscription

+ Type PubsubSubscriptionType

+ func (x *PubsubSubscription) GetType() PubsubSubscriptionType

+ type PubsubSubscriptionType int32

+ const PubsubSubscriptionType_DECLARATIVE

+ const PubsubSubscriptionType_PROGRAMMATIC

+ const PubsubSubscriptionType_STREAMING

+ const PubsubSubscriptionType_UNKNOWN

+ func (PubsubSubscriptionType) Descriptor() protoreflect.EnumDescriptor

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

+ func (PubsubSubscriptionType) Type() protoreflect.EnumType

+ func (x PubsubSubscriptionType) Enum() *PubsubSubscriptionType

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

+ func (x PubsubSubscriptionType) String() string

+ type ScheduleJobRequest struct

+ Job *Job

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

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

+ func (*ScheduleJobRequest) ProtoMessage()

+ func (x *ScheduleJobRequest) GetJob() *Job

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

+ func (x *ScheduleJobRequest) Reset()

+ func (x *ScheduleJobRequest) String() string

+ type ScheduleJobResponse struct

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

+ func (*ScheduleJobResponse) ProtoMessage()

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

+ func (x *ScheduleJobResponse) Reset()

+ func (x *ScheduleJobResponse) String() string

+ type SubscribeTopicEventsRequestAlpha1 struct

+ SubscribeTopicEventsRequestType isSubscribeTopicEventsRequestAlpha1_SubscribeTopicEventsRequestType

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

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

+ func (*SubscribeTopicEventsRequestAlpha1) ProtoMessage()

+ func (m *SubscribeTopicEventsRequestAlpha1) GetSubscribeTopicEventsRequestType() isSubscribeTopicEventsRequestAlpha1_SubscribeTopicEventsRequestType

+ func (x *SubscribeTopicEventsRequestAlpha1) GetEventProcessed() *SubscribeTopicEventsRequestProcessedAlpha1

+ func (x *SubscribeTopicEventsRequestAlpha1) GetInitialRequest() *SubscribeTopicEventsRequestInitialAlpha1

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

+ func (x *SubscribeTopicEventsRequestAlpha1) Reset()

+ func (x *SubscribeTopicEventsRequestAlpha1) String() string

+ type SubscribeTopicEventsRequestAlpha1_EventProcessed struct

+ EventProcessed *SubscribeTopicEventsRequestProcessedAlpha1

+ type SubscribeTopicEventsRequestAlpha1_InitialRequest struct

+ InitialRequest *SubscribeTopicEventsRequestInitialAlpha1

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

+ type SubscribeTopicEventsRequestInitialAlpha1 struct

+ DeadLetterTopic *string

+ Metadata map[string]string

+ PubsubName string

+ Topic string

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

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

+ func (*SubscribeTopicEventsRequestInitialAlpha1) ProtoMessage()

+ func (x *SubscribeTopicEventsRequestInitialAlpha1) GetDeadLetterTopic() string

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

+ func (x *SubscribeTopicEventsRequestInitialAlpha1) GetPubsubName() string

+ func (x *SubscribeTopicEventsRequestInitialAlpha1) GetTopic() string

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

+ func (x *SubscribeTopicEventsRequestInitialAlpha1) Reset()

+ func (x *SubscribeTopicEventsRequestInitialAlpha1) String() string

+ type SubscribeTopicEventsRequestProcessedAlpha1 struct

+ Id string

+ Status *TopicEventResponse

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

+ func (*SubscribeTopicEventsRequestProcessedAlpha1) ProtoMessage()

+ func (x *SubscribeTopicEventsRequestProcessedAlpha1) GetId() string

+ func (x *SubscribeTopicEventsRequestProcessedAlpha1) GetStatus() *TopicEventResponse

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

+ func (x *SubscribeTopicEventsRequestProcessedAlpha1) Reset()

+ func (x *SubscribeTopicEventsRequestProcessedAlpha1) String() string

+ type SubscribeTopicEventsResponseAlpha1 struct

+ SubscribeTopicEventsResponseType isSubscribeTopicEventsResponseAlpha1_SubscribeTopicEventsResponseType

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

+ func (*SubscribeTopicEventsResponseAlpha1) ProtoMessage()

+ func (m *SubscribeTopicEventsResponseAlpha1) GetSubscribeTopicEventsResponseType() isSubscribeTopicEventsResponseAlpha1_SubscribeTopicEventsResponseType

+ func (x *SubscribeTopicEventsResponseAlpha1) GetEventMessage() *TopicEventRequest

+ func (x *SubscribeTopicEventsResponseAlpha1) GetInitialResponse() *SubscribeTopicEventsResponseInitialAlpha1

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

+ func (x *SubscribeTopicEventsResponseAlpha1) Reset()

+ func (x *SubscribeTopicEventsResponseAlpha1) String() string

+ type SubscribeTopicEventsResponseAlpha1_EventMessage struct

+ EventMessage *TopicEventRequest

+ type SubscribeTopicEventsResponseAlpha1_InitialResponse struct

+ InitialResponse *SubscribeTopicEventsResponseInitialAlpha1

+ type SubscribeTopicEventsResponseInitialAlpha1 struct

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

+ func (*SubscribeTopicEventsResponseInitialAlpha1) ProtoMessage()

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

+ func (x *SubscribeTopicEventsResponseInitialAlpha1) Reset()

+ func (x *SubscribeTopicEventsResponseInitialAlpha1) String() string

type UnimplementedAppCallbackAlphaServer

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

type UnimplementedDaprServer

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

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

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

+ func (UnimplementedDaprServer) SubscribeTopicEventsAlpha1(Dapr_SubscribeTopicEventsAlpha1Server) error

Apr 3, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Apr 3, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Mar 9, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Mar 6, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Changes in this version

+ var ActorRuntime_ActorRuntimeStatus_name = map[int32]string

+ var ActorRuntime_ActorRuntimeStatus_value = map[string]int32

+ type ActorRuntime struct

+ ActiveActors []*ActiveActorsCount

+ HostReady bool

+ Placement string

+ RuntimeStatus ActorRuntime_ActorRuntimeStatus

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

+ func (*ActorRuntime) ProtoMessage()

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

+ func (x *ActorRuntime) GetHostReady() bool

+ func (x *ActorRuntime) GetPlacement() string

+ func (x *ActorRuntime) GetRuntimeStatus() ActorRuntime_ActorRuntimeStatus

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

+ func (x *ActorRuntime) Reset()

+ func (x *ActorRuntime) String() string

+ type ActorRuntime_ActorRuntimeStatus int32

+ const ActorRuntime_DISABLED

+ const ActorRuntime_INITIALIZING

+ const ActorRuntime_RUNNING

+ func (ActorRuntime_ActorRuntimeStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (ActorRuntime_ActorRuntimeStatus) Type() protoreflect.EnumType

+ func (x ActorRuntime_ActorRuntimeStatus) Enum() *ActorRuntime_ActorRuntimeStatus

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

+ func (x ActorRuntime_ActorRuntimeStatus) String() string

type BulkPublishRequest

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

type DecryptRequest

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

type DeleteBulkStateRequest

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

type DeleteStateRequest

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

type EncryptRequest

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

type ExecuteActorStateTransactionRequest

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

type ExecuteStateTransactionRequest

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

type GetActorStateRequest

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

type GetBulkSecretRequest

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

type GetBulkStateRequest

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

type GetConfigurationRequest

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

+ type GetMetadataRequest struct

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

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

+ func (*GetMetadataRequest) ProtoMessage()

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

+ func (x *GetMetadataRequest) Reset()

+ func (x *GetMetadataRequest) String() string

type GetMetadataResponse

+ ActorRuntime *ActorRuntime

+ func (x *GetMetadataResponse) GetActorRuntime() *ActorRuntime

type GetSecretRequest

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

type GetStateRequest

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

type GetWorkflowRequest

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

type InvokeActorRequest

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

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

type InvokeBindingRequest

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

type InvokeServiceRequest

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

type PauseWorkflowRequest

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

type PublishEventRequest

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

type PurgeWorkflowRequest

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

type QueryStateRequest

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

type RaiseEventWorkflowRequest

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

type RegisterActorReminderRequest

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

type RegisterActorTimerRequest

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

type ResumeWorkflowRequest

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

type SaveStateRequest

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

type SetMetadataRequest

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

+ type ShutdownRequest struct

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

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

+ func (*ShutdownRequest) ProtoMessage()

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

+ func (x *ShutdownRequest) Reset()

+ func (x *ShutdownRequest) String() string

type StartWorkflowRequest

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

type SubscribeConfigurationRequest

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

type SubtleDecryptRequest

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

type SubtleEncryptRequest

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

type SubtleGetKeyRequest

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

type SubtleSignRequest

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

type SubtleUnwrapKeyRequest

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

type SubtleVerifyRequest

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

type SubtleWrapKeyRequest

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

type TerminateWorkflowRequest

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

type TryLockRequest

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

type UnlockRequest

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

type UnregisterActorReminderRequest

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

type UnregisterActorTimerRequest

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

type UnsubscribeConfigurationRequest

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

Oct 11, 2023

Changes in this version

+ type AppConnectionHealthProperties struct

+ HealthCheckPath string

+ HealthProbeInterval string

+ HealthProbeTimeout string

+ HealthThreshold int32

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

+ func (*AppConnectionHealthProperties) ProtoMessage()

+ func (x *AppConnectionHealthProperties) GetHealthCheckPath() string

+ func (x *AppConnectionHealthProperties) GetHealthProbeInterval() string

+ func (x *AppConnectionHealthProperties) GetHealthProbeTimeout() string

+ func (x *AppConnectionHealthProperties) GetHealthThreshold() int32

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

+ func (x *AppConnectionHealthProperties) Reset()

+ func (x *AppConnectionHealthProperties) String() string

+ type AppConnectionProperties struct

+ ChannelAddress string

+ Health *AppConnectionHealthProperties

+ MaxConcurrency int32

+ Port int32

+ Protocol string

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

+ func (*AppConnectionProperties) ProtoMessage()

+ func (x *AppConnectionProperties) GetChannelAddress() string

+ func (x *AppConnectionProperties) GetHealth() *AppConnectionHealthProperties

+ func (x *AppConnectionProperties) GetMaxConcurrency() int32

+ func (x *AppConnectionProperties) GetPort() int32

+ func (x *AppConnectionProperties) GetProtocol() string

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

+ func (x *AppConnectionProperties) Reset()

+ func (x *AppConnectionProperties) String() string

type DaprClient

+ GetWorkflowBeta1 func(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)

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

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

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

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

+ StartWorkflowBeta1 func(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*StartWorkflowResponse, error)

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

type DaprServer

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

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

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

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

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

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

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

type GetActorStateResponse

+ Metadata map[string]string

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

type GetMetadataResponse

+ AppConnectionProperties *AppConnectionProperties

+ EnabledFeatures []string

+ HttpEndpoints []*MetadataHTTPEndpoint

+ RuntimeVersion string

+ func (x *GetMetadataResponse) GetAppConnectionProperties() *AppConnectionProperties

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

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

+ func (x *GetMetadataResponse) GetRuntimeVersion() string

type GetWorkflowRequest

+ func (x *GetWorkflowRequest) SetInstanceId(val string)

+ func (x *GetWorkflowRequest) SetWorkflowComponent(val string)

+ type MetadataHTTPEndpoint struct

+ Name string

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

+ func (*MetadataHTTPEndpoint) ProtoMessage()

+ func (x *MetadataHTTPEndpoint) GetName() string

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

+ func (x *MetadataHTTPEndpoint) Reset()

+ func (x *MetadataHTTPEndpoint) String() string

type PauseWorkflowRequest

+ func (x *PauseWorkflowRequest) SetInstanceId(val string)

+ func (x *PauseWorkflowRequest) SetWorkflowComponent(val string)

type PurgeWorkflowRequest

+ func (x *PurgeWorkflowRequest) SetInstanceId(val string)

+ func (x *PurgeWorkflowRequest) SetWorkflowComponent(val string)

type ResumeWorkflowRequest

+ func (x *ResumeWorkflowRequest) SetInstanceId(val string)

+ func (x *ResumeWorkflowRequest) SetWorkflowComponent(val string)

type TerminateWorkflowRequest

+ func (x *TerminateWorkflowRequest) SetInstanceId(val string)

+ func (x *TerminateWorkflowRequest) SetWorkflowComponent(val string)

type UnimplementedDaprServer

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

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

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

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

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

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

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

+ type WorkflowRequests interface

+ SetInstanceId func(val string)

+ SetWorkflowComponent func(val string)

Jul 19, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 17, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 17, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 22, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 22, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 21, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 20, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 19, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 19, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 8, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var SubtleGetKeyRequest_KeyFormat_name = map[int32]string

+ var SubtleGetKeyRequest_KeyFormat_value = map[string]int32

+ type CryptoRequests interface

+ GetPayload func() *commonv1pb.StreamPayload

+ HasOptions func() bool

+ Reset func()

+ SetOptions func(opts proto.Message)

+ SetPayload func(payload *commonv1pb.StreamPayload)

+ type CryptoResponses interface

+ GetPayload func() *commonv1pb.StreamPayload

+ Reset func()

+ SetPayload func(payload *commonv1pb.StreamPayload)

type DaprClient

+ DecryptAlpha1 func(ctx context.Context, opts ...grpc.CallOption) (Dapr_DecryptAlpha1Client, error)

+ EncryptAlpha1 func(ctx context.Context, opts ...grpc.CallOption) (Dapr_EncryptAlpha1Client, error)

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

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

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

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

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

+ SubscribeConfiguration func(ctx context.Context, in *SubscribeConfigurationRequest, ...) (Dapr_SubscribeConfigurationClient, error)

+ SubtleDecryptAlpha1 func(ctx context.Context, in *SubtleDecryptRequest, opts ...grpc.CallOption) (*SubtleDecryptResponse, error)

+ SubtleEncryptAlpha1 func(ctx context.Context, in *SubtleEncryptRequest, opts ...grpc.CallOption) (*SubtleEncryptResponse, error)

+ SubtleGetKeyAlpha1 func(ctx context.Context, in *SubtleGetKeyRequest, opts ...grpc.CallOption) (*SubtleGetKeyResponse, error)

+ SubtleSignAlpha1 func(ctx context.Context, in *SubtleSignRequest, opts ...grpc.CallOption) (*SubtleSignResponse, error)

+ SubtleUnwrapKeyAlpha1 func(ctx context.Context, in *SubtleUnwrapKeyRequest, opts ...grpc.CallOption) (*SubtleUnwrapKeyResponse, error)

+ SubtleVerifyAlpha1 func(ctx context.Context, in *SubtleVerifyRequest, opts ...grpc.CallOption) (*SubtleVerifyResponse, error)

+ SubtleWrapKeyAlpha1 func(ctx context.Context, in *SubtleWrapKeyRequest, opts ...grpc.CallOption) (*SubtleWrapKeyResponse, error)

+ UnsubscribeConfiguration func(ctx context.Context, in *UnsubscribeConfigurationRequest, ...) (*UnsubscribeConfigurationResponse, error)

type DaprServer

+ DecryptAlpha1 func(Dapr_DecryptAlpha1Server) error

+ EncryptAlpha1 func(Dapr_EncryptAlpha1Server) error

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

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

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

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

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

+ SubscribeConfiguration func(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationServer) error

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

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

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

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

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

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

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

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

+ type Dapr_DecryptAlpha1Client interface

+ Recv func() (*DecryptResponse, error)

+ Send func(*DecryptRequest) error

+ type Dapr_DecryptAlpha1Server interface

+ Recv func() (*DecryptRequest, error)

+ Send func(*DecryptResponse) error

+ type Dapr_EncryptAlpha1Client interface

+ Recv func() (*EncryptResponse, error)

+ Send func(*EncryptRequest) error

+ type Dapr_EncryptAlpha1Server interface

+ Recv func() (*EncryptRequest, error)

+ Send func(*EncryptResponse) error

+ type Dapr_SubscribeConfigurationClient interface

+ Recv func() (*SubscribeConfigurationResponse, error)

+ type Dapr_SubscribeConfigurationServer interface

+ Send func(*SubscribeConfigurationResponse) error

+ type DecryptRequest struct

+ Options *DecryptRequestOptions

+ Payload *v1.StreamPayload

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

+ func (*DecryptRequest) ProtoMessage()

+ func (x *DecryptRequest) GetOptions() *DecryptRequestOptions

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

+ func (x *DecryptRequest) HasOptions() bool

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

+ func (x *DecryptRequest) Reset()

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

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

+ func (x *DecryptRequest) String() string

+ type DecryptRequestOptions struct

+ ComponentName string

+ KeyName string

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

+ func (*DecryptRequestOptions) ProtoMessage()

+ func (x *DecryptRequestOptions) GetComponentName() string

+ func (x *DecryptRequestOptions) GetKeyName() string

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

+ func (x *DecryptRequestOptions) Reset()

+ func (x *DecryptRequestOptions) String() string

+ type DecryptResponse struct

+ Payload *v1.StreamPayload

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

+ func (*DecryptResponse) ProtoMessage()

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

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

+ func (x *DecryptResponse) Reset()

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

+ func (x *DecryptResponse) String() string

+ type EncryptRequest struct

+ Options *EncryptRequestOptions

+ Payload *v1.StreamPayload

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

+ func (*EncryptRequest) ProtoMessage()

+ func (x *EncryptRequest) GetOptions() *EncryptRequestOptions

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

+ func (x *EncryptRequest) HasOptions() bool

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

+ func (x *EncryptRequest) Reset()

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

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

+ func (x *EncryptRequest) String() string

+ type EncryptRequestOptions struct

+ ComponentName string

+ DataEncryptionCipher string

+ DecryptionKeyName string

+ KeyName string

+ KeyWrapAlgorithm string

+ OmitDecryptionKeyName bool

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

+ func (*EncryptRequestOptions) ProtoMessage()

+ func (x *EncryptRequestOptions) GetComponentName() string

+ func (x *EncryptRequestOptions) GetDataEncryptionCipher() string

+ func (x *EncryptRequestOptions) GetDecryptionKeyName() string

+ func (x *EncryptRequestOptions) GetKeyName() string

+ func (x *EncryptRequestOptions) GetKeyWrapAlgorithm() string

+ func (x *EncryptRequestOptions) GetOmitDecryptionKeyName() bool

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

+ func (x *EncryptRequestOptions) Reset()

+ func (x *EncryptRequestOptions) String() string

+ type EncryptResponse struct

+ Payload *v1.StreamPayload

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

+ func (*EncryptResponse) ProtoMessage()

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

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

+ func (x *EncryptResponse) Reset()

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

+ func (x *EncryptResponse) String() string

type GetWorkflowResponse

+ CreatedAt *timestamppb.Timestamp

+ LastUpdatedAt *timestamppb.Timestamp

+ Properties map[string]string

+ RuntimeStatus string

+ WorkflowName string

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

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

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

+ func (x *GetWorkflowResponse) GetRuntimeStatus() string

+ func (x *GetWorkflowResponse) GetWorkflowName() string

+ type PauseWorkflowRequest struct

+ InstanceId string

+ WorkflowComponent string

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

+ func (*PauseWorkflowRequest) ProtoMessage()

+ func (x *PauseWorkflowRequest) GetInstanceId() string

+ func (x *PauseWorkflowRequest) GetWorkflowComponent() string

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

+ func (x *PauseWorkflowRequest) Reset()

+ func (x *PauseWorkflowRequest) String() string

+ type PurgeWorkflowRequest struct

+ InstanceId string

+ WorkflowComponent string

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

+ func (*PurgeWorkflowRequest) ProtoMessage()

+ func (x *PurgeWorkflowRequest) GetInstanceId() string

+ func (x *PurgeWorkflowRequest) GetWorkflowComponent() string

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

+ func (x *PurgeWorkflowRequest) Reset()

+ func (x *PurgeWorkflowRequest) String() string

+ type RaiseEventWorkflowRequest struct

+ EventData []byte

+ EventName string

+ InstanceId string

+ WorkflowComponent string

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

+ func (*RaiseEventWorkflowRequest) ProtoMessage()

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

+ func (x *RaiseEventWorkflowRequest) GetEventName() string

+ func (x *RaiseEventWorkflowRequest) GetInstanceId() string

+ func (x *RaiseEventWorkflowRequest) GetWorkflowComponent() string

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

+ func (x *RaiseEventWorkflowRequest) Reset()

+ func (x *RaiseEventWorkflowRequest) String() string

+ type ResumeWorkflowRequest struct

+ InstanceId string

+ WorkflowComponent string

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

+ func (*ResumeWorkflowRequest) ProtoMessage()

+ func (x *ResumeWorkflowRequest) GetInstanceId() string

+ func (x *ResumeWorkflowRequest) GetWorkflowComponent() string

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

+ func (x *ResumeWorkflowRequest) Reset()

+ func (x *ResumeWorkflowRequest) String() string

+ type StartWorkflowResponse struct

+ InstanceId string

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

+ func (*StartWorkflowResponse) ProtoMessage()

+ func (x *StartWorkflowResponse) GetInstanceId() string

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

+ func (x *StartWorkflowResponse) Reset()

+ func (x *StartWorkflowResponse) String() string

+ type SubtleCryptoRequests interface

+ SetComponentName func(name string)

+ type SubtleDecryptRequest struct

+ Algorithm string

+ AssociatedData []byte

+ Ciphertext []byte

+ ComponentName string

+ KeyName string

+ Nonce []byte

+ Tag []byte

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

+ func (*SubtleDecryptRequest) ProtoMessage()

+ func (x *SubtleDecryptRequest) GetAlgorithm() string

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

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

+ func (x *SubtleDecryptRequest) GetComponentName() string

+ func (x *SubtleDecryptRequest) GetKeyName() string

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

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

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

+ func (x *SubtleDecryptRequest) Reset()

+ func (x *SubtleDecryptRequest) SetComponentName(name string)

+ func (x *SubtleDecryptRequest) String() string

+ type SubtleDecryptResponse struct

+ Plaintext []byte

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

+ func (*SubtleDecryptResponse) ProtoMessage()

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

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

+ func (x *SubtleDecryptResponse) Reset()

+ func (x *SubtleDecryptResponse) String() string

+ type SubtleEncryptRequest struct

+ Algorithm string

+ AssociatedData []byte

+ ComponentName string

+ KeyName string

+ Nonce []byte

+ Plaintext []byte

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

+ func (*SubtleEncryptRequest) ProtoMessage()

+ func (x *SubtleEncryptRequest) GetAlgorithm() string

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

+ func (x *SubtleEncryptRequest) GetComponentName() string

+ func (x *SubtleEncryptRequest) GetKeyName() string

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

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

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

+ func (x *SubtleEncryptRequest) Reset()

+ func (x *SubtleEncryptRequest) SetComponentName(name string)

+ func (x *SubtleEncryptRequest) String() string

+ type SubtleEncryptResponse struct

+ Ciphertext []byte

+ Tag []byte

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

+ func (*SubtleEncryptResponse) ProtoMessage()

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

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

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

+ func (x *SubtleEncryptResponse) Reset()

+ func (x *SubtleEncryptResponse) String() string

+ type SubtleGetKeyRequest struct

+ ComponentName string

+ Format SubtleGetKeyRequest_KeyFormat

+ Name string

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

+ func (*SubtleGetKeyRequest) ProtoMessage()

+ func (x *SubtleGetKeyRequest) GetComponentName() string

+ func (x *SubtleGetKeyRequest) GetFormat() SubtleGetKeyRequest_KeyFormat

+ func (x *SubtleGetKeyRequest) GetName() string

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

+ func (x *SubtleGetKeyRequest) Reset()

+ func (x *SubtleGetKeyRequest) SetComponentName(name string)

+ func (x *SubtleGetKeyRequest) String() string

+ type SubtleGetKeyRequest_KeyFormat int32

+ const SubtleGetKeyRequest_JSON

+ const SubtleGetKeyRequest_PEM

+ func (SubtleGetKeyRequest_KeyFormat) Descriptor() protoreflect.EnumDescriptor

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

+ func (SubtleGetKeyRequest_KeyFormat) Type() protoreflect.EnumType

+ func (x SubtleGetKeyRequest_KeyFormat) Enum() *SubtleGetKeyRequest_KeyFormat

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

+ func (x SubtleGetKeyRequest_KeyFormat) String() string

+ type SubtleGetKeyResponse struct

+ Name string

+ PublicKey string

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

+ func (*SubtleGetKeyResponse) ProtoMessage()

+ func (x *SubtleGetKeyResponse) GetName() string

+ func (x *SubtleGetKeyResponse) GetPublicKey() string

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

+ func (x *SubtleGetKeyResponse) Reset()

+ func (x *SubtleGetKeyResponse) String() string

+ type SubtleSignRequest struct

+ Algorithm string

+ ComponentName string

+ Digest []byte

+ KeyName string

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

+ func (*SubtleSignRequest) ProtoMessage()

+ func (x *SubtleSignRequest) GetAlgorithm() string

+ func (x *SubtleSignRequest) GetComponentName() string

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

+ func (x *SubtleSignRequest) GetKeyName() string

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

+ func (x *SubtleSignRequest) Reset()

+ func (x *SubtleSignRequest) SetComponentName(name string)

+ func (x *SubtleSignRequest) String() string

+ type SubtleSignResponse struct

+ Signature []byte

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

+ func (*SubtleSignResponse) ProtoMessage()

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

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

+ func (x *SubtleSignResponse) Reset()

+ func (x *SubtleSignResponse) String() string

+ type SubtleUnwrapKeyRequest struct

+ Algorithm string

+ AssociatedData []byte

+ ComponentName string

+ KeyName string

+ Nonce []byte

+ Tag []byte

+ WrappedKey []byte

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

+ func (*SubtleUnwrapKeyRequest) ProtoMessage()

+ func (x *SubtleUnwrapKeyRequest) GetAlgorithm() string

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

+ func (x *SubtleUnwrapKeyRequest) GetComponentName() string

+ func (x *SubtleUnwrapKeyRequest) GetKeyName() string

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

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

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

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

+ func (x *SubtleUnwrapKeyRequest) Reset()

+ func (x *SubtleUnwrapKeyRequest) SetComponentName(name string)

+ func (x *SubtleUnwrapKeyRequest) String() string

+ type SubtleUnwrapKeyResponse struct

+ PlaintextKey []byte

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

+ func (*SubtleUnwrapKeyResponse) ProtoMessage()

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

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

+ func (x *SubtleUnwrapKeyResponse) Reset()

+ func (x *SubtleUnwrapKeyResponse) String() string

+ type SubtleVerifyRequest struct

+ Algorithm string

+ ComponentName string

+ Digest []byte

+ KeyName string

+ Signature []byte

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

+ func (*SubtleVerifyRequest) ProtoMessage()

+ func (x *SubtleVerifyRequest) GetAlgorithm() string

+ func (x *SubtleVerifyRequest) GetComponentName() string

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

+ func (x *SubtleVerifyRequest) GetKeyName() string

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

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

+ func (x *SubtleVerifyRequest) Reset()

+ func (x *SubtleVerifyRequest) SetComponentName(name string)

+ func (x *SubtleVerifyRequest) String() string

+ type SubtleVerifyResponse struct

+ Valid bool

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

+ func (*SubtleVerifyResponse) ProtoMessage()

+ func (x *SubtleVerifyResponse) GetValid() bool

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

+ func (x *SubtleVerifyResponse) Reset()

+ func (x *SubtleVerifyResponse) String() string

+ type SubtleWrapKeyRequest struct

+ Algorithm string

+ AssociatedData []byte

+ ComponentName string

+ KeyName string

+ Nonce []byte

+ PlaintextKey []byte

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

+ func (*SubtleWrapKeyRequest) ProtoMessage()

+ func (x *SubtleWrapKeyRequest) GetAlgorithm() string

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

+ func (x *SubtleWrapKeyRequest) GetComponentName() string

+ func (x *SubtleWrapKeyRequest) GetKeyName() string

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

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

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

+ func (x *SubtleWrapKeyRequest) Reset()

+ func (x *SubtleWrapKeyRequest) SetComponentName(name string)

+ func (x *SubtleWrapKeyRequest) String() string

+ type SubtleWrapKeyResponse struct

+ Tag []byte

+ WrappedKey []byte

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

+ func (*SubtleWrapKeyResponse) ProtoMessage()

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

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

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

+ func (x *SubtleWrapKeyResponse) Reset()

+ func (x *SubtleWrapKeyResponse) String() string

type TransactionalActorStateOperation

+ Metadata map[string]string

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

type UnimplementedDaprServer

+ func (UnimplementedDaprServer) DecryptAlpha1(Dapr_DecryptAlpha1Server) error

+ func (UnimplementedDaprServer) EncryptAlpha1(Dapr_EncryptAlpha1Server) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Jul 17, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 21, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 21, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 20, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 11, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 11, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 10, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 6, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 6, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 4, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 25, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 13, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 31, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 17, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 13, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 13, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 8, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 23, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 21, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 16, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var AppCallbackAlpha_ServiceDesc = grpc.ServiceDesc

+ func RegisterAppCallbackAlphaServer(s grpc.ServiceRegistrar, srv AppCallbackAlphaServer)

+ type AppCallbackAlphaClient interface

+ OnBulkTopicEventAlpha1 func(ctx context.Context, in *TopicEventBulkRequest, opts ...grpc.CallOption) (*TopicEventBulkResponse, error)

+ func NewAppCallbackAlphaClient(cc grpc.ClientConnInterface) AppCallbackAlphaClient

+ type AppCallbackAlphaServer interface

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

+ type BulkPublishRequest struct

+ Entries []*BulkPublishRequestEntry

+ Metadata map[string]string

+ PubsubName string

+ Topic string

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

+ func (*BulkPublishRequest) ProtoMessage()

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

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

+ func (x *BulkPublishRequest) GetPubsubName() string

+ func (x *BulkPublishRequest) GetTopic() string

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

+ func (x *BulkPublishRequest) Reset()

+ func (x *BulkPublishRequest) String() string

+ type BulkPublishRequestEntry struct

+ ContentType string

+ EntryId string

+ Event []byte

+ Metadata map[string]string

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

+ func (*BulkPublishRequestEntry) ProtoMessage()

+ func (x *BulkPublishRequestEntry) GetContentType() string

+ func (x *BulkPublishRequestEntry) GetEntryId() string

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

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

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

+ func (x *BulkPublishRequestEntry) Reset()

+ func (x *BulkPublishRequestEntry) String() string

+ type BulkPublishResponse struct

+ FailedEntries []*BulkPublishResponseFailedEntry

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

+ func (*BulkPublishResponse) ProtoMessage()

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

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

+ func (x *BulkPublishResponse) Reset()

+ func (x *BulkPublishResponse) String() string

+ type BulkPublishResponseFailedEntry struct

+ EntryId string

+ Error string

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

+ func (*BulkPublishResponseFailedEntry) ProtoMessage()

+ func (x *BulkPublishResponseFailedEntry) GetEntryId() string

+ func (x *BulkPublishResponseFailedEntry) GetError() string

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

+ func (x *BulkPublishResponseFailedEntry) Reset()

+ func (x *BulkPublishResponseFailedEntry) String() string

+ type BulkSubscribeConfig struct

+ Enabled bool

+ MaxAwaitDurationMs int32

+ MaxMessagesCount int32

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

+ func (*BulkSubscribeConfig) ProtoMessage()

+ func (x *BulkSubscribeConfig) GetEnabled() bool

+ func (x *BulkSubscribeConfig) GetMaxAwaitDurationMs() int32

+ func (x *BulkSubscribeConfig) GetMaxMessagesCount() int32

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

+ func (x *BulkSubscribeConfig) Reset()

+ func (x *BulkSubscribeConfig) String() string

type DaprClient

+ BulkPublishEventAlpha1 func(ctx context.Context, in *BulkPublishRequest, opts ...grpc.CallOption) (*BulkPublishResponse, error)

+ GetWorkflowAlpha1 func(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)

+ StartWorkflowAlpha1 func(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*WorkflowReference, error)

+ TerminateWorkflowAlpha1 func(ctx context.Context, in *TerminateWorkflowRequest, opts ...grpc.CallOption) (*TerminateWorkflowResponse, error)

type DaprServer

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

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

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

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

type GetMetadataResponse

+ Subscriptions []*PubsubSubscription

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

+ type GetWorkflowRequest struct

+ InstanceId string

+ WorkflowComponent string

+ WorkflowType string

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

+ func (*GetWorkflowRequest) ProtoMessage()

+ func (x *GetWorkflowRequest) GetInstanceId() string

+ func (x *GetWorkflowRequest) GetWorkflowComponent() string

+ func (x *GetWorkflowRequest) GetWorkflowType() string

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

+ func (x *GetWorkflowRequest) Reset()

+ func (x *GetWorkflowRequest) String() string

+ type GetWorkflowResponse struct

+ InstanceId string

+ Metadata map[string]string

+ StartTime int64

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

+ func (*GetWorkflowResponse) ProtoMessage()

+ func (x *GetWorkflowResponse) GetInstanceId() string

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

+ func (x *GetWorkflowResponse) GetStartTime() int64

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

+ func (x *GetWorkflowResponse) Reset()

+ func (x *GetWorkflowResponse) String() string

+ type PubsubSubscription struct

+ DeadLetterTopic string

+ Metadata map[string]string

+ PubsubName string

+ Rules *PubsubSubscriptionRules

+ Topic string

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

+ func (*PubsubSubscription) ProtoMessage()

+ func (x *PubsubSubscription) GetDeadLetterTopic() string

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

+ func (x *PubsubSubscription) GetPubsubName() string

+ func (x *PubsubSubscription) GetRules() *PubsubSubscriptionRules

+ func (x *PubsubSubscription) GetTopic() string

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

+ func (x *PubsubSubscription) Reset()

+ func (x *PubsubSubscription) String() string

+ type PubsubSubscriptionRule struct

+ Match string

+ Path string

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

+ func (*PubsubSubscriptionRule) ProtoMessage()

+ func (x *PubsubSubscriptionRule) GetMatch() string

+ func (x *PubsubSubscriptionRule) GetPath() string

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

+ func (x *PubsubSubscriptionRule) Reset()

+ func (x *PubsubSubscriptionRule) String() string

+ type PubsubSubscriptionRules struct

+ Rules []*PubsubSubscriptionRule

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

+ func (*PubsubSubscriptionRules) ProtoMessage()

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

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

+ func (x *PubsubSubscriptionRules) Reset()

+ func (x *PubsubSubscriptionRules) String() string

+ type StartWorkflowRequest struct

+ Input []byte

+ InstanceId string

+ Options map[string]string

+ WorkflowComponent string

+ WorkflowName string

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

+ func (*StartWorkflowRequest) ProtoMessage()

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

+ func (x *StartWorkflowRequest) GetInstanceId() string

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

+ func (x *StartWorkflowRequest) GetWorkflowComponent() string

+ func (x *StartWorkflowRequest) GetWorkflowName() string

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

+ func (x *StartWorkflowRequest) Reset()

+ func (x *StartWorkflowRequest) String() string

+ type TerminateWorkflowRequest struct

+ InstanceId string

+ WorkflowComponent string

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

+ func (*TerminateWorkflowRequest) ProtoMessage()

+ func (x *TerminateWorkflowRequest) GetInstanceId() string

+ func (x *TerminateWorkflowRequest) GetWorkflowComponent() string

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

+ func (x *TerminateWorkflowRequest) Reset()

+ func (x *TerminateWorkflowRequest) String() string

+ type TerminateWorkflowResponse struct

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

+ func (*TerminateWorkflowResponse) ProtoMessage()

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

+ func (x *TerminateWorkflowResponse) Reset()

+ func (x *TerminateWorkflowResponse) String() string

+ type TopicEventBulkRequest struct

+ Entries []*TopicEventBulkRequestEntry

+ Id string

+ Metadata map[string]string

+ Path string

+ PubsubName string

+ Topic string

+ Type string

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

+ func (*TopicEventBulkRequest) ProtoMessage()

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

+ func (x *TopicEventBulkRequest) GetId() string

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

+ func (x *TopicEventBulkRequest) GetPath() string

+ func (x *TopicEventBulkRequest) GetPubsubName() string

+ func (x *TopicEventBulkRequest) GetTopic() string

+ func (x *TopicEventBulkRequest) GetType() string

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

+ func (x *TopicEventBulkRequest) Reset()

+ func (x *TopicEventBulkRequest) String() string

+ type TopicEventBulkRequestEntry struct

+ ContentType string

+ EntryId string

+ Event isTopicEventBulkRequestEntry_Event

+ Metadata map[string]string

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

+ func (*TopicEventBulkRequestEntry) ProtoMessage()

+ func (m *TopicEventBulkRequestEntry) GetEvent() isTopicEventBulkRequestEntry_Event

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

+ func (x *TopicEventBulkRequestEntry) GetCloudEvent() *TopicEventCERequest

+ func (x *TopicEventBulkRequestEntry) GetContentType() string

+ func (x *TopicEventBulkRequestEntry) GetEntryId() string

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

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

+ func (x *TopicEventBulkRequestEntry) Reset()

+ func (x *TopicEventBulkRequestEntry) String() string

+ type TopicEventBulkRequestEntry_Bytes struct

+ Bytes []byte

+ type TopicEventBulkRequestEntry_CloudEvent struct

+ CloudEvent *TopicEventCERequest

+ type TopicEventBulkResponse struct

+ Statuses []*TopicEventBulkResponseEntry

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

+ func (*TopicEventBulkResponse) ProtoMessage()

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

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

+ func (x *TopicEventBulkResponse) Reset()

+ func (x *TopicEventBulkResponse) String() string

+ type TopicEventBulkResponseEntry struct

+ EntryId string

+ Status TopicEventResponse_TopicEventResponseStatus

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

+ func (*TopicEventBulkResponseEntry) ProtoMessage()

+ func (x *TopicEventBulkResponseEntry) GetEntryId() string

+ func (x *TopicEventBulkResponseEntry) GetStatus() TopicEventResponse_TopicEventResponseStatus

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

+ func (x *TopicEventBulkResponseEntry) Reset()

+ func (x *TopicEventBulkResponseEntry) String() string

+ type TopicEventCERequest struct

+ Data []byte

+ DataContentType string

+ Extensions *structpb.Struct

+ Id string

+ Source string

+ SpecVersion string

+ Type string

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

+ func (*TopicEventCERequest) ProtoMessage()

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

+ func (x *TopicEventCERequest) GetDataContentType() string

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

+ func (x *TopicEventCERequest) GetId() string

+ func (x *TopicEventCERequest) GetSource() string

+ func (x *TopicEventCERequest) GetSpecVersion() string

+ func (x *TopicEventCERequest) GetType() string

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

+ func (x *TopicEventCERequest) Reset()

+ func (x *TopicEventCERequest) String() string

type TopicEventRequest

+ Extensions *structpb.Struct

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

type TopicSubscription

+ BulkSubscribe *BulkSubscribeConfig

+ func (x *TopicSubscription) GetBulkSubscribe() *BulkSubscribeConfig

+ type UnimplementedAppCallbackAlphaServer struct

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

type UnimplementedDaprServer

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

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

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

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

+ type UnsafeAppCallbackAlphaServer interface

+ type WorkflowReference struct

+ InstanceId string

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

+ func (*WorkflowReference) ProtoMessage()

+ func (x *WorkflowReference) GetInstanceId() string

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

+ func (x *WorkflowReference) Reset()

+ func (x *WorkflowReference) String() string

Feb 15, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 14, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 13, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 9, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 7, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 6, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 3, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 1, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jan 30, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 2, 2023 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 1, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 17, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 3, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 31, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 26, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 13, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var AppCallbackHealthCheck_ServiceDesc = grpc.ServiceDesc

+ func RegisterAppCallbackHealthCheckServer(s grpc.ServiceRegistrar, srv AppCallbackHealthCheckServer)

+ type AppCallbackHealthCheckClient interface

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

+ func NewAppCallbackHealthCheckClient(cc grpc.ClientConnInterface) AppCallbackHealthCheckClient

+ type AppCallbackHealthCheckServer interface

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

+ type HealthCheckResponse struct

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

+ func (*HealthCheckResponse) ProtoMessage()

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

+ func (x *HealthCheckResponse) Reset()

+ func (x *HealthCheckResponse) String() string

type InvokeActorRequest

+ Metadata map[string]string

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

+ type UnimplementedAppCallbackHealthCheckServer struct

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

type UnlockResponse_Status

+ const UnlockResponse_LOCK_BELONGS_TO_OTHERS

+ const UnlockResponse_LOCK_DOES_NOT_EXIST

+ type UnsafeAppCallbackHealthCheckServer interface

Oct 13, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 12, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 6, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 4, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 2, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 30, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 30, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 2, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 26, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 13, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Aug 11, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 28, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 21, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 19, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 7, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var UnlockResponse_Status_name = map[int32]string

+ var UnlockResponse_Status_value = map[string]int32

type DaprClient

+ TryLockAlpha1 func(ctx context.Context, in *TryLockRequest, opts ...grpc.CallOption) (*TryLockResponse, error)

+ UnlockAlpha1 func(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)

type DaprServer

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

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

type RegisteredComponents

+ Capabilities []string

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

type TopicSubscription

+ DeadLetterTopic string

+ func (x *TopicSubscription) GetDeadLetterTopic() string

+ type TryLockRequest struct

+ ExpiryInSeconds int32

+ LockOwner string

+ ResourceId string

+ StoreName string

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

+ func (*TryLockRequest) ProtoMessage()

+ func (x *TryLockRequest) GetExpiryInSeconds() int32

+ func (x *TryLockRequest) GetLockOwner() string

+ func (x *TryLockRequest) GetResourceId() string

+ func (x *TryLockRequest) GetStoreName() string

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

+ func (x *TryLockRequest) Reset()

+ func (x *TryLockRequest) String() string

+ type TryLockResponse struct

+ Success bool

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

+ func (*TryLockResponse) ProtoMessage()

+ func (x *TryLockResponse) GetSuccess() bool

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

+ func (x *TryLockResponse) Reset()

+ func (x *TryLockResponse) String() string

type UnimplementedDaprServer

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

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

+ type UnlockRequest struct

+ LockOwner string

+ ResourceId string

+ StoreName string

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

+ func (*UnlockRequest) ProtoMessage()

+ func (x *UnlockRequest) GetLockOwner() string

+ func (x *UnlockRequest) GetResourceId() string

+ func (x *UnlockRequest) GetStoreName() string

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

+ func (x *UnlockRequest) Reset()

+ func (x *UnlockRequest) String() string

+ type UnlockResponse struct

+ Status UnlockResponse_Status

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

+ func (*UnlockResponse) ProtoMessage()

+ func (x *UnlockResponse) GetStatus() UnlockResponse_Status

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

+ func (x *UnlockResponse) Reset()

+ func (x *UnlockResponse) String() string

+ type UnlockResponse_Status int32

+ const UnlockResponse_INTERNAL_ERROR

+ const UnlockResponse_LOCK_BELONG_TO_OTHERS

+ const UnlockResponse_LOCK_UNEXIST

+ const UnlockResponse_SUCCESS

+ func (UnlockResponse_Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (UnlockResponse_Status) Type() protoreflect.EnumType

+ func (x UnlockResponse_Status) Enum() *UnlockResponse_Status

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

+ func (x UnlockResponse_Status) String() string

Jul 7, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 6, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 5, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 1, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 27, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 23, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 22, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 22, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 2, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 26, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 31, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 18, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 22, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 21, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 15, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 15, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 7, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

type DaprClient

+ UnsubscribeConfigurationAlpha1 func(ctx context.Context, in *UnsubscribeConfigurationRequest, ...) (*UnsubscribeConfigurationResponse, error)

type DaprServer

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

type SubscribeConfigurationResponse

+ Id string

+ func (x *SubscribeConfigurationResponse) GetId() string

type UnimplementedDaprServer

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

+ type UnsubscribeConfigurationRequest struct

+ Id string

+ StoreName string

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

+ func (*UnsubscribeConfigurationRequest) ProtoMessage()

+ func (x *UnsubscribeConfigurationRequest) GetId() string

+ func (x *UnsubscribeConfigurationRequest) GetStoreName() string

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

+ func (x *UnsubscribeConfigurationRequest) Reset()

+ func (x *UnsubscribeConfigurationRequest) String() string

+ type UnsubscribeConfigurationResponse struct

+ Message string

+ Ok bool

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

+ func (*UnsubscribeConfigurationResponse) ProtoMessage()

+ func (x *UnsubscribeConfigurationResponse) GetMessage() string

+ func (x *UnsubscribeConfigurationResponse) GetOk() bool

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

+ func (x *UnsubscribeConfigurationResponse) Reset()

+ func (x *UnsubscribeConfigurationResponse) String() string

Apr 7, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 6, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 30, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 28, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 20, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 20, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 15, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 25, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jan 24, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

type DaprClient

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

type DaprServer

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

+ type RenameActorReminderRequest struct

+ ActorId string

+ ActorType string

+ NewName string

+ OldName string

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

+ func (*RenameActorReminderRequest) ProtoMessage()

+ func (x *RenameActorReminderRequest) GetActorId() string

+ func (x *RenameActorReminderRequest) GetActorType() string

+ func (x *RenameActorReminderRequest) GetNewName() string

+ func (x *RenameActorReminderRequest) GetOldName() string

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

+ func (x *RenameActorReminderRequest) Reset()

+ func (x *RenameActorReminderRequest) String() string

type UnimplementedDaprServer

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

Jan 21, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jan 18, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jan 14, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jan 14, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 1, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 25, 2022 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 6, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 3, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 1, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 30, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 11, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

type DaprClient

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

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

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

type DaprServer

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

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

+ SubscribeConfigurationAlpha1 func(*SubscribeConfigurationRequest, Dapr_SubscribeConfigurationAlpha1Server) error

+ type Dapr_SubscribeConfigurationAlpha1Client interface

+ Recv func() (*SubscribeConfigurationResponse, error)

+ type Dapr_SubscribeConfigurationAlpha1Server interface

+ Send func(*SubscribeConfigurationResponse) error

+ 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 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 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 UnimplementedDaprServer

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

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

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

Nov 11, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 9, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 5, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 4, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 6, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 2, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 30, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 8, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 7, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 25, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 24, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 22, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 15, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

type RegisterActorReminderRequest

+ Ttl string

+ func (x *RegisterActorReminderRequest) GetTtl() string

type RegisterActorTimerRequest

+ Ttl string

+ func (x *RegisterActorTimerRequest) GetTtl() string

type TopicEventRequest

+ Path string

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

+ Routes *TopicRoutes

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

Sep 13, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 10, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 10, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 10, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 9, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 8, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 8, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 15, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 26, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 23, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 21, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 20, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 15, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 17, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 16, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 26, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 22, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 21, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 19, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 18, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

May 18, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 16, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 14, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 6, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Apr 1, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

type DaprClient

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

type DaprServer

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

type UnimplementedDaprServer

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

Mar 31, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 25, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Mar 4, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Feb 17, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var AppCallback_ServiceDesc = grpc.ServiceDesc

+ 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

+ 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 BindingEventRequest

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

type BindingEventResponse

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

type BindingEventResponse_BindingEventConcurrency

+ func (BindingEventResponse_BindingEventConcurrency) Descriptor() protoreflect.EnumDescriptor

+ func (BindingEventResponse_BindingEventConcurrency) Type() protoreflect.EnumType

+ func (x BindingEventResponse_BindingEventConcurrency) Enum() *BindingEventResponse_BindingEventConcurrency

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

type BulkStateItem

+ Metadata map[string]string

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

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

type DaprClient

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

+ ExecuteActorStateTransaction func(ctx context.Context, in *ExecuteActorStateTransactionRequest, ...) (*empty.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)

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

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

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

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

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

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

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

type DaprServer

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

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

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

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

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

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

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

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

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

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

+ UnregisterActorTimer func(context.Context, *UnregisterActorTimerRequest) (*empty.Empty, 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

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

+ 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

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

+ 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

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

type GetBulkStateResponse

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

+ 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

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

type GetSecretResponse

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

type GetStateRequest

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

type GetStateResponse

+ Metadata map[string]string

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

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

+ 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

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

type InvokeBindingResponse

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

type InvokeServiceRequest

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

type ListInputBindingsResponse

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

type ListTopicSubscriptionsResponse

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

type PublishEventRequest

+ DataContentType string

+ Metadata map[string]string

+ func (x *PublishEventRequest) GetDataContentType() string

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

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

+ type RegisterActorReminderRequest struct

+ ActorId string

+ ActorType string

+ Data []byte

+ DueTime string

+ Name string

+ Period 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) 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

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

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

+ 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 TopicEventRequest

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

type TopicEventResponse

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

type TopicEventResponse_TopicEventResponseStatus

+ func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

+ func (TopicEventResponse_TopicEventResponseStatus) Type() protoreflect.EnumType

+ func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

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

type TopicSubscription

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

+ type TransactionalActorStateOperation struct

+ Key string

+ OperationType string

+ Value *any.Any

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

+ func (*TransactionalActorStateOperation) ProtoMessage()

+ func (x *TransactionalActorStateOperation) GetKey() string

+ func (x *TransactionalActorStateOperation) GetOperationType() string

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

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

+ func (x *TransactionalActorStateOperation) Reset()

+ func (x *TransactionalActorStateOperation) String() string

type TransactionalStateOperation

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

type UnimplementedDaprServer

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

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

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

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

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

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

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

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

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

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

+ func (UnimplementedDaprServer) UnregisterActorTimer(context.Context, *UnregisterActorTimerRequest) (*empty.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

Feb 11, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jan 28, 2021 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Dec 17, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Nov 11, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 23, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 5, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Oct 3, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 30, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var TopicEventResponse_TopicEventResponseStatus_name = map[int32]string

+ var TopicEventResponse_TopicEventResponseStatus_value = map[string]int32

type BulkStateItem

+ Error string

+ func (m *BulkStateItem) GetError() string

type DeleteStateRequest

+ Metadata map[string]string

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

type GetBulkStateRequest

+ Metadata map[string]string

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

type GetStateRequest

+ Metadata map[string]string

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

type TopicEventResponse

+ Status TopicEventResponse_TopicEventResponseStatus

+ func (m *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

+ type TopicEventResponse_TopicEventResponseStatus int32

+ const TopicEventResponse_DROP

+ const TopicEventResponse_RETRY

+ const TopicEventResponse_SUCCESS

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

+ func (x TopicEventResponse_TopicEventResponseStatus) String() string

Sep 30, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 28, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 25, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 25, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Sep 24, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Aug 20, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ type BulkStateItem struct

+ Data []byte

+ Etag string

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BulkStateItem) ProtoMessage()

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

+ func (m *BulkStateItem) GetEtag() string

+ func (m *BulkStateItem) GetKey() string

+ func (m *BulkStateItem) Reset()

+ func (m *BulkStateItem) String() string

+ func (m *BulkStateItem) XXX_DiscardUnknown()

+ func (m *BulkStateItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BulkStateItem) XXX_Merge(src proto.Message)

+ func (m *BulkStateItem) XXX_Size() int

+ func (m *BulkStateItem) XXX_Unmarshal(b []byte) error

type DaprClient

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

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

type DaprServer

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

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

+ type ExecuteStateTransactionRequest struct

+ Metadata map[string]string

+ Operations []*TransactionalStateOperation

+ StoreName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecuteStateTransactionRequest) ProtoMessage()

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

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

+ func (m *ExecuteStateTransactionRequest) GetStoreName() string

+ func (m *ExecuteStateTransactionRequest) Reset()

+ func (m *ExecuteStateTransactionRequest) String() string

+ func (m *ExecuteStateTransactionRequest) XXX_DiscardUnknown()

+ func (m *ExecuteStateTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecuteStateTransactionRequest) XXX_Merge(src proto.Message)

+ func (m *ExecuteStateTransactionRequest) XXX_Size() int

+ func (m *ExecuteStateTransactionRequest) XXX_Unmarshal(b []byte) error

+ type GetBulkStateRequest struct

+ Keys []string

+ Parallelism int32

+ StoreName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetBulkStateRequest) ProtoMessage()

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

+ func (m *GetBulkStateRequest) GetParallelism() int32

+ func (m *GetBulkStateRequest) GetStoreName() string

+ func (m *GetBulkStateRequest) Reset()

+ func (m *GetBulkStateRequest) String() string

+ func (m *GetBulkStateRequest) XXX_DiscardUnknown()

+ func (m *GetBulkStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetBulkStateRequest) XXX_Merge(src proto.Message)

+ func (m *GetBulkStateRequest) XXX_Size() int

+ func (m *GetBulkStateRequest) XXX_Unmarshal(b []byte) error

+ type GetBulkStateResponse struct

+ Items []*BulkStateItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetBulkStateResponse) ProtoMessage()

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

+ func (m *GetBulkStateResponse) Reset()

+ func (m *GetBulkStateResponse) String() string

+ func (m *GetBulkStateResponse) XXX_DiscardUnknown()

+ func (m *GetBulkStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetBulkStateResponse) XXX_Merge(src proto.Message)

+ func (m *GetBulkStateResponse) XXX_Size() int

+ func (m *GetBulkStateResponse) XXX_Unmarshal(b []byte) error

type PublishEventRequest

+ PubsubName string

+ func (m *PublishEventRequest) GetPubsubName() string

type TopicEventRequest

+ PubsubName string

+ func (m *TopicEventRequest) GetPubsubName() string

+ type TopicEventResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TopicEventResponse) ProtoMessage()

+ func (m *TopicEventResponse) Reset()

+ func (m *TopicEventResponse) String() string

+ func (m *TopicEventResponse) XXX_DiscardUnknown()

+ func (m *TopicEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopicEventResponse) XXX_Merge(src proto.Message)

+ func (m *TopicEventResponse) XXX_Size() int

+ func (m *TopicEventResponse) XXX_Unmarshal(b []byte) error

type TopicSubscription

+ PubsubName string

+ func (m *TopicSubscription) GetPubsubName() string

+ type TransactionalStateOperation struct

+ OperationType string

+ Request *v1.StateItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TransactionalStateOperation) ProtoMessage()

+ func (m *TransactionalStateOperation) GetOperationType() string

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

+ func (m *TransactionalStateOperation) Reset()

+ func (m *TransactionalStateOperation) String() string

+ func (m *TransactionalStateOperation) XXX_DiscardUnknown()

+ func (m *TransactionalStateOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransactionalStateOperation) XXX_Merge(src proto.Message)

+ func (m *TransactionalStateOperation) XXX_Size() int

+ func (m *TransactionalStateOperation) XXX_Unmarshal(b []byte) error

type UnimplementedDaprServer

+ func (*UnimplementedDaprServer) ExecuteStateTransaction(ctx context.Context, req *ExecuteStateTransactionRequest) (*empty.Empty, error)

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

Aug 18, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 16, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 14, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jul 13, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 9, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Changes in this version

+ var BindingEventResponse_BindingEventConcurrency_name = map[int32]string

+ var BindingEventResponse_BindingEventConcurrency_value = map[string]int32

+ func RegisterAppCallbackServer(s *grpc.Server, srv AppCallbackServer)

+ func RegisterDaprServer(s *grpc.Server, srv DaprServer)

+ type AppCallbackClient interface

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

+ ListTopicSubscriptions func(ctx context.Context, in *empty.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) (*empty.Empty, error)

+ func NewAppCallbackClient(cc *grpc.ClientConn) AppCallbackClient

+ type AppCallbackServer interface

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

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

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

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

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

+ type BindingEventRequest struct

+ Data []byte

+ Metadata map[string]string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BindingEventRequest) ProtoMessage()

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

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

+ func (m *BindingEventRequest) GetName() string

+ func (m *BindingEventRequest) Reset()

+ func (m *BindingEventRequest) String() string

+ func (m *BindingEventRequest) XXX_DiscardUnknown()

+ func (m *BindingEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BindingEventRequest) XXX_Merge(src proto.Message)

+ func (m *BindingEventRequest) XXX_Size() int

+ func (m *BindingEventRequest) XXX_Unmarshal(b []byte) error

+ type BindingEventResponse struct

+ Concurrency BindingEventResponse_BindingEventConcurrency

+ Data []byte

+ States []*v1.StateItem

+ StoreName string

+ To []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BindingEventResponse) ProtoMessage()

+ func (m *BindingEventResponse) GetConcurrency() BindingEventResponse_BindingEventConcurrency

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

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

+ func (m *BindingEventResponse) GetStoreName() string

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

+ func (m *BindingEventResponse) Reset()

+ func (m *BindingEventResponse) String() string

+ func (m *BindingEventResponse) XXX_DiscardUnknown()

+ func (m *BindingEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BindingEventResponse) XXX_Merge(src proto.Message)

+ func (m *BindingEventResponse) XXX_Size() int

+ func (m *BindingEventResponse) XXX_Unmarshal(b []byte) error

+ type BindingEventResponse_BindingEventConcurrency int32

+ const BindingEventResponse_PARALLEL

+ const BindingEventResponse_SEQUENTIAL

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

+ func (x BindingEventResponse_BindingEventConcurrency) String() string

+ type DaprClient interface

+ DeleteState func(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*empty.Empty, 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)

+ 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) (*empty.Empty, error)

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

+ func NewDaprClient(cc *grpc.ClientConn) DaprClient

+ type DaprServer interface

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

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

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

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

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

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

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

+ type DeleteStateRequest struct

+ Etag string

+ Key string

+ Options *v1.StateOptions

+ StoreName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteStateRequest) ProtoMessage()

+ func (m *DeleteStateRequest) GetEtag() string

+ func (m *DeleteStateRequest) GetKey() string

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

+ func (m *DeleteStateRequest) GetStoreName() string

+ func (m *DeleteStateRequest) Reset()

+ func (m *DeleteStateRequest) String() string

+ func (m *DeleteStateRequest) XXX_DiscardUnknown()

+ func (m *DeleteStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteStateRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteStateRequest) XXX_Size() int

+ func (m *DeleteStateRequest) XXX_Unmarshal(b []byte) error

+ type GetSecretRequest struct

+ Key string

+ Metadata map[string]string

+ StoreName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetSecretRequest) ProtoMessage()

+ func (m *GetSecretRequest) GetKey() string

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

+ func (m *GetSecretRequest) GetStoreName() string

+ func (m *GetSecretRequest) Reset()

+ func (m *GetSecretRequest) String() string

+ func (m *GetSecretRequest) XXX_DiscardUnknown()

+ func (m *GetSecretRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetSecretRequest) XXX_Merge(src proto.Message)

+ func (m *GetSecretRequest) XXX_Size() int

+ func (m *GetSecretRequest) XXX_Unmarshal(b []byte) error

+ type GetSecretResponse struct

+ Data map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetSecretResponse) ProtoMessage()

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

+ func (m *GetSecretResponse) Reset()

+ func (m *GetSecretResponse) String() string

+ func (m *GetSecretResponse) XXX_DiscardUnknown()

+ func (m *GetSecretResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetSecretResponse) XXX_Merge(src proto.Message)

+ func (m *GetSecretResponse) XXX_Size() int

+ func (m *GetSecretResponse) XXX_Unmarshal(b []byte) error

+ type GetStateRequest struct

+ Consistency v1.StateOptions_StateConsistency

+ Key string

+ StoreName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetStateRequest) ProtoMessage()

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

+ func (m *GetStateRequest) GetKey() string

+ func (m *GetStateRequest) GetStoreName() string

+ func (m *GetStateRequest) Reset()

+ func (m *GetStateRequest) String() string

+ func (m *GetStateRequest) XXX_DiscardUnknown()

+ func (m *GetStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetStateRequest) XXX_Merge(src proto.Message)

+ func (m *GetStateRequest) XXX_Size() int

+ func (m *GetStateRequest) XXX_Unmarshal(b []byte) error

+ type GetStateResponse struct

+ Data []byte

+ Etag string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetStateResponse) ProtoMessage()

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

+ func (m *GetStateResponse) GetEtag() string

+ func (m *GetStateResponse) Reset()

+ func (m *GetStateResponse) String() string

+ func (m *GetStateResponse) XXX_DiscardUnknown()

+ func (m *GetStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetStateResponse) XXX_Merge(src proto.Message)

+ func (m *GetStateResponse) XXX_Size() int

+ func (m *GetStateResponse) XXX_Unmarshal(b []byte) error

+ type InvokeBindingRequest struct

+ Data []byte

+ Metadata map[string]string

+ Name string

+ Operation string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InvokeBindingRequest) ProtoMessage()

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

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

+ func (m *InvokeBindingRequest) GetName() string

+ func (m *InvokeBindingRequest) GetOperation() string

+ func (m *InvokeBindingRequest) Reset()

+ func (m *InvokeBindingRequest) String() string

+ func (m *InvokeBindingRequest) XXX_DiscardUnknown()

+ func (m *InvokeBindingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InvokeBindingRequest) XXX_Merge(src proto.Message)

+ func (m *InvokeBindingRequest) XXX_Size() int

+ func (m *InvokeBindingRequest) XXX_Unmarshal(b []byte) error

+ type InvokeBindingResponse struct

+ Data []byte

+ Metadata map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InvokeBindingResponse) ProtoMessage()

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

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

+ func (m *InvokeBindingResponse) Reset()

+ func (m *InvokeBindingResponse) String() string

+ func (m *InvokeBindingResponse) XXX_DiscardUnknown()

+ func (m *InvokeBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InvokeBindingResponse) XXX_Merge(src proto.Message)

+ func (m *InvokeBindingResponse) XXX_Size() int

+ func (m *InvokeBindingResponse) XXX_Unmarshal(b []byte) error

+ type InvokeServiceRequest struct

+ Id string

+ Message *v1.InvokeRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InvokeServiceRequest) ProtoMessage()

+ func (m *InvokeServiceRequest) GetId() string

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

+ func (m *InvokeServiceRequest) Reset()

+ func (m *InvokeServiceRequest) String() string

+ func (m *InvokeServiceRequest) XXX_DiscardUnknown()

+ func (m *InvokeServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InvokeServiceRequest) XXX_Merge(src proto.Message)

+ func (m *InvokeServiceRequest) XXX_Size() int

+ func (m *InvokeServiceRequest) XXX_Unmarshal(b []byte) error

+ type ListInputBindingsResponse struct

+ Bindings []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListInputBindingsResponse) ProtoMessage()

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

+ func (m *ListInputBindingsResponse) Reset()

+ func (m *ListInputBindingsResponse) String() string

+ func (m *ListInputBindingsResponse) XXX_DiscardUnknown()

+ func (m *ListInputBindingsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListInputBindingsResponse) XXX_Merge(src proto.Message)

+ func (m *ListInputBindingsResponse) XXX_Size() int

+ func (m *ListInputBindingsResponse) XXX_Unmarshal(b []byte) error

+ type ListTopicSubscriptionsResponse struct

+ Subscriptions []*TopicSubscription

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListTopicSubscriptionsResponse) ProtoMessage()

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

+ func (m *ListTopicSubscriptionsResponse) Reset()

+ func (m *ListTopicSubscriptionsResponse) String() string

+ func (m *ListTopicSubscriptionsResponse) XXX_DiscardUnknown()

+ func (m *ListTopicSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListTopicSubscriptionsResponse) XXX_Merge(src proto.Message)

+ func (m *ListTopicSubscriptionsResponse) XXX_Size() int

+ func (m *ListTopicSubscriptionsResponse) XXX_Unmarshal(b []byte) error

+ type PublishEventRequest struct

+ Data []byte

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishEventRequest) ProtoMessage()

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

+ func (m *PublishEventRequest) GetTopic() string

+ func (m *PublishEventRequest) Reset()

+ func (m *PublishEventRequest) String() string

+ func (m *PublishEventRequest) XXX_DiscardUnknown()

+ func (m *PublishEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PublishEventRequest) XXX_Merge(src proto.Message)

+ func (m *PublishEventRequest) XXX_Size() int

+ func (m *PublishEventRequest) XXX_Unmarshal(b []byte) error

+ type SaveStateRequest struct

+ States []*v1.StateItem

+ StoreName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SaveStateRequest) ProtoMessage()

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

+ func (m *SaveStateRequest) GetStoreName() string

+ func (m *SaveStateRequest) Reset()

+ func (m *SaveStateRequest) String() string

+ func (m *SaveStateRequest) XXX_DiscardUnknown()

+ func (m *SaveStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SaveStateRequest) XXX_Merge(src proto.Message)

+ func (m *SaveStateRequest) XXX_Size() int

+ func (m *SaveStateRequest) XXX_Unmarshal(b []byte) error

+ type TopicEventRequest struct

+ Data []byte

+ DataContentType string

+ Id string

+ Source string

+ SpecVersion string

+ Topic string

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TopicEventRequest) ProtoMessage()

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

+ func (m *TopicEventRequest) GetDataContentType() string

+ func (m *TopicEventRequest) GetId() string

+ func (m *TopicEventRequest) GetSource() string

+ func (m *TopicEventRequest) GetSpecVersion() string

+ func (m *TopicEventRequest) GetTopic() string

+ func (m *TopicEventRequest) GetType() string

+ func (m *TopicEventRequest) Reset()

+ func (m *TopicEventRequest) String() string

+ func (m *TopicEventRequest) XXX_DiscardUnknown()

+ func (m *TopicEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopicEventRequest) XXX_Merge(src proto.Message)

+ func (m *TopicEventRequest) XXX_Size() int

+ func (m *TopicEventRequest) XXX_Unmarshal(b []byte) error

+ type TopicSubscription struct

+ Metadata map[string]string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TopicSubscription) ProtoMessage()

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

+ func (m *TopicSubscription) GetTopic() string

+ func (m *TopicSubscription) Reset()

+ func (m *TopicSubscription) String() string

+ func (m *TopicSubscription) XXX_DiscardUnknown()

+ func (m *TopicSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopicSubscription) XXX_Merge(src proto.Message)

+ func (m *TopicSubscription) XXX_Size() int

+ func (m *TopicSubscription) XXX_Unmarshal(b []byte) error

+ type UnimplementedAppCallbackServer struct

+ func (*UnimplementedAppCallbackServer) ListInputBindings(ctx context.Context, req *empty.Empty) (*ListInputBindingsResponse, error)

+ func (*UnimplementedAppCallbackServer) ListTopicSubscriptions(ctx context.Context, req *empty.Empty) (*ListTopicSubscriptionsResponse, error)

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

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

+ func (*UnimplementedAppCallbackServer) OnTopicEvent(ctx context.Context, req *TopicEventRequest) (*empty.Empty, error)

+ type UnimplementedDaprServer struct

+ func (*UnimplementedDaprServer) DeleteState(ctx context.Context, req *DeleteStateRequest) (*empty.Empty, error)

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

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

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

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

+ func (*UnimplementedDaprServer) PublishEvent(ctx context.Context, req *PublishEventRequest) (*empty.Empty, error)

+ func (*UnimplementedDaprServer) SaveState(ctx context.Context, req *SaveStateRequest) (*empty.Empty, error)

Jun 8, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 6, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

Jun 5, 2020 GO-2023-1955

  GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr