kubemq

Sep 28, 2024

Changes in this version

type CommandReceive

+ func (cr *CommandReceive) String() string

type CommandResponse

+ func (cr *CommandResponse) String() string

type Event

+ func (e *Event) String() string

type EventStoreReceive

+ func (es *EventStoreReceive) String() string

type QueryReceive

+ func (qr *QueryReceive) String() string

type QueryResponse

+ func (qr *QueryResponse) String() string

type Response

+ func (r *Response) String() string

Apr 28, 2024

Changes in this version

+ func CreateChannel(ctx context.Context, client *Client, clientId string, channel string, ...) error

+ func DecodeCQChannelList(dataBytes []byte) ([]*common.CQChannel, error)

+ func DecodePubSubChannelList(dataBytes []byte) ([]*common.PubSubChannel, error)

+ func DecodeQueuesChannelList(dataBytes []byte) ([]*common.QueuesChannel, error)

+ func DeleteChannel(ctx context.Context, client *Client, clientId string, channel string, ...) error

+ func ListCQChannels(ctx context.Context, client *Client, clientId string, channelType string, ...) ([]*common.CQChannel, error)

+ func ListPubSubChannels(ctx context.Context, client *Client, clientId string, channelType string, ...) ([]*common.PubSubChannel, error)

+ func ListQueuesChannels(ctx context.Context, client *Client, clientId string, search string) ([]*common.QueuesChannel, error)

type CommandsClient

+ func (c *CommandsClient) Create(ctx context.Context, channel string) error

+ func (c *CommandsClient) Delete(ctx context.Context, channel string) error

+ func (c *CommandsClient) List(ctx context.Context, search string) ([]*common.CQChannel, error)

type EventsClient

+ func (e *EventsClient) Create(ctx context.Context, channel string) error

+ func (e *EventsClient) Delete(ctx context.Context, channel string) error

+ func (e *EventsClient) List(ctx context.Context, search string) ([]*common.PubSubChannel, error)

type EventsStoreClient

+ func (es *EventsStoreClient) Create(ctx context.Context, channel string) error

+ func (es *EventsStoreClient) Delete(ctx context.Context, channel string) error

+ func (es *EventsStoreClient) List(ctx context.Context, search string) ([]*common.PubSubChannel, error)

type QueriesClient

+ func (q *QueriesClient) Create(ctx context.Context, channel string) error

+ func (q *QueriesClient) Delete(ctx context.Context, channel string) error

+ func (q *QueriesClient) List(ctx context.Context, search string) ([]*common.CQChannel, error)

type QueuesClient

+ func (q *QueuesClient) Create(ctx context.Context, channel string) error

+ func (q *QueuesClient) Delete(ctx context.Context, channel string) error

+ func (q *QueuesClient) List(ctx context.Context, search string) ([]*common.QueuesChannel, error)

Jun 28, 2021

Changes in this version

type QueuesClient

+ func NewQueuesStreamClient(ctx context.Context, op ...Option) (*QueuesClient, error)

May 28, 2021

Changes in this version

type Client

+ func (c *Client) QueuesInfo(ctx context.Context, filter string) (*QueuesInfo, error)

+ type QueueInfo struct

+ Bytes int64

+ Delivered int64

+ FirstSequence int64

+ LastSequence int64

+ Messages int64

+ Name string

+ Sent int64

+ Subscribers int

+ Waiting int64

type QueuesClient

+ func (q *QueuesClient) QueuesInfo(ctx context.Context, filter string) (*QueuesInfo, error)

+ type QueuesInfo struct

+ Delivered int64

+ Queues []*QueueInfo

+ Sent int64

+ TotalQueues int

+ Waiting int64

type Transport

+ QueuesInfo func(ctx context.Context, filter string) (*QueuesInfo, error)

Apr 8, 2021

Changes in this version

type AckAllQueueMessagesRequest

+ func (req *AckAllQueueMessagesRequest) Complete(opts *Options) *AckAllQueueMessagesRequest

+ func (req *AckAllQueueMessagesRequest) Validate() error

type Client

+ func (c *Client) SubscribeToCommandsWithRequest(ctx context.Context, request *CommandsSubscription, errCh chan error) (<-chan *CommandReceive, error)

+ func (c *Client) SubscribeToEventsStoreWithRequest(ctx context.Context, request *EventsStoreSubscription, errCh chan error) (<-chan *EventStoreReceive, error)

+ func (c *Client) SubscribeToEventsWithRequest(ctx context.Context, request *EventsSubscription, errCh chan error) (<-chan *Event, error)

+ func (c *Client) SubscribeToQueriesWithRequest(ctx context.Context, request *QueriesSubscription, errCh chan error) (<-chan *QueryReceive, error)

+ type CommandsClient struct

+ func NewCommandsClient(ctx context.Context, op ...Option) (*CommandsClient, error)

+ func (c *CommandsClient) Close() error

+ func (c *CommandsClient) Response(ctx context.Context, response *Response) error

+ func (c *CommandsClient) Send(ctx context.Context, request *Command) (*CommandResponse, error)

+ func (c *CommandsClient) Subscribe(ctx context.Context, request *CommandsSubscription, ...) error

+ type CommandsSubscription struct

+ Channel string

+ ClientId string

+ Group string

+ func (cs *CommandsSubscription) Complete(opts *Options) *CommandsSubscription

+ func (cs *CommandsSubscription) Validate() error

+ type EventsClient struct

+ func NewEventsClient(ctx context.Context, op ...Option) (*EventsClient, error)

+ func (e *EventsClient) Close() error

+ func (e *EventsClient) Send(ctx context.Context, message *Event) error

+ func (e *EventsClient) Stream(ctx context.Context, onError func(err error)) (func(msg *Event) error, error)

+ func (e *EventsClient) Subscribe(ctx context.Context, request *EventsSubscription, ...) error

+ type EventsErrorsHandler func(error)

+ type EventsMessageHandler func(*Event)

+ type EventsStoreClient struct

+ func NewEventsStoreClient(ctx context.Context, op ...Option) (*EventsStoreClient, error)

+ func (es *EventsStoreClient) Close() error

+ func (es *EventsStoreClient) Send(ctx context.Context, message *EventStore) (*EventStoreResult, error)

+ func (es *EventsStoreClient) Stream(ctx context.Context, onResult func(result *EventStoreResult, err error)) (func(msg *EventStore) error, error)

+ func (es *EventsStoreClient) Subscribe(ctx context.Context, request *EventsStoreSubscription, ...) error

+ type EventsStoreSubscription struct

+ Channel string

+ ClientId string

+ Group string

+ SubscriptionType SubscriptionOption

+ func (es *EventsStoreSubscription) Complete(opts *Options) *EventsStoreSubscription

+ func (es *EventsStoreSubscription) Validate() error

+ type EventsSubscription struct

+ Channel string

+ ClientId string

+ Group string

+ func (es *EventsSubscription) Complete(opts *Options) *EventsSubscription

+ func (es *EventsSubscription) Validate() error

+ type QueriesClient struct

+ func NewQueriesClient(ctx context.Context, op ...Option) (*QueriesClient, error)

+ func (q *QueriesClient) Close() error

+ func (q *QueriesClient) Response(ctx context.Context, response *Response) error

+ func (q *QueriesClient) Send(ctx context.Context, request *Query) (*QueryResponse, error)

+ func (q *QueriesClient) Subscribe(ctx context.Context, request *QueriesSubscription, ...) error

+ type QueriesSubscription struct

+ Channel string

+ ClientId string

+ Group string

+ func (qs *QueriesSubscription) Complete(opts *Options) *QueriesSubscription

+ func (qs *QueriesSubscription) Validate() error

+ type QueueTransactionMessageRequest struct

+ Channel string

+ ClientID string

+ RequestID string

+ VisibilitySeconds int32

+ WaitTimeSeconds int32

+ func NewQueueTransactionMessageRequest() *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) Complete(opts *Options) *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) SetChannel(channel string) *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) SetClientId(clientId string) *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) SetId(id string) *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) SetVisibilitySeconds(visibility int) *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) SetWaitTimeSeconds(wait int) *QueueTransactionMessageRequest

+ func (req *QueueTransactionMessageRequest) Validate() error

+ type QueueTransactionMessageResponse struct

+ Message *QueueMessage

+ func (qt *QueueTransactionMessageResponse) Ack() error

+ func (qt *QueueTransactionMessageResponse) ExtendVisibilitySeconds(value int) error

+ func (qt *QueueTransactionMessageResponse) Reject() error

+ func (qt *QueueTransactionMessageResponse) Resend(channel string) error

+ func (qt *QueueTransactionMessageResponse) ResendNewMessage(msg *QueueMessage) error

+ type QueuesClient struct

+ func NewQueuesClient(ctx context.Context, op ...Option) (*QueuesClient, error)

+ func (q *QueuesClient) AckAll(ctx context.Context, request *AckAllQueueMessagesRequest) (*AckAllQueueMessagesResponse, error)

+ func (q *QueuesClient) Batch(ctx context.Context, messages []*QueueMessage) ([]*SendQueueMessageResult, error)

+ func (q *QueuesClient) Close() error

+ func (q *QueuesClient) Peek(ctx context.Context, request *ReceiveQueueMessagesRequest) (*ReceiveQueueMessagesResponse, error)

+ func (q *QueuesClient) Pull(ctx context.Context, request *ReceiveQueueMessagesRequest) (*ReceiveQueueMessagesResponse, error)

+ func (q *QueuesClient) Send(ctx context.Context, message *QueueMessage) (*SendQueueMessageResult, error)

+ func (q *QueuesClient) Subscribe(ctx context.Context, request *ReceiveQueueMessagesRequest, ...) (chan struct{}, error)

+ func (q *QueuesClient) Transaction(ctx context.Context, request *QueueTransactionMessageRequest) (*QueueTransactionMessageResponse, error)

+ func (q *QueuesClient) TransactionStream(ctx context.Context, request *QueueTransactionMessageRequest, ...) (chan struct{}, error)

type ReceiveQueueMessagesRequest

+ func NewReceiveQueueMessagesRequest() *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) Complete(opts *Options) *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) Validate() error

type Transport

+ GetGRPCRawClient func() (pb.KubemqClient, error)

Aug 21, 2020

Changes in this version

type CommandReceive

+ ClientId string

type QueryReceive

+ ClientId string

Jul 27, 2020

Changes in this version

type Command

+ func (c *Command) SetTags(tags map[string]string) *Command

type Event

+ func (e *Event) SetTags(tags map[string]string) *Event

type EventStore

+ func (es *EventStore) SetTags(tags map[string]string) *EventStore

type Query

+ func (q *Query) SetTags(tags map[string]string) *Query

type QueueMessage

+ func (qm *QueueMessage) SetTags(tags map[string]string) *QueueMessage

Jun 13, 2020

Changes in this version

type Client

+ func (c *Client) SetCommand(cmd *Command) *Command

+ func (c *Client) SetEvent(e *Event) *Event

+ func (c *Client) SetEventStore(es *EventStore) *EventStore

+ func (c *Client) SetQuery(query *Query) *Query

+ func (c *Client) SetQueueMessage(qm *QueueMessage) *QueueMessage

+ func (c *Client) SetResponse(response *Response) *Response

type Command

+ func NewCommand() *Command

type Event

+ func NewEvent() *Event

type EventStore

+ func NewEventStore() *EventStore

type Option

+ func WithAutoReconnect(value bool) Option

+ func WithCheckConnection(value bool) Option

+ func WithMaxReconnects(value int) Option

+ func WithReconnectInterval(duration time.Duration) Option

type Query

+ func NewQuery() *Query

type QueueMessage

+ func NewQueueMessage() *QueueMessage

type Response

+ func NewResponse() *Response

Apr 13, 2020

Changes in this version

type Client

+ func (c *Client) Ping(ctx context.Context) (*ServerInfo, error)

Dec 25, 2019

Changes in this version

type Option

+ func WithAuthToken(token string) Option

Dec 24, 2019

Changes in this version

type Option

+ func WithCertificate(certData, serverOverrideDomain string) Option

+ func WithDefaultChannel(channel string) Option

Jul 30, 2019

Changes in this version

+ var ErrNoTransportConnection = errors.New("no transport layer established, aborting")

Jul 15, 2019

Changes in this version

+ var ErrNoTransportCpnnection = errors.New("no transport layer established, aborting")

+ var ErrNoTransportDefined = errors.New("no transport layer defined, create object with client instance")

+ type AckAllQueueMessagesRequest struct

+ Channel string

+ ClientID string

+ RequestID string

+ WaitTimeSeconds int32

+ func (req *AckAllQueueMessagesRequest) AddTrace(name string) *Trace

+ func (req *AckAllQueueMessagesRequest) Send(ctx context.Context) (*AckAllQueueMessagesResponse, error)

+ func (req *AckAllQueueMessagesRequest) SetChannel(channel string) *AckAllQueueMessagesRequest

+ func (req *AckAllQueueMessagesRequest) SetClientId(clientId string) *AckAllQueueMessagesRequest

+ func (req *AckAllQueueMessagesRequest) SetId(id string) *AckAllQueueMessagesRequest

+ func (req *AckAllQueueMessagesRequest) SetWaitTimeSeconds(wait int) *AckAllQueueMessagesRequest

+ type AckAllQueueMessagesResponse struct

+ AffectedMessages uint64

+ Error string

+ IsError bool

+ RequestID string

type Client

+ ServerInfo *ServerInfo

+ func (c *Client) AQM() *AckAllQueueMessagesRequest

+ func (c *Client) AckAllQueueMessages(ctx context.Context, req *AckAllQueueMessagesRequest) (*AckAllQueueMessagesResponse, error)

+ func (c *Client) NewAckAllQueueMessagesRequest() *AckAllQueueMessagesRequest

+ func (c *Client) NewCommand() *Command

+ func (c *Client) NewEvent() *Event

+ func (c *Client) NewEventStore() *EventStore

+ func (c *Client) NewQuery() *Query

+ func (c *Client) NewQueueMessage() *QueueMessage

+ func (c *Client) NewQueueMessages() *QueueMessages

+ func (c *Client) NewReceiveQueueMessagesRequest() *ReceiveQueueMessagesRequest

+ func (c *Client) NewResponse() *Response

+ func (c *Client) NewStreamQueueMessage() *StreamQueueMessage

+ func (c *Client) QM() *QueueMessage

+ func (c *Client) QMB() *QueueMessages

+ func (c *Client) RQM() *ReceiveQueueMessagesRequest

+ func (c *Client) ReceiveQueueMessages(ctx context.Context, req *ReceiveQueueMessagesRequest) (*ReceiveQueueMessagesResponse, error)

+ func (c *Client) SQM() *StreamQueueMessage

+ func (c *Client) SendQueueMessage(ctx context.Context, msg *QueueMessage) (*SendQueueMessageResult, error)

+ func (c *Client) SendQueueMessages(ctx context.Context, msg []*QueueMessage) ([]*SendQueueMessageResult, error)

type Command

+ Tags map[string]string

+ func (c *Command) AddTag(key, value string) *Command

+ func (c *Command) AddTrace(name string) *Trace

type CommandReceive

+ Tags map[string]string

type CommandResponse

+ Tags map[string]string

type Event

+ Tags map[string]string

+ func (e *Event) AddTag(key, value string) *Event

type EventStore

+ Tags map[string]string

+ func (es *EventStore) AddTag(key, value string) *EventStore

type EventStoreReceive

+ Tags map[string]string

type Option

+ func WithUri(uri string) Option

type Options

+ func (o *Options) Validate() error

type Query

+ Tags map[string]string

+ func (q *Query) AddTag(key, value string) *Query

+ func (q *Query) AddTrace(name string) *Trace

type QueryReceive

+ Tags map[string]string

type QueryResponse

+ Tags map[string]string

+ type QueueMessage struct

+ Attributes *QueueMessageAttributes

+ Body []byte

+ Channel string

+ ClientId string

+ Id string

+ Metadata string

+ Policy *QueueMessagePolicy

+ Tags map[string]string

+ func (qm *QueueMessage) Ack() error

+ func (qm *QueueMessage) AddTag(key, value string) *QueueMessage

+ func (qm *QueueMessage) AddTrace(name string) *Trace

+ func (qm *QueueMessage) ExtendVisibility(value int32) error

+ func (qm *QueueMessage) Reject() error

+ func (qm *QueueMessage) Resend(channel string) error

+ func (qm *QueueMessage) Send(ctx context.Context) (*SendQueueMessageResult, error)

+ func (qm *QueueMessage) SetBody(body []byte) *QueueMessage

+ func (qm *QueueMessage) SetChannel(channel string) *QueueMessage

+ func (qm *QueueMessage) SetClientId(clientId string) *QueueMessage

+ func (qm *QueueMessage) SetId(id string) *QueueMessage

+ func (qm *QueueMessage) SetMetadata(metadata string) *QueueMessage

+ func (qm *QueueMessage) SetPolicyDelaySeconds(sec int) *QueueMessage

+ func (qm *QueueMessage) SetPolicyExpirationSeconds(sec int) *QueueMessage

+ func (qm *QueueMessage) SetPolicyMaxReceiveCount(max int) *QueueMessage

+ func (qm *QueueMessage) SetPolicyMaxReceiveQueue(channel string) *QueueMessage

+ type QueueMessageAttributes struct

+ DelayedTo int64

+ ExpirationAt int64

+ MD5OfBody string

+ ReRouted bool

+ ReRoutedFromQueue string

+ ReceiveCount int32

+ Sequence uint64

+ Timestamp int64

+ type QueueMessagePolicy struct

+ DelaySeconds int32

+ ExpirationSeconds int32

+ MaxReceiveCount int32

+ MaxReceiveQueue string

+ type QueueMessages struct

+ Messages []*QueueMessage

+ func (qma *QueueMessages) Add(msg *QueueMessage) *QueueMessages

+ func (qma *QueueMessages) Send(ctx context.Context) ([]*SendQueueMessageResult, error)

+ type ReceiveQueueMessagesRequest struct

+ Channel string

+ ClientID string

+ IsPeak bool

+ MaxNumberOfMessages int32

+ RequestID string

+ WaitTimeSeconds int32

+ func (req *ReceiveQueueMessagesRequest) AddTrace(name string) *Trace

+ func (req *ReceiveQueueMessagesRequest) Send(ctx context.Context) (*ReceiveQueueMessagesResponse, error)

+ func (req *ReceiveQueueMessagesRequest) SetChannel(channel string) *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) SetClientId(clientId string) *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) SetId(id string) *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) SetIsPeak(value bool) *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) SetMaxNumberOfMessages(max int) *ReceiveQueueMessagesRequest

+ func (req *ReceiveQueueMessagesRequest) SetWaitTimeSeconds(wait int) *ReceiveQueueMessagesRequest

+ type ReceiveQueueMessagesResponse struct

+ Error string

+ IsError bool

+ IsPeak bool

+ Messages []*QueueMessage

+ MessagesExpired int32

+ MessagesReceived int32

+ RequestID string

type Response

+ Tags map[string]string

+ func (r *Response) AddTrace(name string) *Trace

+ func (r *Response) SetTags(tags map[string]string) *Response

+ type SendQueueMessageResult struct

+ DelayedTo int64

+ Error string

+ ExpirationAt int64

+ IsError bool

+ MessageID string

+ SentAt int64

+ type ServerInfo struct

+ Host string

+ ServerStartTime int64

+ ServerUpTimeSeconds int64

+ Version string

+ type StreamQueueMessage struct

+ Channel string

+ ClientID string

+ RequestID string

+ func (req *StreamQueueMessage) AddTrace(name string) *Trace

+ func (req *StreamQueueMessage) Close()

+ func (req *StreamQueueMessage) Next(ctx context.Context, visibility, wait int32) (*QueueMessage, error)

+ func (req *StreamQueueMessage) ResendWithNewMessage(msg *QueueMessage) error

+ func (req *StreamQueueMessage) SetChannel(channel string) *StreamQueueMessage

+ func (req *StreamQueueMessage) SetClientId(clientId string) *StreamQueueMessage

+ func (req *StreamQueueMessage) SetId(id string) *StreamQueueMessage

+ type Trace struct

+ Name string

+ func CreateTrace(name string) *Trace

+ func (t *Trace) AddAnnotation(timestamp time.Time, message string) *Trace

+ func (t *Trace) AddBoolAttribute(key string, value bool) *Trace

+ func (t *Trace) AddInt64Attribute(key string, value int64) *Trace

+ func (t *Trace) AddStringAttribute(key string, value string) *Trace

type Transport

+ AckAllQueueMessages func(ctx context.Context, req *AckAllQueueMessagesRequest) (*AckAllQueueMessagesResponse, error)

+ Ping func(ctx context.Context) (*ServerInfo, error)

+ ReceiveQueueMessages func(ctx context.Context, req *ReceiveQueueMessagesRequest) (*ReceiveQueueMessagesResponse, error)

+ SendQueueMessage func(ctx context.Context, msg *QueueMessage) (*SendQueueMessageResult, error)

+ SendQueueMessages func(ctx context.Context, msg []*QueueMessage) ([]*SendQueueMessageResult, error)

+ StreamQueueMessage func(ctx context.Context, reqCh chan *pb.StreamQueueMessagesRequest, ...)

type TransportType

+ const TransportTypeRest

Dec 16, 2018

Changes in this version

+ type Client struct

+ func NewClient(ctx context.Context, op ...Option) (*Client, error)

+ func (c *Client) C() *Command

+ func (c *Client) Close() error

+ func (c *Client) E() *Event

+ func (c *Client) ES() *EventStore

+ func (c *Client) Q() *Query

+ func (c *Client) R() *Response

+ func (c *Client) StreamEvents(ctx context.Context, eventsCh chan *Event, errCh chan error)

+ func (c *Client) StreamEventsStore(ctx context.Context, eventsCh chan *EventStore, ...)

+ func (c *Client) SubscribeToCommands(ctx context.Context, channel, group string, errCh chan error) (<-chan *CommandReceive, error)

+ func (c *Client) SubscribeToEvents(ctx context.Context, channel, group string, errCh chan error) (<-chan *Event, error)

+ func (c *Client) SubscribeToEventsStore(ctx context.Context, channel, group string, errCh chan error, ...) (<-chan *EventStoreReceive, error)

+ func (c *Client) SubscribeToQueries(ctx context.Context, channel, group string, errCh chan error) (<-chan *QueryReceive, error)

+ type Command struct

+ Body []byte

+ Channel string

+ ClientId string

+ Id string

+ Metadata string

+ Timeout time.Duration

+ func (c *Command) Send(ctx context.Context) (*CommandResponse, error)

+ func (c *Command) SetBody(body []byte) *Command

+ func (c *Command) SetChannel(channel string) *Command

+ func (c *Command) SetClientId(clientId string) *Command

+ func (c *Command) SetId(id string) *Command

+ func (c *Command) SetMetadata(metadata string) *Command

+ func (c *Command) SetTimeout(timeout time.Duration) *Command

+ type CommandReceive struct

+ Body []byte

+ Channel string

+ Id string

+ Metadata string

+ ResponseTo string

+ type CommandResponse struct

+ CommandId string

+ Error string

+ Executed bool

+ ExecutedAt time.Time

+ ResponseClientId string

+ type Event struct

+ Body []byte

+ Channel string

+ ClientId string

+ Id string

+ Metadata string

+ func (e *Event) Send(ctx context.Context) error

+ func (e *Event) SetBody(body []byte) *Event

+ func (e *Event) SetChannel(channel string) *Event

+ func (e *Event) SetClientId(clientId string) *Event

+ func (e *Event) SetId(id string) *Event

+ func (e *Event) SetMetadata(metadata string) *Event

+ type EventStore struct

+ Body []byte

+ Channel string

+ ClientId string

+ Id string

+ Metadata string

+ func (es *EventStore) Send(ctx context.Context) (*EventStoreResult, error)

+ func (es *EventStore) SetBody(body []byte) *EventStore

+ func (es *EventStore) SetChannel(channel string) *EventStore

+ func (es *EventStore) SetClientId(clientId string) *EventStore

+ func (es *EventStore) SetId(id string) *EventStore

+ func (es *EventStore) SetMetadata(metadata string) *EventStore

+ type EventStoreReceive struct

+ Body []byte

+ Channel string

+ ClientId string

+ Id string

+ Metadata string

+ Sequence uint64

+ Timestamp time.Time

+ type EventStoreResult struct

+ Err error

+ Id string

+ Sent bool

+ type Option interface

+ func WithAddress(host string, port int) Option

+ func WithClientId(id string) Option

+ func WithCredentials(certFile, serverOverrideDomain string) Option

+ func WithDefaultCacheTTL(ttl time.Duration) Option

+ func WithDefualtChannel(channel string) Option

+ func WithReceiveBufferSize(size int) Option

+ func WithToken(token string) Option

+ func WithTransportType(transportType TransportType) Option

+ type Options struct

+ func GetDefaultOptions() *Options

+ type Query struct

+ Body []byte

+ CacheKey string

+ CacheTTL time.Duration

+ Channel string

+ ClientId string

+ Id string

+ Metadata string

+ Timeout time.Duration

+ func (q *Query) Send(ctx context.Context) (*QueryResponse, error)

+ func (q *Query) SetBody(body []byte) *Query

+ func (q *Query) SetCacheKey(cacheKey string) *Query

+ func (q *Query) SetCacheTTL(ttl time.Duration) *Query

+ func (q *Query) SetChannel(channel string) *Query

+ func (q *Query) SetClientId(clientId string) *Query

+ func (q *Query) SetId(id string) *Query

+ func (q *Query) SetMetadata(metadata string) *Query

+ func (q *Query) SetTimeout(timeout time.Duration) *Query

+ type QueryReceive struct

+ Body []byte

+ Channel string

+ Id string

+ Metadata string

+ ResponseTo string

+ type QueryResponse struct

+ Body []byte

+ CacheHit bool

+ Error string

+ Executed bool

+ ExecutedAt time.Time

+ Metadata string

+ QueryId string

+ ResponseClientId string

+ type Response struct

+ Body []byte

+ ClientId string

+ Err error

+ ExecutedAt time.Time

+ Metadata string

+ RequestId string

+ ResponseTo string

+ func (r *Response) Send(ctx context.Context) error

+ func (r *Response) SetBody(body []byte) *Response

+ func (r *Response) SetClientId(clientId string) *Response

+ func (r *Response) SetError(err error) *Response

+ func (r *Response) SetExecutedAt(executedAt time.Time) *Response

+ func (r *Response) SetMetadata(metadata string) *Response

+ func (r *Response) SetRequestId(id string) *Response

+ func (r *Response) SetResponseTo(channel string) *Response

+ type SubscriptionOption interface

+ func StartFromFirstEvent() SubscriptionOption

+ func StartFromLastEvent() SubscriptionOption

+ func StartFromNewEvents() SubscriptionOption

+ func StartFromSequence(sequence int) SubscriptionOption

+ func StartFromTime(since time.Time) SubscriptionOption

+ func StartFromTimeDelta(delta time.Duration) SubscriptionOption

+ type Transport interface

+ Close func() error

+ SendCommand func(ctx context.Context, command *Command) (*CommandResponse, error)

+ SendEvent func(ctx context.Context, event *Event) error

+ SendEventStore func(ctx context.Context, eventStore *EventStore) (*EventStoreResult, error)

+ SendQuery func(ctx context.Context, query *Query) (*QueryResponse, error)

+ SendResponse func(ctx context.Context, response *Response) error

+ StreamEvents func(ctx context.Context, eventsCh chan *Event, errCh chan error)

+ StreamEventsStore func(ctx context.Context, eventsCh chan *EventStore, ...)

+ SubscribeToCommands func(ctx context.Context, channel, group string, errCh chan error) (<-chan *CommandReceive, error)

+ SubscribeToEvents func(ctx context.Context, channel, group string, errCh chan error) (<-chan *Event, error)

+ SubscribeToEventsStore func(ctx context.Context, channel, group string, errCh chan error, ...) (<-chan *EventStoreReceive, error)

+ SubscribeToQueries func(ctx context.Context, channel, group string, errCh chan error) (<-chan *QueryReceive, error)

+ type TransportType int

+ const TransportTypeGRPC