worker

Documentation

Index

• type Handle
  • func NewHandle[T any](param *param.Handle[T], get callback.GetConsumer[T]) *Handle[T]
  • func (h *Handle[T]) Start(ctx context.Context, handler message.Handler[T]) (err error)
• type Send
  • func NewSend[T any](param *param.Send[T], get callback.GetProducer[T]) *Send[T]
  • func (s *Send[T]) Do(ctx context.Context, payload T) (id *message.Id, err error)

Types

type Handle

type Handle[T any] struct {
	simaqian.Logger
	// contains filtered or unexported fields
}

func NewHandle

func NewHandle[T any](param *param.Handle[T], get callback.GetConsumer[T]) *Handle[T]

func (*Handle[T]) Start

func (h *Handle[T]) Start(ctx context.Context, handler message.Handler[T]) (err error)

type Send

type Send[T any] struct {
	// contains filtered or unexported fields
}

func NewSend

func NewSend[T any](param *param.Send[T], get callback.GetProducer[T]) *Send[T]

func (*Send[T]) Do

func (s *Send[T]) Do(ctx context.Context, payload T) (id *message.Id, err error)