dal

Documentation

Index

• type DAL
  • func New(conn libdal.Connection, encryption *encryption.Service) *DAL
  • func (d *DAL) CompleteEventForSubscription(ctx context.Context, module, name string) error
  • func (d *DAL) CreateSubscribers(ctx context.Context, key model.DeploymentKey, module *schema.Module) error
  • func (d *DAL) CreateSubscriptions(ctx context.Context, key model.DeploymentKey, module *schema.Module) error
  • func (d *DAL) GetSubscriptionsNeedingUpdate(ctx context.Context) ([]model.Subscription, error)
  • func (d *DAL) ProgressSubscriptions(ctx context.Context, eventConsumptionDelay time.Duration) (count int, err error)
  • func (d *DAL) PublishEventForTopic(ctx context.Context, module, topic, caller string, payload []byte) error
  • func (d *DAL) RemoveSubscriptionsAndSubscribers(ctx context.Context, key model.DeploymentKey) error
  • func (d *DAL) ResetSubscription(ctx context.Context, module, name string) (err error)

Types

type DAL

type DAL struct {
	*libdal.Handle[DAL]
	// contains filtered or unexported fields
}

func New

func New(conn libdal.Connection, encryption *encryption.Service) *DAL

func (*DAL) CompleteEventForSubscription

func (d *DAL) CompleteEventForSubscription(ctx context.Context, module, name string) error

func (*DAL) CreateSubscribers

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

func (*DAL) CreateSubscriptions

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

func (*DAL) GetSubscriptionsNeedingUpdate

func (d *DAL) GetSubscriptionsNeedingUpdate(ctx context.Context) ([]model.Subscription, error)

func (*DAL) ProgressSubscriptions

func (d *DAL) ProgressSubscriptions(ctx context.Context, eventConsumptionDelay time.Duration) (count int, err error)

func (*DAL) PublishEventForTopic

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

func (*DAL) RemoveSubscriptionsAndSubscribers

func (d *DAL) RemoveSubscriptionsAndSubscribers(ctx context.Context, key model.DeploymentKey) error

func (*DAL) ResetSubscription

func (d *DAL) ResetSubscription(ctx context.Context, module, name string) (err error)

ResetSubscription resets the subscription cursor to the topic's head.