pubsub

Documentation

Index

• type AsyncCallListener
• type Scheduler
• type Service
  • func New(conn libdal.Connection, encryption *encryption.Service, scheduler Scheduler, ...) *Service
  • func (s *Service) AsyncCallDidCommit(ctx context.Context, origin async.AsyncOriginPubSub)
  • func (s *Service) CreateSubscribers(ctx context.Context, key model.DeploymentKey, module *schema.Module) error
  • func (s *Service) CreateSubscriptions(ctx context.Context, key model.DeploymentKey, module *schema.Module) error
  • func (s *Service) OnCallCompletion(ctx context.Context, tx libdal.Connection, origin async.AsyncOriginPubSub, ...) error
  • func (s *Service) PublishEventForTopic(ctx context.Context, module, topic, caller string, payload []byte) error
  • func (s *Service) RemoveSubscriptionsAndSubscribers(ctx context.Context, key model.DeploymentKey) error
  • func (s *Service) ResetSubscription(ctx context.Context, module, name string) (err error)

Types

type AsyncCallListener

type AsyncCallListener interface {
	AsyncCallWasAdded(ctx context.Context)
}

type Scheduler

type Scheduler interface {
	Singleton(name string, retry backoff.Backoff, job scheduledtask.Job)
	Parallel(name string, retry backoff.Backoff, job scheduledtask.Job)
}

type Service

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

func New

func New(conn libdal.Connection, encryption *encryption.Service, scheduler Scheduler, asyncCallListener optional.Option[AsyncCallListener]) *Service

func (*Service) AsyncCallDidCommit

func (s *Service) AsyncCallDidCommit(ctx context.Context, origin async.AsyncOriginPubSub)

AsyncCallDidCommit is called after a subscription's async call has been completed and committed to the database.

func (*Service) CreateSubscribers

func (s *Service) CreateSubscribers(ctx context.Context, key model.DeploymentKey, module *schema.Module) error

func (*Service) CreateSubscriptions

func (s *Service) CreateSubscriptions(ctx context.Context, key model.DeploymentKey, module *schema.Module) error

func (*Service) OnCallCompletion

func (s *Service) OnCallCompletion(ctx context.Context, tx libdal.Connection, origin async.AsyncOriginPubSub, failed bool, isFinalResult bool) error

OnCallCompletion is called within a transaction after an async call has completed to allow the subscription state to be updated.

func (*Service) PublishEventForTopic

func (s *Service) PublishEventForTopic(ctx context.Context, module, topic, caller string, payload []byte) error

func (*Service) RemoveSubscriptionsAndSubscribers

func (s *Service) RemoveSubscriptionsAndSubscribers(ctx context.Context, key model.DeploymentKey) error

func (*Service) ResetSubscription

func (s *Service) ResetSubscription(ctx context.Context, module, name string) (err error)