job

Documentation

Index

• type NewChannelJob
  • func (j NewChannelJob) Name() string
• type NewUserJob
  • func (j NewUserJob) Name() string
• type Server
  • func NewServer(core core.Core) *Server
  • func (s *Server) Dispatch(ctx context.Context, message async.Message) error
  • func (s *Server) Handler() http.Handler
  • func (s *Server) NewChannelJob(ctx context.Context, payload NewChannelJob) error
  • func (s *Server) NewUserJob(ctx context.Context, payload NewUserJob) error

Types

type NewChannelJob

type NewChannelJob struct {
	ChannelID string
}

func (NewChannelJob) Name

func (j NewChannelJob) Name() string

type NewUserJob

type NewUserJob struct {
	UserID string
}

func (NewUserJob) Name

func (j NewUserJob) Name() string

type Server

type Server struct {
	core.Core
}

func NewServer

func NewServer(core core.Core) *Server

func (*Server) Dispatch

func (s *Server) Dispatch(ctx context.Context, message async.Message) error

func (*Server) Handler

func (s *Server) Handler() http.Handler

func (*Server) NewChannelJob

func (s *Server) NewChannelJob(ctx context.Context, payload NewChannelJob) error

func (*Server) NewUserJob

func (s *Server) NewUserJob(ctx context.Context, payload NewUserJob) error