transporter_manager

package
v0.13.0 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTransporterManager

func RegisterTransporterManager(nameSpace string, rh ResetHandler) error

Types

type INameSpaceManager

type INameSpaceManager interface {
	RegisterTransporterManager(nameSpace string, rh ResetHandler) error
	GetTransporterManager(nameSpace string) ITransporterManager
}

func NewNameSpaceManager

func NewNameSpaceManager() INameSpaceManager

type ITransporterManager

type ITransporterManager interface {
	Set(workerID string, transporter log.EntryTransporter) error
	Del(workerID string) error
}

func GetTransporterManager

func GetTransporterManager(nameSpace string) ITransporterManager

type ResetHandler

type ResetHandler func(transports ...log.EntryTransporter)

Jump to

Keyboard shortcuts

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