connector

Documentation

Overview

Package connector provides the connector of the broker.

Index

• type RealTimeConnector

Types

type RealTimeConnector

type RealTimeConnector interface {
	// Produce produce a Message to the queue in real time
	Produce(ctx context.Context, msg *types.Message) error
	// NewConsumer new a consumer to consume Messages from the realtime queue in background
	NewConsumer(topic, group string, batchSize int, fn type2.HandleMessage) error
	// Close the queue
	Close() error
}

RealTimeConnector is a connector which can send messages to the realtime queue the realtime queue can store or consume messages in realtime