mocks

Documentation

Index

• type MockConsumerGroup
  • func (m *MockConsumerGroup) Claims() map[string][]int32
  • func (m *MockConsumerGroup) Close() error
  • func (m *MockConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error
  • func (m *MockConsumerGroup) Errors() <-chan error
  • func (m *MockConsumerGroup) MemberID() string
  • func (m *MockConsumerGroup) Pause(map[string][]int32)
  • func (m *MockConsumerGroup) PauseAll()
  • func (m *MockConsumerGroup) Resume(map[string][]int32)
  • func (m *MockConsumerGroup) ResumeAll()
  • func (m *MockConsumerGroup) Topics() []string
• type MockConsumerGroupClaim
  • func (m *MockConsumerGroupClaim) Messages() <-chan *sarama.ConsumerMessage
• type MockConsumerGroupSession
  • func (m *MockConsumerGroupSession) MarkMessage(msg *sarama.ConsumerMessage, metadata string)
• type MockMainService
  • func (m *MockMainService) MainFuncService(data []request.DataDetail) *fiber.Map

Types

type MockConsumerGroup

type MockConsumerGroup struct {
	mock.Mock
}

func (*MockConsumerGroup) Claims

func (m *MockConsumerGroup) Claims() map[string][]int32

func (*MockConsumerGroup) Close

func (m *MockConsumerGroup) Close() error

func (*MockConsumerGroup) Consume

func (m *MockConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error

func (*MockConsumerGroup) Errors

func (m *MockConsumerGroup) Errors() <-chan error

func (*MockConsumerGroup) MemberID

func (m *MockConsumerGroup) MemberID() string

func (*MockConsumerGroup) Pause

func (m *MockConsumerGroup) Pause(map[string][]int32)

func (*MockConsumerGroup) PauseAll

func (m *MockConsumerGroup) PauseAll()

func (*MockConsumerGroup) Resume

func (m *MockConsumerGroup) Resume(map[string][]int32)

func (*MockConsumerGroup) ResumeAll

func (m *MockConsumerGroup) ResumeAll()

func (*MockConsumerGroup) Topics

func (m *MockConsumerGroup) Topics() []string

type MockConsumerGroupClaim

type MockConsumerGroupClaim struct {
	mock.Mock
	sarama.ConsumerGroupClaim
}

MockConsumerGroupClaim is a mock for sarama.ConsumerGroupClaim

func (*MockConsumerGroupClaim) Messages

func (m *MockConsumerGroupClaim) Messages() <-chan *sarama.ConsumerMessage

Messages returns the mocked message channel

type MockConsumerGroupSession

type MockConsumerGroupSession struct {
	mock.Mock
	sarama.ConsumerGroupSession
}

MockConsumerGroupSession is a mock for sarama.ConsumerGroupSession

func (*MockConsumerGroupSession) MarkMessage

func (m *MockConsumerGroupSession) MarkMessage(msg *sarama.ConsumerMessage, metadata string)

MarkMessage is a mock method to track message acknowledgment.

type MockMainService

type MockMainService struct {
	mock.Mock
}

MockMainService is a mock for the MainService interface

func (*MockMainService) MainFuncService

func (m *MockMainService) MainFuncService(data []request.DataDetail) *fiber.Map

MainFuncService is a mock method to simulate the processing of data