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
- type Details
- type TopicSubscriptions
Constants ¶
View Source
const (
Metadata_key_pubsubName = "pubsubName"
)
Variables ¶
This section is empty.
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 TopicSubscriptions ¶ added in v0.5.0
type TopicSubscriptions struct {
// contains filtered or unexported fields
}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.