pubsub

Documentation

Index

• type DAL
• type Manager
  • func New(ctx context.Context, key model.ControllerKey, dal *dal.DAL) *Manager
  • func (m *Manager) HandleEventNotification()
  • func (m *Manager) HandleTopicNotification()
  • func (m *Manager) OnCallCompletion(ctx context.Context, tx *dal.Tx, origin dal.AsyncOriginPubSub, failed bool) error
  • func (m *Manager) UpdatedControllerList(ctx context.Context, controllers []dal.Controller)

Types

type DAL

type DAL interface {
	GetSubscriptionsNeedingUpdate(ctx context.Context) ([]model.Subscription, error)
	ProgressSubscription(ctx context.Context, subscription model.Subscription) 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, key model.ControllerKey, dal *dal.DAL) *Manager

func (*Manager) HandleEventNotification

func (m *Manager) HandleEventNotification()

func (*Manager) HandleTopicNotification

func (m *Manager) HandleTopicNotification()

func (*Manager) OnCallCompletion

func (m *Manager) OnCallCompletion(ctx context.Context, tx *dal.Tx, origin dal.AsyncOriginPubSub, failed bool) error

func (*Manager) UpdatedControllerList

func (m *Manager) UpdatedControllerList(ctx context.Context, controllers []dal.Controller)

UpdatedControllerList synchronises the hash ring with the active controllers.