messaging

Documentation

Index

• type DirectMessageRequest
• type DirectMessageResponse
• type DirectMessaging
  • func NewDirectMessaging(daprID, namespace string, port int, mode modes.DaprMode, ...) DirectMessaging

Types

type DirectMessageRequest

type DirectMessageRequest struct {
	Target   string            `json:"target"`
	Method   string            `json:"method"`
	From     string            `json:"from,omitempty"`
	Metadata map[string]string `json:"metadata"`
	Data     []byte            `json:"data,omitempty"`
}

DirectMessageRequest is the request object for directly invoking a remote app

type DirectMessageResponse

type DirectMessageResponse struct {
	Data     []byte            `json:"data"`
	Metadata map[string]string `json:"metadata"`
}

DirectMessageResponse is the response object for directly invoking a remote app

type DirectMessaging

type DirectMessaging interface {
	Invoke(req *DirectMessageRequest) (*DirectMessageResponse, error)
}

DirectMessaging is the API interface for invoking a remote app

func NewDirectMessaging

func NewDirectMessaging(daprID, namespace string, port int, mode modes.DaprMode, appChannel channel.AppChannel, grpcConnectionFn func(address, id string, skipTLS, recreateIfExists bool) (*grpc.ClientConn, error), resolver servicediscovery.Resolver) DirectMessaging

NewDirectMessaging returns a new direct messaging api