customdestinationmanager

package
v1.11.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 28, 2023 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source
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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL