mocks

Oct 28, 2024

Changes in this version

+ type Client struct

+ func NewClient(t interface{ ... }) *Client

+ func (_m *Client) Close() error

+ func (_m *Client) Submit(ctx context.Context, pattern worker.TaskPattern, payload []byte) error

+ func (_m *Client) SubmitToBatch(ctx context.Context, pattern worker.TaskPattern, payload []byte) error

+ type Server struct

+ func NewServer(t interface{ ... }) *Server

+ func (_m *Server) HandleCron(spec worker.CronSpec, cronFunc worker.CronHandler)

+ func (_m *Server) HandleTask(pattern worker.TaskPattern, cb worker.TaskHandler, opts ...worker.TaskOption)

+ func (_m *Server) Shutdown()

+ func (_m *Server) Start() error