mocks

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 21, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAddrMock

func NewAddrMock(addr string) net.Addr

func NewConnMock

func NewConnMock() websocket.Conn

func NewProviderMock

func NewProviderMock(
	taskClient task.TaskClient,
	subscriber subscriber.Subscriber,
	websocket websocket.Websocket,
	store websocket.Store) download.Provider

func NewSubscriberMock

func NewSubscriberMock() subscriber.Subscriber

func NewTaskClientMock

func NewTaskClientMock() task.TaskClient

func NewWebsocketMock

func NewWebsocketMock() websocket.Websocket

Types

type AddrMock

type AddrMock struct {
	mock.Mock
}

func (*AddrMock) Network

func (m *AddrMock) Network() string

func (*AddrMock) String

func (m *AddrMock) String() string

type ConnMock

type ConnMock struct {
	mock.Mock
}

func (*ConnMock) Close

func (m *ConnMock) Close() error

func (*ConnMock) ReadJSON

func (m *ConnMock) ReadJSON(p interface{}) error

func (*ConnMock) RemoteAddr

func (m *ConnMock) RemoteAddr() net.Addr

func (*ConnMock) WriteJSON

func (m *ConnMock) WriteJSON(p interface{}) error

type ProviderMock

type ProviderMock struct {
	mock.Mock
}

func (*ProviderMock) NewSubscriber

func (m *ProviderMock) NewSubscriber(
	onReceive func(ctx context.Context, message *pubsub.Message),
	projectID string, subscriptionID string,
	logger *log.Logger) (subscriber.Subscriber, error)

func (*ProviderMock) NewTaskClient

func (m *ProviderMock) NewTaskClient(
	queuePath string, target string) (task.TaskClient, error)

func (*ProviderMock) NewWebsocket

func (m *ProviderMock) NewWebsocket(
	origins []string) (websocket.Websocket, error)

func (*ProviderMock) NewWebsocketStore

func (m *ProviderMock) NewWebsocketStore() websocket.Store

type SubscriberMock

type SubscriberMock struct {
	mock.Mock
}

func (*SubscriberMock) Close

func (m *SubscriberMock) Close()

func (*SubscriberMock) Listen

func (m *SubscriberMock) Listen() error

func (*SubscriberMock) NewJobStatus

func (m *SubscriberMock) NewJobStatus(
	message *pubsub.Message) (*subscriber.JobStatus, error)

type TaskClientMock

type TaskClientMock struct {
	mock.Mock
}

func (*TaskClientMock) Close

func (m *TaskClientMock) Close() error

func (*TaskClientMock) CreateTask

func (m *TaskClientMock) CreateTask(
	tPayload task.Task) (*taskspb.Task, error)

type WebsocketMock

type WebsocketMock struct {
	mock.Mock
}

func (*WebsocketMock) IsClosed

func (m *WebsocketMock) IsClosed(err error) bool

func (*WebsocketMock) Upgrade

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL