writer

Documentation

Index

• Constants
• type Writer
  • func NewWriter(commonOpts *genericoptions.KafkaOptions, ...) (*Writer, error)
  • func (l *Writer) WriteMessage(ctx context.Context, msg *types.TemplateMsgRequest, messageType string) error
  • func (l *Writer) WriteUplinkMessage(ctx context.Context, msg *types.UplinkMsgRequest)
  • func (l *Writer) WriterHistory(history *model.HistoryM)

Constants

const (
	VerificationMessage = "VERIFICATION_MESSAGE"
)

Types

type Writer

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

Writer is a log.Writer implementation that writes log messages to Kafka.

func NewWriter

func NewWriter(commonOpts *genericoptions.KafkaOptions,
	verifyOpts *genericoptions.KafkaOptions,
	uplinkOpts *genericoptions.KafkaOptions,
	historyStore store.HistoryStore) (*Writer, error)

NewWriter creates a new kafkaLogger instance.

func (*Writer) WriteMessage

func (l *Writer) WriteMessage(ctx context.Context, msg *types.TemplateMsgRequest, messageType string) error

WriteMessage writes a log message for the common message.

func (*Writer) WriteUplinkMessage

func (l *Writer) WriteUplinkMessage(ctx context.Context, msg *types.UplinkMsgRequest)

WriteUplinkMessage writes a log message for the uplink message.

func (*Writer) WriterHistory

func (l *Writer) WriterHistory(history *model.HistoryM)

WriterHistory adds a new history record in the datastore.