array

package
v0.0.0-...-7febb3a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 12, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AckAllQueueMessages 

type AckAllQueueMessages interface {
	AckAllQueueMessages(ctx context.Context, req *pb.AckAllQueueMessagesRequest) (*pb.AckAllQueueMessagesResponse, error)
}

func ChainAckAllQueueMessages 

func ChainAckAllQueueMessages(aq AckAllQueueMessages, aqm ...AckAllQueueMessagesMiddleware) AckAllQueueMessages

type AckAllQueueMessagesFunc 

type AckAllQueueMessagesFunc func(ctx context.Context, req *pb.AckAllQueueMessagesRequest) (*pb.AckAllQueueMessagesResponse, error)

func (AckAllQueueMessagesFunc) AckAllQueueMessages 

func (aqf AckAllQueueMessagesFunc) AckAllQueueMessages(ctx context.Context, req *pb.AckAllQueueMessagesRequest) (*pb.AckAllQueueMessagesResponse, error)

type AckAllQueueMessagesMiddleware 

type AckAllQueueMessagesMiddleware func(AckAllQueueMessages) AckAllQueueMessages

func AckAllQueueMessagesLogging 

func AckAllQueueMessagesLogging(l *logging.Logger) AckAllQueueMessagesMiddleware

type Array 

type Array struct {
	QuerySender
	CommandSender
	ResponseSender
	Stopped chan struct{}
	// contains filtered or unexported fields
}

func Start 

func Start(ctx context.Context, appConfig *config.Config) (*Array, error)

func (*Array) AckAllQueueMessages 

func (a *Array) AckAllQueueMessages(ctx context.Context, req *pb.AckAllQueueMessagesRequest) (*pb.AckAllQueueMessagesResponse, error)

func (*Array) ClientsCount 

func (a *Array) ClientsCount() int

func (*Array) Close 

func (a *Array) Close()

func (*Array) DeleteClient 

func (a *Array) DeleteClient(id string) error

func (*Array) GetClientsList 

func (a *Array) GetClientsList() (list []string)

func (*Array) Monitor 

func (a *Array) Monitor() *monitor.Middleware

func (*Array) NewClient 

func (a *Array) NewClient(ctx context.Context, id string, clientId string) (*client.Client, error)

func (*Array) NewQueueClient 

func (a *Array) NewQueueClient(ctx context.Context, clientID string) (*client.QueueClient, error)

func (*Array) NewQueueClientFromPool 

func (a *Array) NewQueueClientFromPool(channel string) (*client.QueueClient, error)

func (*Array) NewQueueDownstreamClientFromPool 

func (a *Array) NewQueueDownstreamClientFromPool() (*client.QueueClient, string, error)

func (*Array) NewQueueUpstreamClientFromPool 

func (a *Array) NewQueueUpstreamClientFromPool() (*client.QueueClient, string, error)

func (*Array) NewRawNatsClient 

func (a *Array) NewRawNatsClient(ctx context.Context, clientID string) (*client.Client, error)

func (*Array) NewStoreClient 

func (a *Array) NewStoreClient(ctx context.Context, clientID string) (*client.Client, error)

func (*Array) QueuesDownstream 

func (a *Array) QueuesDownstream(ctx context.Context, requests chan *pb.QueuesDownstreamRequest, response chan *pb.QueuesDownstreamResponse, done chan bool) error

func (*Array) QueuesUpstream 

func (a *Array) QueuesUpstream(ctx context.Context, requests chan *pb.QueuesUpstreamRequest, response chan *pb.QueuesUpstreamResponse, done chan bool) error

func (*Array) ReceiveQueueMessages 

func (a *Array) ReceiveQueueMessages(ctx context.Context, req *pb.ReceiveQueueMessagesRequest) (*pb.ReceiveQueueMessagesResponse, error)

func (*Array) ReleaseQueueDownstreamClientFromPool 

func (a *Array) ReleaseQueueDownstreamClientFromPool(id string)

func (*Array) ReleaseQueueUpstreamClientFromPool 

func (a *Array) ReleaseQueueUpstreamClientFromPool(id string)

func (*Array) SendCommand 

func (a *Array) SendCommand(ctx context.Context, req *pb.Request) (*pb.Response, error)

func (*Array) SendEvents 

func (a *Array) SendEvents(ctx context.Context, msg *pb.Event) (*pb.Result, error)

func (*Array) SendEventsStore 

func (a *Array) SendEventsStore(ctx context.Context, msg *pb.Event) (*pb.Result, error)

func (*Array) SendQuery 

func (a *Array) SendQuery(ctx context.Context, req *pb.Request) (*pb.Response, error)

func (*Array) SendQueueMessage 

func (a *Array) SendQueueMessage(ctx context.Context, msg *pb.QueueMessage) (*pb.SendQueueMessageResult, error)

func (*Array) SendQueueMessagesBatch 

func (a *Array) SendQueueMessagesBatch(ctx context.Context, req *pb.QueueMessagesBatchRequest) (*pb.QueueMessagesBatchResponse, error)

func (*Array) SendResponse 

func (a *Array) SendResponse(ctx context.Context, res *pb.Response) error

func (*Array) StreamQueueMessage 

func (a *Array) StreamQueueMessage(ctx context.Context, requests chan *pb.StreamQueueMessagesRequest, response chan *pb.StreamQueueMessagesResponse, done chan bool) (string, error)

func (*Array) SubscribeEvents 

func (a *Array) SubscribeEvents(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive, errCh chan error) (string, error)

func (*Array) SubscribeEventsStore 

func (a *Array) SubscribeEventsStore(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive, errCh chan error) (string, error)

func (*Array) SubscribeToCommands 

func (a *Array) SubscribeToCommands(ctx context.Context, subReq *pb.Subscribe, reqCh chan *pb.Request, errCh chan error) (string, error)

func (*Array) SubscribeToQueries 

func (a *Array) SubscribeToQueries(ctx context.Context, subReq *pb.Subscribe, reqCh chan *pb.Request, errCh chan error) (string, error)

type CommandReceiver 

type CommandReceiver interface {
	SubscribeToCommands(ctx context.Context, subReq *pb.Subscribe, rx chan *pb.Request) error
}

func ChainCommandReceiver 

func ChainCommandReceiver(cr CommandReceiver, crm ...CommandReceiverMiddleware) CommandReceiver

type CommandReceiverFunc 

type CommandReceiverFunc func(ctx context.Context, subReq *pb.Subscribe, rx chan *pb.Request) error

func (CommandReceiverFunc) SubscribeToCommands 

func (crf CommandReceiverFunc) SubscribeToCommands(ctx context.Context, subReq *pb.Subscribe, rx chan *pb.Request) error

type CommandReceiverMiddleware 

type CommandReceiverMiddleware func(CommandReceiver) CommandReceiver

func CommandReceiverLogging 

func CommandReceiverLogging(l *logging.Logger) CommandReceiverMiddleware

type CommandSender 

type CommandSender interface {
	SendCommand(ctx context.Context, req *pb.Request) (*pb.Response, error)
}

func ChainCommandSender 

func ChainCommandSender(cs CommandSender, csm ...CommandSenderMiddleware) CommandSender

type CommandSenderFunc 

type CommandSenderFunc func(ctx context.Context, req *pb.Request) (*pb.Response, error)

func (CommandSenderFunc) SendCommand 

func (csf CommandSenderFunc) SendCommand(ctx context.Context, req *pb.Request) (*pb.Response, error)

type CommandSenderMiddleware 

type CommandSenderMiddleware func(CommandSender) CommandSender

func CommandSenderLogging 

func CommandSenderLogging(l *logging.Logger) CommandSenderMiddleware

func CommandSenderMonitor 

func CommandSenderMonitor(mm *monitor.Middleware) CommandSenderMiddleware

type EventsReceiver 

type EventsReceiver interface {
	SubscribeToEvents(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive) error
}

func ChainEventsReceiver 

func ChainEventsReceiver(ev EventsReceiver, erm ...EventsReceiverMiddleware) EventsReceiver

type EventsReceiverFunc 

type EventsReceiverFunc func(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive) error

func (EventsReceiverFunc) SubscribeToEvents 

func (qs EventsReceiverFunc) SubscribeToEvents(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive) error

type EventsReceiverMiddleware 

type EventsReceiverMiddleware func(EventsReceiver) EventsReceiver

func EventsReceiverLogging 

func EventsReceiverLogging(l *logging.Logger) EventsReceiverMiddleware

type EventsSender 

type EventsSender interface {
	SendEvents(ctx context.Context, msg *pb.Event) (*pb.Result, error)
}

func ChainEventsSenders 

func ChainEventsSenders(es EventsSender, esm ...EventsSenderMiddleware) EventsSender

type EventsSenderFunc 

type EventsSenderFunc func(ctx context.Context, msg *pb.Event) (*pb.Result, error)

func (EventsSenderFunc) SendEvents 

func (esf EventsSenderFunc) SendEvents(ctx context.Context, msg *pb.Event) (*pb.Result, error)

type EventsSenderMiddleware 

type EventsSenderMiddleware func(EventsSender) EventsSender

func EventsSenderLogging 

func EventsSenderLogging(l *logging.Logger) EventsSenderMiddleware

type EventsStoreReceiver 

type EventsStoreReceiver interface {
	SubscribeToEventsStore(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive) error
}

func ChainEventsStoreReceiver 

func ChainEventsStoreReceiver(esr EventsStoreReceiver, esrm ...EventsStoreReceiverMiddleware) EventsStoreReceiver

type EventsStoreReceiverFunc 

type EventsStoreReceiverFunc func(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive) error

func (EventsStoreReceiverFunc) SubscribeToEventsStore 

func (qs EventsStoreReceiverFunc) SubscribeToEventsStore(ctx context.Context, subReq *pb.Subscribe, msgCh chan *pb.EventReceive) error

type EventsStoreReceiverMiddleware 

type EventsStoreReceiverMiddleware func(EventsStoreReceiver) EventsStoreReceiver

func EventsStoreReceiverLogging 

func EventsStoreReceiverLogging(l *logging.Logger) EventsStoreReceiverMiddleware

type EventsStoreSender 

type EventsStoreSender interface {
	SendEventsStore(ctx context.Context, msg *pb.Event) (*pb.Result, error)
}

func ChainEventsStoreSenders 

func ChainEventsStoreSenders(ess EventsStoreSender, essm ...EventsStoreSenderMiddleware) EventsStoreSender

type EventsStoreSenderFunc 

type EventsStoreSenderFunc func(ctx context.Context, msg *pb.Event) (*pb.Result, error)

func (EventsStoreSenderFunc) SendEventsStore 

func (essf EventsStoreSenderFunc) SendEventsStore(ctx context.Context, msg *pb.Event) (*pb.Result, error)

type EventsStoreSenderMiddleware 

type EventsStoreSenderMiddleware func(EventsStoreSender) EventsStoreSender

func EventsStoreSenderLogging 

func EventsStoreSenderLogging(l *logging.Logger) EventsStoreSenderMiddleware

type QueryReceiver 

type QueryReceiver interface {
	SubscribeToQueries(ctx context.Context, subReq *pb.Subscribe, rx chan *pb.Request) error
}

func ChainQueryReceiver 

func ChainQueryReceiver(qr QueryReceiver, qrm ...QueryReceiverMiddleware) QueryReceiver

type QueryReceiverFunc 

type QueryReceiverFunc func(ctx context.Context, subReq *pb.Subscribe, rx chan *pb.Request) error

func (QueryReceiverFunc) SubscribeToQueries 

func (qsf QueryReceiverFunc) SubscribeToQueries(ctx context.Context, subReq *pb.Subscribe, rx chan *pb.Request) error

type QueryReceiverMiddleware 

type QueryReceiverMiddleware func(QueryReceiver) QueryReceiver

func QueryReceiverLogging 

func QueryReceiverLogging(l *logging.Logger) QueryReceiverMiddleware

type QuerySender 

type QuerySender interface {
	SendQuery(ctx context.Context, req *pb.Request) (*pb.Response, error)
}

func ChainQuerySender 

func ChainQuerySender(qs QuerySender, qsm ...QuerySenderMiddleware) QuerySender

type QuerySenderFunc 

type QuerySenderFunc func(ctx context.Context, req *pb.Request) (*pb.Response, error)

func (QuerySenderFunc) SendQuery 

func (qsf QuerySenderFunc) SendQuery(ctx context.Context, req *pb.Request) (*pb.Response, error)

type QuerySenderMiddleware 

type QuerySenderMiddleware func(QuerySender) QuerySender

func QuerySenderLogging 

func QuerySenderLogging(l *logging.Logger) QuerySenderMiddleware

func QuerySenderMonitor 

func QuerySenderMonitor(mm *monitor.Middleware) QuerySenderMiddleware

type QueueBatchSender 

type QueueBatchSender interface {
	SendQueueMessagesBatch(ctx context.Context, req *pb.QueueMessagesBatchRequest) (*pb.QueueMessagesBatchResponse, error)
}

func ChainQueueBatchSenders 

func ChainQueueBatchSenders(qbs QueueBatchSender, qbsm ...QueueBatchSenderMiddleware) QueueBatchSender

type QueueBatchSenderFunc 

type QueueBatchSenderFunc func(ctx context.Context, req *pb.QueueMessagesBatchRequest) (*pb.QueueMessagesBatchResponse, error)

func (QueueBatchSenderFunc) SendQueueMessagesBatch 

func (qbsf QueueBatchSenderFunc) SendQueueMessagesBatch(ctx context.Context, req *pb.QueueMessagesBatchRequest) (*pb.QueueMessagesBatchResponse, error)

type QueueBatchSenderMiddleware 

type QueueBatchSenderMiddleware func(QueueBatchSender) QueueBatchSender

func QueueBatchSenderLogging 

func QueueBatchSenderLogging(l *logging.Logger) QueueBatchSenderMiddleware

type QueueReceiver 

type QueueReceiver interface {
	ReceiveQueueMessages(ctx context.Context, req *pb.ReceiveQueueMessagesRequest) (*pb.ReceiveQueueMessagesResponse, error)
}

func ChainQueueReceivers 

func ChainQueueReceivers(qr QueueReceiver, qrm ...QueueReceiverMiddleware) QueueReceiver

type QueueReceiverFunc 

type QueueReceiverFunc func(ctx context.Context, req *pb.ReceiveQueueMessagesRequest) (*pb.ReceiveQueueMessagesResponse, error)

func (QueueReceiverFunc) ReceiveQueueMessages 

func (qr QueueReceiverFunc) ReceiveQueueMessages(ctx context.Context, req *pb.ReceiveQueueMessagesRequest) (*pb.ReceiveQueueMessagesResponse, error)

type QueueReceiverMiddleware 

type QueueReceiverMiddleware func(QueueReceiver) QueueReceiver

func QueueReceiverLogging 

func QueueReceiverLogging(l *logging.Logger) QueueReceiverMiddleware

type QueueSender 

type QueueSender interface {
	SendQueueMessage(ctx context.Context, msg *pb.QueueMessage) *pb.SendQueueMessageResult
}

func ChainQueueSenders 

func ChainQueueSenders(qs QueueSender, qsm ...QueueSenderMiddleware) QueueSender

type QueueSenderFunc 

type QueueSenderFunc func(ctx context.Context, msg *pb.QueueMessage) *pb.SendQueueMessageResult

func (QueueSenderFunc) SendQueueMessage 

func (qs QueueSenderFunc) SendQueueMessage(ctx context.Context, msg *pb.QueueMessage) *pb.SendQueueMessageResult

type QueueSenderMiddleware 

type QueueSenderMiddleware func(QueueSender) QueueSender

func QueueSenderLogging 

func QueueSenderLogging(l *logging.Logger) QueueSenderMiddleware

type ResponseSender 

type ResponseSender interface {
	SendResponse(ctx context.Context, res *pb.Response) error
}

func ChainResponseSender 

func ChainResponseSender(rs ResponseSender, rsm ...ResponseSenderMiddleware) ResponseSender

type ResponseSenderFunc 

type ResponseSenderFunc func(ctx context.Context, res *pb.Response) error

func (ResponseSenderFunc) SendResponse 

func (rsf ResponseSenderFunc) SendResponse(ctx context.Context, res *pb.Response) error

type ResponseSenderMiddleware 

type ResponseSenderMiddleware func(ResponseSender) ResponseSender

func ResponseSenderLogging 

func ResponseSenderLogging(l *logging.Logger) ResponseSenderMiddleware

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.