messages

README

跟TeaWeb主线程交互说明

接收

• Start - 启动插件
• Stop - 停止插件
• Reload - 刷新插件
• ReloadApp - 刷新单个App
• FilterRequest - 过滤HTTP请求
• FilterResponse - 过滤HTTP响应

发送

• Register - 注册插件
• ReloadApps - 刷新插件相关的所有Apps
• ReloadApp - 刷新单个App
• FilterRequest - 过滤HTTP请求结果
• FilterResponse - 过滤HTTP响应结果

Documentation

Index

• Variables
• func NewAction(action string) interface{}
• func RegisterAction(actionPtr ...interface{})
• func Unmarshal(action string, data []byte) (interface{}, error)
• type Action
  • func (this *Action) MessageId() uint32
  • func (this *Action) Name() string
  • func (this *Action) SetMessageId(messageId uint32)
  • func (this *Action) SetTime(t time.Time)
  • func (this *Action) Time() time.Time
• type ActionInterface
• type EmptyAction
  • func (this *EmptyAction) Name() string
• type FilterRequestAction
  • func (this *FilterRequestAction) Name() string
  • func (this *FilterRequestAction) Request() (*http.Request, error)
• type FilterResponseAction
  • func (this *FilterResponseAction) Name() string
  • func (this *FilterResponseAction) Response() (*http.Response, error)
• type LoadAction
  • func (this *LoadAction) Name() string
• type Message
  • func NewActionMessage(action ActionInterface) *Message
  • func NewMessage() *Message
  • func (this *Message) Marshal() ([]byte, error)
• type Queue
  • func NewQueue() *Queue
  • func (this *Queue) Notify(resp ActionInterface)
  • func (this *Queue) Wait(action ActionInterface) (respAction ActionInterface)
• type RegisterPluginAction
  • func (this *RegisterPluginAction) Name() string
• type ReloadAction
  • func (this *ReloadAction) Name() string
• type ReloadAppAction
  • func (this *ReloadAppAction) Name() string
• type ReloadAppsAction
  • func (this *ReloadAppsAction) Name() string
• type StartAction
  • func (this *StartAction) Name() string
• type StopAction
  • func (this *StopAction) Name() string

Variables

var ActionQueue = NewQueue()

Functions

func NewAction

func NewAction(action string) interface{}

func RegisterAction

func RegisterAction(actionPtr ...interface{})

func Unmarshal

func Unmarshal(action string, data []byte) (interface{}, error)

Types

type Action

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

func (*Action) MessageId

func (this *Action) MessageId() uint32

func (*Action) Name

func (this *Action) Name() string

func (*Action) SetMessageId

func (this *Action) SetMessageId(messageId uint32)

func (*Action) SetTime

func (this *Action) SetTime(t time.Time)

func (*Action) Time

func (this *Action) Time() time.Time

type ActionInterface

type ActionInterface interface {
	Name() string
	SetMessageId(messageId uint32)
	MessageId() uint32
	SetTime(t time.Time)
	Time() time.Time
}

type EmptyAction

type EmptyAction struct {
	Action
}

func (*EmptyAction) Name

func (this *EmptyAction) Name() string

type FilterRequestAction

type FilterRequestAction struct {
	Action

	Continue bool
	Data     []byte
}

func (*FilterRequestAction) Name

func (this *FilterRequestAction) Name() string

func (*FilterRequestAction) Request

func (this *FilterRequestAction) Request() (*http.Request, error)

type FilterResponseAction

type FilterResponseAction struct {
	Action

	Continue bool
	Data     []byte
}

func (*FilterResponseAction) Name

func (this *FilterResponseAction) Name() string

func (*FilterResponseAction) Response

func (this *FilterResponseAction) Response() (*http.Response, error)

type LoadAction

type LoadAction struct {
	Action
}

func (*LoadAction) Name

func (this *LoadAction) Name() string

type Message

type Message struct {
	Id     uint32
	Action string
	Value  interface{}
}

func NewActionMessage

func NewActionMessage(action ActionInterface) *Message

func NewMessage

func NewMessage() *Message

func (*Message) Marshal

func (this *Message) Marshal() ([]byte, error)

type Queue

type Queue struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue() *Queue

func (*Queue) Notify

func (this *Queue) Notify(resp ActionInterface)

func (*Queue) Wait

func (this *Queue) Wait(action ActionInterface) (respAction ActionInterface)

type RegisterPluginAction

type RegisterPluginAction struct {
	Action

	Plugin *plugins.Plugin
}

func (*RegisterPluginAction) Name

func (this *RegisterPluginAction) Name() string

type ReloadAction

type ReloadAction struct {
	Action
}

func (*ReloadAction) Name

func (this *ReloadAction) Name() string

type ReloadAppAction

type ReloadAppAction struct {
	Action

	App *apps.App
}

func (*ReloadAppAction) Name

func (this *ReloadAppAction) Name() string

type ReloadAppsAction

type ReloadAppsAction struct {
	Action

	Apps []*apps.App
}

func (*ReloadAppsAction) Name

func (this *ReloadAppsAction) Name() string

type StartAction

type StartAction struct {
	Action
}

func (*StartAction) Name

func (this *StartAction) Name() string

type StopAction

type StopAction struct {
	Action
}

func (*StopAction) Name

func (this *StopAction) Name() string