workers

Documentation

Index

• type Processor
  • func New(state *state.State, federator *federation.Federator, ...) Processor
  • func (p *Processor) EnqueueClientAPI(cctx context.Context, msgs ...messages.FromClientAPI)
  • func (p *Processor) EnqueueFediAPI(cctx context.Context, msgs ...messages.FromFediAPI)
  • func (p *Processor) ProcessFromClientAPI(ctx context.Context, cMsg messages.FromClientAPI) error
  • func (p *Processor) ProcessFromFediAPI(ctx context.Context, fMsg messages.FromFediAPI) error

Types

type Processor

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

func New

func New(
	state *state.State,
	federator *federation.Federator,
	converter *typeutils.Converter,
	filter *visibility.Filter,
	emailSender email.Sender,
	account *account.Processor,
	media *media.Processor,
	stream *stream.Processor,
) Processor

func (*Processor) EnqueueClientAPI

func (p *Processor) EnqueueClientAPI(cctx context.Context, msgs ...messages.FromClientAPI)

func (*Processor) EnqueueFediAPI

func (p *Processor) EnqueueFediAPI(cctx context.Context, msgs ...messages.FromFediAPI)

func (*Processor) ProcessFromClientAPI

func (p *Processor) ProcessFromClientAPI(ctx context.Context, cMsg messages.FromClientAPI) error

func (*Processor) ProcessFromFediAPI

func (p *Processor) ProcessFromFediAPI(ctx context.Context, fMsg messages.FromFediAPI) error