instructions

Documentation

Index

• func Convert(ctx context.Context, msgs chan *pulsarutils.ConsumerMessage, bufferSize int, ...) chan *model.InstructionSet
• func ConvertMsg(ctx context.Context, msg *pulsarutils.ConsumerMessage, ...) *model.InstructionSet
• type HasNodeName

Functions

func Convert

func 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 ConvertMsg

func 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.

Types

type HasNodeName

type HasNodeName interface {
	GetNodeName() string
}