Documentation
¶
Index ¶
- Variables
- func NewMessageClient(client *rpc.Client) (pb.MessageClient, error)
- func NewMiddleClient(client *rpc.Client) (pb.MiddleClient, error)
- func NewStorageClient(client *rpc.Client) (pb.StorageClient, error)
- func NewSubscribeClient(client *rpc.Client) (pb.SubscribeClient, error)
- func NewTaskClient(client *rpc.Client) (pb.TaskClient, error)
- func NewWorkflowClient(client *rpc.Client) (pb.WorkflowClient, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewMessageClient, NewSubscribeClient, NewMiddleClient, NewWorkflowClient, NewTaskClient, NewStorageClient)
Functions ¶
func NewMessageClient ¶ added in v0.0.15
func NewMessageClient(client *rpc.Client) (pb.MessageClient, error)
func NewMiddleClient ¶
func NewMiddleClient(client *rpc.Client) (pb.MiddleClient, error)
func NewStorageClient ¶ added in v0.0.22
func NewStorageClient(client *rpc.Client) (pb.StorageClient, error)
func NewSubscribeClient ¶
func NewSubscribeClient(client *rpc.Client) (pb.SubscribeClient, error)
func NewTaskClient ¶ added in v0.0.17
func NewTaskClient(client *rpc.Client) (pb.TaskClient, error)
func NewWorkflowClient ¶ added in v0.0.9
func NewWorkflowClient(client *rpc.Client) (pb.WorkflowClient, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.