processor package - git.espin.ovh/albert/mercurial/components/processor

Documentation ¶

This section is empty.

var (
	MessageCount uint64
)

This section is empty.

type GobConfig struct {
	ProcessName string
}

type Gober struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewGober(config *GobConfig, net *fb.Network, log logger.LoggerAdapter) *Gober

func (g *Gober) In() *fb.InPort

func (g *Gober) Out() *fb.OutPort

func (g *Gober) Run()

type JsonConfig struct {
	ProcessName string
}

type Jsoner struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewJsoner(config *JsonConfig, net *fb.Network, log logger.LoggerAdapter) *Jsoner

func (js *Jsoner) In() *fb.InPort

func (js *Jsoner) Out() *fb.OutPort

func (js *Jsoner) Run()

type MessageSpeed struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewMessageSpeed(config *MessageSpeedConfig, net *fb.Network, log logger.LoggerAdapter) *MessageSpeed

func (ms *MessageSpeed) In() *fb.InPort

func (ms *MessageSpeed) MSOut() *fb.OutPort

func (ms *MessageSpeed) Out() *fb.OutPort

func (ms *MessageSpeed) Run()

type MessageSpeedConfig struct {
	ProcessName string
}

type MsgPackConfig struct {
	ProcessName string
}

type MsgPacker struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewMsgPacker(config *MsgPackConfig, net *fb.Network, log logger.LoggerAdapter) *MsgPacker

func (mp *MsgPacker) In() *fb.InPort

func (mp *MsgPacker) Out() *fb.OutPort

func (mp *MsgPacker) Run()