mocks

package

v0.1.0 Latest Latest Go to latest Published: Jan 18, 2021 License: GPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MockedAMQPClient struct {
	mock.Mock
}

func (m *MockedAMQPClient) Channel() (*amqp.Channel, error)

func (m *MockedAMQPClient) Close() error

type MockedAcknowledger struct {
	mock.Mock
}

func (m *MockedAcknowledger) Ack(tag uint64, multiple bool) error

func (m *MockedAcknowledger) Nack(tag uint64, multiple bool, requeue bool) error

func (m *MockedAcknowledger) Reject(tag uint64, requeue bool) error

type MockedChannel struct {
	mock.Mock
}

func (m *MockedChannel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

func (m *MockedChannel) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

func (m *MockedChannel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

type MockedLogger struct {
	mock.Mock
}

func (m *MockedLogger) Error(msg string, fields ...zap.Field)

func (m *MockedLogger) Fatal(msg string, fields ...zap.Field)

func (m *MockedLogger) Info(msg string, fields ...zap.Field)

func (m *MockedLogger) Sync() error

func (m *MockedLogger) With(fields ...zap.Field) *zap.Logger

type MockedStorage struct {
	mock.Mock
}

func (m *MockedStorage) Delete(_ context.Context, path string) error

func (m *MockedStorage) Open(_ context.Context, path string) (io.ReadCloser, error)

func (m *MockedStorage) Save(_ context.Context, content io.Reader, path string) error

func (m *MockedStorage) Stat(_ context.Context, path string) (*storage.Stat, error)

type MockedTranscoder struct {
	mock.Mock
}

func (m *MockedTranscoder) Process() transcoding.IProcess

func (m *MockedTranscoder) Run(p transcoding.IProcess) error