transporter_manager

Documentation

Index

• func RegisterTransporterManager(nameSpace string, rh ResetHandler) error
• type INameSpaceManager
  • func NewNameSpaceManager() INameSpaceManager
• type ITransporterManager
  • func GetTransporterManager(nameSpace string) ITransporterManager
• type ResetHandler

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)