implprocessor

Documentation

Index

• type MockProcessor
  • func New(customFn func() error) *MockProcessor
  • func (m *MockProcessor) BatchProcess(ctx context.Context, messages [][]byte) error
  • func (m *MockProcessor) Process(ctx context.Context, message []byte) error

Types

type MockProcessor

type MockProcessor struct {
	Success  map[string]bool
	CustomFn func() error
	// contains filtered or unexported fields
}

func New

func New(customFn func() error) *MockProcessor

func (*MockProcessor) BatchProcess

func (m *MockProcessor) BatchProcess(ctx context.Context, messages [][]byte) error

func (*MockProcessor) Process

func (m *MockProcessor) Process(ctx context.Context, message []byte) error