listeners

Documentation

Index

• Variables
• func CreateListener(typename string) (*types.Listener, error)
• func GetTypeNames() []string
• func Load(listener *types.Listener) error
• func LoadListener(listener *types.Listener, ctx *types.Context) error
• func LoadListeners(ctx types.Context)
• func RegisterType(name string, i interface{})
• func RunDispatch()
• type CacherListener
  • func (listener *CacherListener) InitListener(ctx *types.Context) (err error)
• type ListenerType
• type NATSDataListener
  • func (listener *NATSDataListener) InitListener(ctx *types.Context) (err error)
• type NATSFileListener
  • func (listener *NATSFileListener) InitListener(gctx *types.Context) (err error)
• type UDPDataListener
  • func (listener *UDPDataListener) InitListener(ctx *types.Context) (err error)
• type UDPFileListener
  • func (listener *UDPFileListener) InitListener(gctx *types.Context) (err error)
• type UDPMetaListener
  • func (listener *UDPMetaListener) InitListener(ctx *types.Context) (err error)

Variables

var Listeners []types.Listener

Functions

func CreateListener

func CreateListener(typename string) (*types.Listener, error)

func GetTypeNames

func GetTypeNames() []string

func Load

func Load(listener *types.Listener) error

func LoadListener

func LoadListener(listener *types.Listener, ctx *types.Context) error

func LoadListeners

func LoadListeners(ctx types.Context)

func RegisterType

func RegisterType(name string, i interface{})

func RunDispatch

func RunDispatch()

Types

type CacherListener

type CacherListener struct {
	Port int `json:"port"`
}

func (*CacherListener) InitListener

func (listener *CacherListener) InitListener(ctx *types.Context) (err error)

type ListenerType

type ListenerType struct {
	Name string `json:"name"`
	Type reflect.Type
}

type NATSDataListener

type NATSDataListener struct {
	URL string `json:"url"`
	// contains filtered or unexported fields
}

func (*NATSDataListener) InitListener

func (listener *NATSDataListener) InitListener(ctx *types.Context) (err error)

type NATSFileListener

type NATSFileListener struct {
	URL string `json:"url"`
	// contains filtered or unexported fields
}

func (*NATSFileListener) InitListener

func (listener *NATSFileListener) InitListener(gctx *types.Context) (err error)

type UDPDataListener

type UDPDataListener struct {
	Port int `json:"port"`
}

func (*UDPDataListener) InitListener

func (listener *UDPDataListener) InitListener(ctx *types.Context) (err error)

type UDPFileListener

type UDPFileListener struct {
	Port int `json:"port"`
}

func (*UDPFileListener) InitListener

func (listener *UDPFileListener) InitListener(gctx *types.Context) (err error)

type UDPMetaListener

type UDPMetaListener struct {
	Port int `json:"port"`
}

func (*UDPMetaListener) InitListener

func (listener *UDPMetaListener) InitListener(ctx *types.Context) (err error)