kafka

Documentation

Index

• Constants
• Variables
• type Context
• type Option

Constants

const DefaultBatchSize = 2048

const (
	EntityType = "kafka"
)

Variables

var (
	NewMessage        = utils.NewMessage
	Execute           = utils.Execute
	NewMessageContext = utils.NewMessageContext
)

Types

type Context

type Context = ruleql.Context

type Option

type Option struct {
	SinkURI string `json:"sink,omitempty"`
}