event

Documentation

Index

• func WithNamePrefix(name string) syncOption
• func WithSubject(subject string) syncOption
• type Func
  • func FnDB[T any](fn func(context.Context, *T) error) Func
• type FuncsMap
• type Sync
  • func NewSync(getter bus.Getter, opts ...syncOption) *Sync
  • func (s *Sync) Continue(ctx context.Context) error
  • func (s *Sync) IsLocked() bool
  • func (s *Sync) Lock() error
  • func (s *Sync) Once(ctx context.Context, wait time.Duration) error
  • func (s *Sync) Register(subject string, fn Func)
  • func (s *Sync) Start(ctx context.Context, onceTimeout time.Duration) error

Functions

func WithNamePrefix

func WithNamePrefix(name string) syncOption

WithNamePrefix is used to set the name prefix for the continue event This is useful if you have multiple instance of same serive running and using a unique name for each instance make sure that each instance process their own queue of messages. Restarting the instance with the same name will make sure that the instance will continue processing the messages from the last point.

func WithSubject

func WithSubject(subject string) syncOption

Types

type Func

type Func func(ctx context.Context, evt *bus.Event) error

func FnDB

func FnDB[T any](fn func(context.Context, *T) error) Func

type FuncsMap

type FuncsMap map[string][]Func

type Sync

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

func NewSync

func NewSync(getter bus.Getter, opts ...syncOption) *Sync

func (*Sync) Continue

func (s *Sync) Continue(ctx context.Context) error

func (*Sync) IsLocked

func (s *Sync) IsLocked() bool

func (*Sync) Lock

func (s *Sync) Lock() error

func (*Sync) Once

func (s *Sync) Once(ctx context.Context, wait time.Duration) error

func (*Sync) Register

func (s *Sync) Register(subject string, fn Func)

func (*Sync) Start

func (s *Sync) Start(ctx context.Context, onceTimeout time.Duration) error

Start is a simple wrapper around Once and Continue if the context gets canceled, contine will be stopped as well