plugin

Documentation

Index

• type ConsoleOutput
  • func (c *ConsoleOutput) Send(msg *msg.Message)
  • func (c *ConsoleOutput) Start()
  • func (c *ConsoleOutput) Status() Status
  • func (c *ConsoleOutput) Stop()
• type Filter
• type HelloInput
  • func (h *HelloInput) Receive() *msg.Message
  • func (h *HelloInput) Start()
  • func (h *HelloInput) Status() Status
  • func (h *HelloInput) Stop()
• type Input
• type Output
• type Plugin
• type Status
• type UpperFilter
  • func (u *UpperFilter) Process(msg *msg.Message) *msg.Message
  • func (u *UpperFilter) Start()
  • func (u *UpperFilter) Status() Status
  • func (u *UpperFilter) Stop()

Types

type ConsoleOutput

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

func (*ConsoleOutput) Send

func (c *ConsoleOutput) Send(msg *msg.Message)

func (*ConsoleOutput) Start

func (c *ConsoleOutput) Start()

func (*ConsoleOutput) Status

func (c *ConsoleOutput) Status() Status

func (*ConsoleOutput) Stop

func (c *ConsoleOutput) Stop()

type Filter

type Filter interface {
	Plugin
	Process(msg *msg.Message) *msg.Message
}

type HelloInput

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

func (*HelloInput) Receive

func (h *HelloInput) Receive() *msg.Message

func (*HelloInput) Start

func (h *HelloInput) Start()

func (*HelloInput) Status

func (h *HelloInput) Status() Status

func (*HelloInput) Stop

func (h *HelloInput) Stop()

type Input

type Input interface {
	Plugin
	Receive() *msg.Message
}

Input、Filter、Output三类插件接口的定义跟上一篇文章类似 这里使用Message结构体替代了原来的string，使得语义更清晰

type Output

type Output interface {
	Plugin
	Send(msg *msg.Message)
}

type Plugin

type Plugin interface {
	// 启动插件
	Start()
	// 停止插件
	Stop()
	// 返回插件当前的运行状态
	Status() Status
}

type Status

type Status uint8

插件运行状态

const (
	Stopped Status = iota
	Started
)

type UpperFilter

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

func (*UpperFilter) Process

func (u *UpperFilter) Process(msg *msg.Message) *msg.Message

func (*UpperFilter) Start

func (u *UpperFilter) Start()

func (*UpperFilter) Status

func (u *UpperFilter) Status() Status

func (*UpperFilter) Stop

func (u *UpperFilter) Stop()