mocks

Documentation

Index

• type MockedAMQPClient
  • func (m *MockedAMQPClient) Channel() (*amqp.Channel, error)
  • func (m *MockedAMQPClient) Close() error
• type MockedAcknowledger
  • 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
  • func (m *MockedChannel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-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
  • 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
  • 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
  • func (m *MockedTranscoder) Process() transcoding.IProcess
  • func (m *MockedTranscoder) Run(p transcoding.IProcess) error

Types

type MockedAMQPClient

type MockedAMQPClient struct {
	mock.Mock
}

func (*MockedAMQPClient) Channel

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

func (*MockedAMQPClient) Close

func (m *MockedAMQPClient) Close() error

type MockedAcknowledger

type MockedAcknowledger struct {
	mock.Mock
}

func (*MockedAcknowledger) Ack

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

func (*MockedAcknowledger) Nack

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

func (*MockedAcknowledger) Reject

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

type MockedChannel

type MockedChannel struct {
	mock.Mock
}

func (*MockedChannel) Consume

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

func (*MockedChannel) Publish

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

func (*MockedChannel) QueueDeclare

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

type MockedLogger

type MockedLogger struct {
	mock.Mock
}

func (*MockedLogger) Error

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

func (*MockedLogger) Fatal

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

func (*MockedLogger) Info

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

func (*MockedLogger) Sync

func (m *MockedLogger) Sync() error

func (*MockedLogger) With

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

type MockedStorage

type MockedStorage struct {
	mock.Mock
}

func (*MockedStorage) Delete

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

func (*MockedStorage) Open

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

func (*MockedStorage) Save

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

func (*MockedStorage) Stat

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

type MockedTranscoder

type MockedTranscoder struct {
	mock.Mock
}

func (*MockedTranscoder) Process

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

func (*MockedTranscoder) Run

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