customdestinationmanager

Documentation

Index

• Constants
• Variables
• func Init()
• type CustomManagerT
  • func (customManager *CustomManagerT) BackendConfigInitialized() <-chan struct{}
  • func (customManager *CustomManagerT) SendData(jsonData json.RawMessage, destID string) (int, string)
• type DestinationManager
  • func New(destType string, o Opts) DestinationManager
• type Opts

Constants

const (
	STREAM              = "stream"
	KV                  = "kv"
	CLIENT_EXPIRED_CODE = 721
)

Variables

var (
	ObjectStreamDestinations []string
	KVStoreDestinations      []string
	Destinations             []string
)

Functions

func Init

func Init()

Types

type CustomManagerT

type CustomManagerT struct {
	// contains filtered or unexported fields
}

CustomManagerT handles this module

func (*CustomManagerT) BackendConfigInitialized

func (customManager *CustomManagerT) BackendConfigInitialized() <-chan struct{}

func (*CustomManagerT) SendData

func (customManager *CustomManagerT) SendData(jsonData json.RawMessage, destID string) (int, string)

SendData gets the producer from streamDestinationsMap and sends data

type DestinationManager

type DestinationManager interface {
	SendData(jsonData json.RawMessage, destID string) (int, string)
	BackendConfigInitialized() <-chan struct{}
}

DestinationManager implements the method to send the events to custom destinations

func New

func New(destType string, o Opts) DestinationManager

New returns CustomdestinationManager

type Opts

type Opts struct {
	Timeout time.Duration
}