pubsub

Documentation

Index

• type AsyncCallListener
• type DAL
• type Manager
  • func New(ctx context.Context, dal *dal.DAL, scheduler Scheduler, ...) *Manager
  • func (m *Manager) AsyncCallDidCommit(ctx context.Context, origin dal.AsyncOriginPubSub)
  • func (m *Manager) OnCallCompletion(ctx context.Context, tx *dal.Tx, origin dal.AsyncOriginPubSub, failed bool, ...) error
• type Scheduler

Types

type AsyncCallListener

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

type DAL

type DAL interface {
	ProgressSubscriptions(ctx context.Context, eventConsumptionDelay time.Duration) (count int, err error)
	CompleteEventForSubscription(ctx context.Context, module, name string) error
}

type Manager

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

func New

func New(ctx context.Context, dal *dal.DAL, scheduler Scheduler, asyncCallListener AsyncCallListener) *Manager

func (*Manager) AsyncCallDidCommit

func (m *Manager) AsyncCallDidCommit(ctx context.Context, origin dal.AsyncOriginPubSub)

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

func (*Manager) OnCallCompletion

func (m *Manager) OnCallCompletion(ctx context.Context, tx *dal.Tx, origin dal.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.

type Scheduler

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