saramahelpers

Documentation

Overview

Package saramahelpers contains helper function to be used in code based on Sarama library with Kafka interface

Index

• func StringToSaramaConsumerMessage(str string) *sarama.ConsumerMessage
• type MockConsumerGroupClaim
  • func NewMockConsumerGroupClaim(messages []*sarama.ConsumerMessage) *MockConsumerGroupClaim
  • func (cgc *MockConsumerGroupClaim) HighWaterMarkOffset() int64
  • func (cgc *MockConsumerGroupClaim) InitialOffset() int64
  • func (cgc *MockConsumerGroupClaim) Messages() <-chan *sarama.ConsumerMessage
  • func (cgc *MockConsumerGroupClaim) Partition() int32
  • func (cgc *MockConsumerGroupClaim) Topic() string
• type MockConsumerGroupSession
  • func (*MockConsumerGroupSession) Claims() map[string][]int32
  • func (*MockConsumerGroupSession) Commit()
  • func (*MockConsumerGroupSession) Context() context.Context
  • func (*MockConsumerGroupSession) GenerationID() int32
  • func (*MockConsumerGroupSession) MarkMessage(msg *sarama.ConsumerMessage, metadata string)
  • func (*MockConsumerGroupSession) MarkOffset(topic string, partition int32, offset int64, metadata string)
  • func (*MockConsumerGroupSession) MemberID() string
  • func (*MockConsumerGroupSession) ResetOffset(topic string, partition int32, offset int64, metadata string)

Functions

func StringToSaramaConsumerMessage

func StringToSaramaConsumerMessage(str string) *sarama.ConsumerMessage

StringToSaramaConsumerMessage converts string to sarama consumer message

Types

type MockConsumerGroupClaim

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

MockConsumerGroupClaim MockConsumerGroupClaim

func NewMockConsumerGroupClaim

func NewMockConsumerGroupClaim(messages []*sarama.ConsumerMessage) *MockConsumerGroupClaim

NewMockConsumerGroupClaim creates MockConsumerGroupClaim with provided messages

func (*MockConsumerGroupClaim) HighWaterMarkOffset

func (cgc *MockConsumerGroupClaim) HighWaterMarkOffset() int64

HighWaterMarkOffset returns the high water mark offset of the partition,

func (*MockConsumerGroupClaim) InitialOffset

func (cgc *MockConsumerGroupClaim) InitialOffset() int64

InitialOffset returns the initial offset that was used as a starting point for this claim.

func (*MockConsumerGroupClaim) Messages

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

Messages returns the read channel for the messages that are returned by

func (*MockConsumerGroupClaim) Partition

func (cgc *MockConsumerGroupClaim) Partition() int32

Partition returns the consumed partition.

func (*MockConsumerGroupClaim) Topic

func (cgc *MockConsumerGroupClaim) Topic() string

Topic returns the consumed topic name.

type MockConsumerGroupSession

type MockConsumerGroupSession struct{}

MockConsumerGroupSession MockConsumerGroupSession

func (*MockConsumerGroupSession) Claims

func (*MockConsumerGroupSession) Claims() map[string][]int32

Claims returns information about the claimed partitions by topic.

func (*MockConsumerGroupSession) Commit

func (*MockConsumerGroupSession) Commit()

Commit commits

func (*MockConsumerGroupSession) Context

func (*MockConsumerGroupSession) Context() context.Context

Context returns the session context.

func (*MockConsumerGroupSession) GenerationID

func (*MockConsumerGroupSession) GenerationID() int32

GenerationID returns the current generation ID.

func (*MockConsumerGroupSession) MarkMessage

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

MarkMessage marks a message as consumed.

func (*MockConsumerGroupSession) MarkOffset

func (*MockConsumerGroupSession) MarkOffset(topic string, partition int32, offset int64, metadata string)

MarkOffset marks the provided offset, alongside a metadata string

func (*MockConsumerGroupSession) MemberID

func (*MockConsumerGroupSession) MemberID() string

MemberID returns the cluster member ID.

func (*MockConsumerGroupSession) ResetOffset

func (*MockConsumerGroupSession) ResetOffset(topic string, partition int32, offset int64, metadata string)

ResetOffset resets to the provided offset, alongside a metadata string that