dapr

Documentation

Index

• Constants
• func BulkGetResponse2BulkStateItem(compResp *state.BulkGetResponse) *dapr_v1pb.BulkStateItem
• func DeleteStateRequest2DeleteRequest(grpcReq *dapr_v1pb.DeleteStateRequest, key string) *state.DeleteRequest
• func GetResponse2BulkStateItem(compResp *state.GetResponse, key string) *dapr_v1pb.BulkStateItem
• func GetResponse2GetStateResponse(compResp *state.GetResponse) *dapr_v1pb.GetStateResponse
• func NewDaprAPI_Alpha(ac *grpc_api.ApplicationContext) grpc_api.GrpcAPI
• func StateConcurrencyToString(c dapr_common_v1pb.StateOptions_StateConcurrency) string
• func StateConsistencyToString(c dapr_common_v1pb.StateOptions_StateConsistency) string
• func StateItem2DeleteRequest(grpcReq *dapr_common_v1pb.StateItem, key string) *state.DeleteRequest
• func StateItem2SetRequest(grpcReq *dapr_common_v1pb.StateItem, key string) *state.SetRequest
• type DaprGrpcAPI
  • func NewDaprServer(appId string, hellos map[string]hello.HelloService, ...) DaprGrpcAPI
• type Details
• type TopicSubscriptions

Constants

const (
	Metadata_key_pubsubName = "pubsubName"
)

Functions

func BulkGetResponse2BulkStateItem

func BulkGetResponse2BulkStateItem(compResp *state.BulkGetResponse) *dapr_v1pb.BulkStateItem

converting from BulkGetResponse to BulkStateItem

func DeleteStateRequest2DeleteRequest

func DeleteStateRequest2DeleteRequest(grpcReq *dapr_v1pb.DeleteStateRequest, key string) *state.DeleteRequest

converting from DeleteStateRequest to DeleteRequest

func GetResponse2BulkStateItem

func GetResponse2BulkStateItem(compResp *state.GetResponse, key string) *dapr_v1pb.BulkStateItem

converting from GetResponse to BulkStateItem

func GetResponse2GetStateResponse

func GetResponse2GetStateResponse(compResp *state.GetResponse) *dapr_v1pb.GetStateResponse

func NewDaprAPI_Alpha

func NewDaprAPI_Alpha(ac *grpc_api.ApplicationContext) grpc_api.GrpcAPI

NewDaprAPI_Alpha construct a grpc_api.GrpcAPI which implements DaprServer. Currently it only support Dapr's InvokeService and InvokeBinding API. Note: this feature is still in Alpha state and we don't recommend that you use it in your production environment.

func StateConcurrencyToString

func StateConcurrencyToString(c dapr_common_v1pb.StateOptions_StateConcurrency) string

func StateConsistencyToString

func StateConsistencyToString(c dapr_common_v1pb.StateOptions_StateConsistency) string

func StateItem2DeleteRequest

func StateItem2DeleteRequest(grpcReq *dapr_common_v1pb.StateItem, key string) *state.DeleteRequest

converting from StateItem to DeleteRequest

func StateItem2SetRequest

func StateItem2SetRequest(grpcReq *dapr_common_v1pb.StateItem, key string) *state.SetRequest

Types

type DaprGrpcAPI

type DaprGrpcAPI interface {
	dapr_v1pb.DaprServer
	grpc_api.GrpcAPI
}

func NewDaprServer

func NewDaprServer(
	appId string,
	hellos map[string]hello.HelloService,
	configStores map[string]configstores.Store,
	rpcs map[string]rpc.Invoker,
	pubSubs map[string]pubsub.PubSub,
	stateStores map[string]state.Store,
	transactionalStateStores map[string]state.TransactionalStore,
	files map[string]file.File,
	lockStores map[string]lock.LockStore,
	sequencers map[string]sequencer.Store,
	sendToOutputBindingFn func(name string, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error),
	secretStores map[string]secretstores.SecretStore,
) DaprGrpcAPI

type Details

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

type TopicSubscriptions

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