Versions in this module Expand all Collapse all v0 v0.1.1 Feb 21, 2024 v0.1.0 Nov 13, 2023 Changes in this version + 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 struct + func (m *AddrMock) Network() string + func (m *AddrMock) String() string + type ConnMock struct + func (m *ConnMock) Close() error + func (m *ConnMock) ReadJSON(p interface{}) error + func (m *ConnMock) RemoteAddr() net.Addr + func (m *ConnMock) WriteJSON(p interface{}) error + type ProviderMock struct + 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 struct + func (m *SubscriberMock) Close() + func (m *SubscriberMock) Listen() error + func (m *SubscriberMock) NewJobStatus(message *pubsub.Message) (*subscriber.JobStatus, error) + type TaskClientMock struct + func (m *TaskClientMock) Close() error + func (m *TaskClientMock) CreateTask(tPayload task.Task) (*taskspb.Task, error) + type WebsocketMock struct + func (m *WebsocketMock) IsClosed(err error) bool + func (m *WebsocketMock) Upgrade(w http.ResponseWriter, r *http.Request, h http.Header) (websocket.Conn, error)
Go to main page