types

type Acknowledgement struct {
	Status int
	Offset int
	Event  *kafka.Message
}

type CommitStore struct {
	Value   bool
	Message *kafka.Message
}

type DeadLetter struct {
	UUID      string
	TIMESTAMP string
	Topic     string
	Partition int
	Offset    int
	Key       string
	String    string
	Headers   string
}

type SafeCommitHash struct {
	Mutex sync.Mutex
	// contains filtered or unexported fields
}

type TriageConfig struct {
	TopicName           string
	DeadLetterTableName string
	AuthenticationToken string
	KafkaConfigMap      kafka.ConfigMap
}