customdestinationmanager

package

v0.0.0-...-0ade494 Latest Latest Go to latest Published: Aug 26, 2022 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

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

View Source

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

func Init()

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

CustomManagerT handles this module

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

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

SendData gets the producer from streamDestinationsMap and sends data

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(destType string, o Opts) DestinationManager

New returns CustomdestinationManager

type Opts struct {
	Timeout time.Duration
}