mocks

Documentation

Index

• type EventListenerMock
  • func (e *EventListenerMock) ListenAndServe(ctx context.Context) error
  • func (e *EventListenerMock) Run(ctx context.Context)
  • func (e *EventListenerMock) Subscribe(eventType broker.EventType, offset uint64) (bool, error)
  • func (e *EventListenerMock) Unsubscribe(eventType broker.EventType) (bool, error)
• type SafeBuffer
  • func (b *SafeBuffer) Read(p []byte) (n int, err error)
  • func (b *SafeBuffer) Seek(offset int64, whence int) (ret int64, err error)
  • func (b *SafeBuffer) String() string
  • func (b *SafeBuffer) Truncate(size int64) error
  • func (b *SafeBuffer) Write(p []byte) (n int, err error)

Types

type EventListenerMock

type EventListenerMock struct{}

func (*EventListenerMock) ListenAndServe

func (e *EventListenerMock) ListenAndServe(ctx context.Context) error

func (*EventListenerMock) Run

func (e *EventListenerMock) Run(ctx context.Context)

func (*EventListenerMock) Subscribe

func (e *EventListenerMock) Subscribe(eventType broker.EventType, offset uint64) (bool, error)

func (*EventListenerMock) Unsubscribe

func (e *EventListenerMock) Unsubscribe(eventType broker.EventType) (bool, error)

type SafeBuffer

type SafeBuffer struct {
	// contains filtered or unexported fields
}

func (*SafeBuffer) Read

func (b *SafeBuffer) Read(p []byte) (n int, err error)

func (*SafeBuffer) Seek

func (b *SafeBuffer) Seek(offset int64, whence int) (ret int64, err error)

func (*SafeBuffer) String

func (b *SafeBuffer) String() string

func (*SafeBuffer) Truncate

func (b *SafeBuffer) Truncate(size int64) error

func (*SafeBuffer) Write

func (b *SafeBuffer) Write(p []byte) (n int, err error)