# Functions
ConfigureTopics configures and checks topics in the slice passed.
NewEmitter creates a new wrapped goka emitter.
NewMetrics creates a new metrics handler.
NewProtoViewSourceJob creates a new proto view source job.
NewProtoWrapper creates a new proto schema codec ProtoWrapper.
NewRegistry creates a new proto schema registry.
NewService creates a new kafmesh service.
NewSinkRunner create a new sink runner.
WaitTillServiceIsRunning waits till the kafmesh service is running.
# Constants
MessageTypeProtobuf uses protobuf serialization.
# Structs
Codec is a goka codec for proto schema objects.
ComponentDiscovery provides component information for discovery.
Emitter is the emitter for a goka stream.
InputDiscovery provides input information for discovery.
JoinDiscovery provides join information for discovery.
LookupDiscovery provides lookup information for discovery.
MessageContext is the extra kafka context data for the message.
Metrics handles prometheus metrics.
OutputDiscovery provides output information for discovery.
PersistentDiscovery provides persistence information for discovery.
ProcessorContext is a context for processor observability.
ProcessorDiscovery provides processor information for discovery.
ProtoViewSourceJob executes a protobuf synchronize.
ProtoWrapper is a codec generator for proto schema codecs.
Registry is the proto schema registry api.
Service is the kafmesh service.
ServiceDiscovery provides service information for discovery.
ServiceOptions are the options passed to services.
SinkDiscovery provides sink information for discovery.
SinkRunner is a sink runner for kafmesh.
SourceDiscovery provides source information for discovery.
Topic is a definition for a kafka topic.
TopicDiscovery provides topic information for discovery.
ViewDiscovery adds view information for discovery.
ViewSinkDiscovery provides view sink information for discovery.
ViewSourceDiscovery provides view source information for discovery.
# Interfaces
EmitMessage is the message to be emitted.
Message is a protobuf object.
SinkDefinition is the definition of a sink that runs at an interval and will also flush if the buffer is full.
# Type aliases
KafaConfigurator configures the kafka topics require to run the service.
MessageType is the type of serialization used for the kafka topic.