Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Formatter ¶
func NewProtoFormatter ¶
func NewProtoFormatter(messageType protoreflect.MessageType) Formatter
func NewRawFormatter ¶
func NewRawFormatter() Formatter
func NewTextFormatter ¶
func NewTextFormatter() Formatter
type Reader ¶
type Reader interface {
Read() (*dto.KafkaMessage, error)
}
type Writer ¶
type Writer interface {
Write(*dto.KafkaMessage) error
}
Click to show internal directories.
Click to hide internal directories.