pubsub

May 18, 2023

Changes in this version

+ var ErrMissingEventActorID = errors.New("missing event actor id")

+ var ErrMissingEventSubjectID = errors.New("missing event subject id")

type Client

+ func (c *Client) NewSubject(subjects ...string) string

+ func (c *Client) PublishChange(ctx context.Context, subject string, data pubsubx.ChangeMessage) error

+ type EventOption func(m *pubsubx.ChangeMessage)

+ func WithActorID(u string) EventOption

+ func WithAdditionalSubjectIDs(a ...string) EventOption

+ func WithSubjectID(s string) EventOption

May 1, 2023

Changes in this version

+ func NewMetadataURN(id string) string

Apr 26, 2023

Changes in this version

+ const DefaultMessageSource

+ var ErrMissingEventActorURN = errors.New("missing event actor urn")

+ var ErrMissingEventSource = errors.New("missing event source")

+ var ErrMissingEventSubjectURN = errors.New("missing event subject urn")

+ func NewMessage(tenantURN string, opts ...MsgOption) (*pubsubx.Message, error)

+ type MsgOption func(m *pubsubx.Message)

+ func WithActorURN(u string) MsgOption

+ func WithAdditionalData(d map[string]interface{}) MsgOption

+ func WithAdditionalSubjectURNs(a ...string) MsgOption

+ func WithEventType(e string) MsgOption

+ func WithSource(s string) MsgOption

+ func WithSubjectFields(f map[string]string) MsgOption

+ func WithSubjectURN(s string) MsgOption

Mar 29, 2023

Changes in this version

+ func NewPortMessage(actorURN string, tenantURN string, portURN string, ...) (*pubsubx.Message, error)

+ func NewPortURN(id string) string

Mar 21, 2023

Changes in this version

+ const CreateEventType

+ const DeleteEventType

+ const UpdateEventType

+ func NewFrontendMessage(actorURN string, tenantURN string, frontendURN string, ...) (*pubsubx.Message, error)

+ func NewFrontendURN(id string) string

+ func NewOriginMessage(actorURN string, tenantURN string, originURN string, ...) (*pubsubx.Message, error)

+ func NewOriginURN(id string) string

+ func NewPoolMessage(actorURN string, tenantURN string, poolURN string, ...) (*pubsubx.Message, error)

+ func NewPoolURN(id string) string

+ func NewTenantURN(id string) string

type Client

+ func (c *Client) ChanSubscribe(ctx context.Context, sub string, ch chan *nats.Msg, stream string) (*nats.Subscription, error)

Mar 1, 2023

Changes in this version

+ type Client struct

+ func NewClient(opts ...Option) *Client

+ func (c *Client) AddStream() (*nats.StreamInfo, error)

+ func (c *Client) PublishCreate(ctx context.Context, actor, location string, data *pubsubx.Message) error

+ func (c *Client) PublishDelete(ctx context.Context, actor, location string, data *pubsubx.Message) error

+ func (c *Client) PublishUpdate(ctx context.Context, actor, location string, data *pubsubx.Message) error

+ type Option func(c *Client)

+ func WithJetreamContext(js nats.JetStreamContext) Option

+ func WithLogger(l *zap.SugaredLogger) Option

+ func WithStreamName(s string) Option

+ func WithSubjectPrefix(p string) Option

Feb 21, 2023

Changes in this version

+ var ErrInvalidActorURN = errors.New("invalid actor urn")

+ var ErrInvalidAssignmentURN = errors.New("invalid assignment urn")

+ var ErrInvalidTenantURN = errors.New("invalid tenant urn")

+ var ErrInvalidURN = errors.New("invalid urn")

+ func NewAssignmentMessage(actorURN string, tenantURN string, assignmentURN string, ...) (*pubsubx.Message, error)

+ func NewAssignmentURN(assignmentID string) string

+ func NewLoadBalancerMessage(actorURN string, tenantURN string, loadBalancerURN string, ...) (*pubsubx.Message, error)

+ func NewLoadBalancerURN(loadBalancerID string) string

+ func PublishCreate(ctx context.Context, js nats.JetStreamContext, actor, location string, ...) error

+ func PublishDelete(ctx context.Context, js nats.JetStreamContext, actor, location string, ...) error

+ func PublishUpdate(ctx context.Context, js nats.JetStreamContext, actor, location string, ...) error