pubsub

Documentation

Overview

Package pubsub wraps nats calls

Index

• Variables
• 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

Variables

var (
	ErrInvalidActorURN      = errors.New("invalid actor urn")
	ErrInvalidTenantURN     = errors.New("invalid tenant urn")
	ErrInvalidAssignmentURN = errors.New("invalid assignment urn")
	ErrInvalidURN           = errors.New("invalid urn")
)

nolint

Functions

func NewAssignmentMessage

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

NewAssignmentMessage creates a new assignment message

func NewAssignmentURN

func NewAssignmentURN(assignmentID string) string

NewAssignmentURN creates a new assignment URN

func NewLoadBalancerMessage

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

NewLoadBalancerMessage creates a new loadbalancer message

func NewLoadBalancerURN

func NewLoadBalancerURN(loadBalancerID string) string

NewLoadBalancerURN creates a new loadbalancer URN

func PublishCreate

func PublishCreate(ctx context.Context, js nats.JetStreamContext, actor, location string, data *pubsubx.Message) error

PublishCreate publishes a create event

func PublishDelete

func PublishDelete(ctx context.Context, js nats.JetStreamContext, actor, location string, data *pubsubx.Message) error

PublishDelete publishes a delete event

func PublishUpdate

func PublishUpdate(ctx context.Context, js nats.JetStreamContext, actor, location string, data *pubsubx.Message) error

PublishUpdate publishes an update event