client

Documentation

Index

• type Client
  • func (c *Client) Cancel(ctx context.Context, taskId string) error
  • func (c *Client) Enqueue(task queue.Task) (uuid.UUID, error)
• type MockTaskClient
  • func NewMockTaskClient(t interface{ ... }) *MockTaskClient
  • func (_m *MockTaskClient) Cancel(ctx context.Context, taskId string) error
  • func (_m *MockTaskClient) Enqueue(task queue.Task) (uuid.UUID, error)
• type TaskClient
  • func NewTaskClient(q queue.Queue) TaskClient

Types

type Client

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

func (*Client) Cancel

func (c *Client) Cancel(ctx context.Context, taskId string) error

func (*Client) Enqueue

func (c *Client) Enqueue(task queue.Task) (uuid.UUID, error)

TODO propgate context to enqueue

type MockTaskClient

type MockTaskClient struct {
	mock.Mock
}

MockTaskClient is an autogenerated mock type for the TaskClient type

func NewMockTaskClient

func NewMockTaskClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockTaskClient

NewMockTaskClient creates a new instance of MockTaskClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockTaskClient) Cancel

func (_m *MockTaskClient) Cancel(ctx context.Context, taskId string) error

Cancel provides a mock function with given fields: ctx, taskId

func (*MockTaskClient) Enqueue

func (_m *MockTaskClient) Enqueue(task queue.Task) (uuid.UUID, error)

Enqueue provides a mock function with given fields: task

type TaskClient

type TaskClient interface {
	Enqueue(task queue.Task) (uuid.UUID, error)
	Cancel(ctx context.Context, taskId string) error
}

func NewTaskClient

func NewTaskClient(q queue.Queue) TaskClient