actions

Documentation

Index

• type InternalClient
  • func NewInternalClient() *InternalClient
  • func (c *InternalClient) CreateChannel(ctx context.Context, request *actions.CreateChannelRequest) error
  • func (c *InternalClient) Init(ctx context.Context, arrayService *array.Array, brokerService *broker.Service) error
  • func (c *InternalClient) PurgeQueueChannel(ctx context.Context, request *actions.PurgeQueueChannelRequest) (*actions.PurgeQueueChannelResponse, error)
  • func (c *InternalClient) ReceiveQueueMessages(ctx context.Context, request *actions.ReceiveQueueMessagesRequest) ([]*actions.ReceiveQueueMessageResponse, error)
  • func (c *InternalClient) SendCQRSMessageRequest(ctx context.Context, request *actions.SendCQRSMessageRequest) (*actions.ReceiveCQRSResponse, error)
  • func (c *InternalClient) SendCQRSMessageResponse(ctx context.Context, response *actions.SendCQRSMessageResponse) error
  • func (c *InternalClient) SendPubSubMessage(ctx context.Context, request *actions.SendPubSubMessageRequest) error
  • func (c *InternalClient) SendQueueMessage(ctx context.Context, request *actions.SendQueueMessageRequest) (*actions.SendQueueMessageResponse, error)
  • func (c *InternalClient) StreamQueueMessages(ctx context.Context, requests chan *actions.StreamQueueMessagesRequest, ...)
  • func (c *InternalClient) SubscribeToCommands(ctx context.Context, channel, group string, ...) error
  • func (c *InternalClient) SubscribeToEvents(ctx context.Context, channel, group string, ...) error
  • func (c *InternalClient) SubscribeToEventsStore(ctx context.Context, channel, group, clientId, subType, subValue string, ...) error
  • func (c *InternalClient) SubscribeToQueries(ctx context.Context, channel, group string, ...) error

Types

type InternalClient

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

func NewInternalClient

func NewInternalClient() *InternalClient

func (*InternalClient) CreateChannel

func (c *InternalClient) CreateChannel(ctx context.Context, request *actions.CreateChannelRequest) error

func (*InternalClient) Init

func (c *InternalClient) Init(ctx context.Context, arrayService *array.Array, brokerService *broker.Service) error

func (*InternalClient) PurgeQueueChannel

func (c *InternalClient) PurgeQueueChannel(ctx context.Context, request *actions.PurgeQueueChannelRequest) (*actions.PurgeQueueChannelResponse, error)

func (*InternalClient) ReceiveQueueMessages

func (c *InternalClient) ReceiveQueueMessages(ctx context.Context, request *actions.ReceiveQueueMessagesRequest) ([]*actions.ReceiveQueueMessageResponse, error)

func (*InternalClient) SendCQRSMessageRequest

func (c *InternalClient) SendCQRSMessageRequest(ctx context.Context, request *actions.SendCQRSMessageRequest) (*actions.ReceiveCQRSResponse, error)

func (*InternalClient) SendCQRSMessageResponse

func (c *InternalClient) SendCQRSMessageResponse(ctx context.Context, response *actions.SendCQRSMessageResponse) error

func (*InternalClient) SendPubSubMessage

func (c *InternalClient) SendPubSubMessage(ctx context.Context, request *actions.SendPubSubMessageRequest) error

func (*InternalClient) SendQueueMessage

func (c *InternalClient) SendQueueMessage(ctx context.Context, request *actions.SendQueueMessageRequest) (*actions.SendQueueMessageResponse, error)

func (*InternalClient) StreamQueueMessages

func (c *InternalClient) StreamQueueMessages(ctx context.Context, requests chan *actions.StreamQueueMessagesRequest, responses chan *actions.StreamQueueMessagesResponse)

func (*InternalClient) SubscribeToCommands

func (c *InternalClient) SubscribeToCommands(ctx context.Context, channel, group string, messagesChan chan *actions.SubscribeCQRSRequestMessage, errChan chan error) error

func (*InternalClient) SubscribeToEvents

func (c *InternalClient) SubscribeToEvents(ctx context.Context, channel, group string, messagesChan chan *actions.SubscribePubSubMessage, errChan chan error) error

func (*InternalClient) SubscribeToEventsStore

func (c *InternalClient) SubscribeToEventsStore(ctx context.Context, channel, group, clientId, subType, subValue string, messagesChan chan *actions.SubscribePubSubMessage, errChan chan error) error

func (*InternalClient) SubscribeToQueries

func (c *InternalClient) SubscribeToQueries(ctx context.Context, channel, group string, messagesChan chan *actions.SubscribeCQRSRequestMessage, errChan chan error) error