instructions

Documentation

Index

• type HasNodeName
• type Service
  • func New(m *metrics.Metrics) *Service
  • func (s *Service) Convert(ctx context.Context, msgs chan *pulsarutils.ConsumerMessage, bufferSize int, ...) chan *model.InstructionSet
  • func (s *Service) ConvertMsg(ctx context.Context, msg *pulsarutils.ConsumerMessage, ...) *model.InstructionSet

Types

type HasNodeName

type HasNodeName interface {
	GetNodeName() string
}

type Service

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

func New

func New(m *metrics.Metrics) *Service

func (*Service) Convert

func (s *Service) Convert(
	ctx context.Context,
	msgs chan *pulsarutils.ConsumerMessage,
	bufferSize int,
	userAnnotationPrefix string,
	compressor compress.Compressor,
) chan *model.InstructionSet

Convert takes a channel containing incoming pulsar messages and returns a channel with the corresponding InstructionSets. Each pulsar message will generate exactly one InstructionSet.

func (*Service) ConvertMsg

func (s *Service) ConvertMsg(
	ctx context.Context,
	msg *pulsarutils.ConsumerMessage,
	userAnnotationPrefix string,
	compressor compress.Compressor,
) *model.InstructionSet

ConvertMsg converts a pulsar message into an InstructionSet. An instructionSet will always be produced even if errors are encountered via parsing. In this case of errors, the resulting InstructionSet will contain all events that could be parsed, along with the mesageId of the original message. In the case that no events can be parsed (e.g. the message is not valid protobuf), an empty InstructionSet containing only the messageId will be returned.