Documentation ¶
Index ¶
- func NewAddrMock(addr string) net.Addr
- func NewConnMock() websocket.Conn
- func NewProviderMock(taskClient task.TaskClient, subscriber subscriber.Subscriber, ...) download.Provider
- func NewSubscriberMock() subscriber.Subscriber
- func NewTaskClientMock() task.TaskClient
- func NewWebsocketMock() websocket.Websocket
- type AddrMock
- type ConnMock
- type ProviderMock
- func (m *ProviderMock) NewSubscriber(onReceive func(ctx context.Context, message *pubsub.Message), projectID string, ...) (subscriber.Subscriber, error)
- func (m *ProviderMock) NewTaskClient(queuePath string, target string) (task.TaskClient, error)
- func (m *ProviderMock) NewWebsocket(origins []string) (websocket.Websocket, error)
- func (m *ProviderMock) NewWebsocketStore() websocket.Store
- type SubscriberMock
- type TaskClientMock
- type WebsocketMock
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAddrMock ¶
func NewConnMock ¶
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 ¶
Types ¶
type ConnMock ¶
func (*ConnMock) RemoteAddr ¶
type ProviderMock ¶
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 ¶
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 ¶
func (*TaskClientMock) Close ¶
func (m *TaskClientMock) Close() error
func (*TaskClientMock) CreateTask ¶
Click to show internal directories.
Click to hide internal directories.