stream

Documentation

Overview

Package stream allows to interact with different stream-processing platforms.

Index

• type Message
• type MetadataEntry
• type MsgHandler
• type Processor

Types

type Message

type Message struct {
	Key      []byte
	Value    []byte
	Metadata []MetadataEntry
}

Message represents a message coming from a stream.

type MetadataEntry

type MetadataEntry struct {
	Key   []byte
	Value []byte
}

MetadataEntry represents a metadata entry.

type MsgHandler

type MsgHandler func(msg Message) error

A MsgHandler processes a message.

type Processor

type Processor interface {
	Process(ctx context.Context, entity string, h MsgHandler) error
}

A Processor represents a stream message processor.