event

Documentation

Index

• Variables
• type Fields
• type Header
  • func ParseHeader(header string) (*Header, error)
• type Message
  • func (msg *Message) String() string
• type Payload
  • func ParsePayload(payload string) (*Payload, error)

Variables

var (
	ErrParseHeader  = errors.New("解析Header失败")
	ErrParsePayload = errors.New("解析Payload失败")
)

Types

type Fields

type Fields map[string]string

Fields

type Header

type Header struct {
	Ver        string
	Server     string
	Serial     int
	Pool       string
	PoolSerial int
	EventName  string // 事件名称
	Len        int    // Payload长度
}

Header Supervisord触发事件时会先发送Header，根据Header中len字段去读取Payload

func ParseHeader

func ParseHeader(header string) (*Header, error)

type Message

type Message struct {
	Header  *Header
	Payload *Payload
}

Message 消息格式

func (*Message) String

func (msg *Message) String() string

type Payload

type Payload struct {
	Ip          string
	ProcessName string // 进程名称
	GroupName   string // 进程组名称
	FromState   string
	Expected    int
	Pid         int
}

Payload

func ParsePayload

func ParsePayload(payload string) (*Payload, error)