rtq

Documentation

Index

• func NewQ(name string, cfg Config) (*rtQ, error)
• func RxRouteHandler(c *gin.Context)
• type Config
• type Message
• type MessageBatch

Functions

func NewQ

func NewQ(name string, cfg Config) (*rtQ, error)

NewQ returns a new rtQ

func RxRouteHandler

func RxRouteHandler(c *gin.Context)

RxRouteHandler handles the http route for inbound data

Types

type Config

type Config struct {
	Interval   time.Duration
	Batch      int
	MaxInQueue int
	Logger     *zap.Logger
	Receiver   string
	Path       string
}

Config options for rxtx

type Message

type Message struct {
	Seq      string                 `json:"seq"`
	Time     time.Time              `json:"time"`
	Uuid     string                 `json:"uuid"`
	Producer string                 `json:"producer"`
	Label    string                 `json:"label"`
	Key      string                 `json:"key"`
	Payload  map[string]interface{} `json:"payload"`
}

Message to store and send

type MessageBatch

type MessageBatch struct {
	Uuid     string    `json:"uuid"`
	Size     int       `json:"size"`
	Messages []Message `json:"messages"`
}

MessageBatch Holds a batch of Messages for the server