event

Documentation

Index

• type Event
  • func NewErrorCluster(msg string) (e *Event)
  • func NewErrorNode(msg string) (e *Event)
  • func NewErrorPipeline(name string, msg string) (e *Event)
  • func NewInfoCluster(msg string) (e *Event)
  • func NewInfoNode(msg string) (e *Event)
  • func NewInfoPipeline(name string, msg string) (e *Event)
  • func NewWarnCluster(msg string) (e *Event)
  • func NewWarnNode(msg string) (e *Event)
  • func NewWarnPipeline(name string, msg string) (e *Event)
• type MessageType
• type ResourceType
• type Type

Types

type Event

type Event struct {
	Key          string       `json:"key"`
	Type         Type         `json:"type"`
	ResourceType ResourceType `json:"resource_type"`
	ResourceName string       `json:"resource_name"`
	FirstTime    time.Time    `json:"first_time"`
	LastTime     time.Time    `json:"last_time"`
	Count        int          `json:"count"`
	MessageType  MessageType  `json:"type_message"`
	Message      string       `json:"message"`
	NodeName     string       `json:"node_name"`
	NodeIP       net.IP       `json:"node_ip"`
}

Event generated by pipelines and nodes in the cluster. Events include common information and error information, which can be easily located when an error occurs

func NewErrorCluster

func NewErrorCluster(msg string) (e *Event)

NewErrorCluster returns a new cluster error event

func NewErrorNode

func NewErrorNode(msg string) (e *Event)

NewErrorNode returns a new node error event

func NewErrorPipeline

func NewErrorPipeline(name string, msg string) (e *Event)

NewErrorPipeline returns a new pipeline error event

func NewInfoCluster

func NewInfoCluster(msg string) (e *Event)

NewInfoCluster returns a new cluster info event

func NewInfoNode

func NewInfoNode(msg string) (e *Event)

NewInfoNode returns a new node event of info level

func NewInfoPipeline

func NewInfoPipeline(name string, msg string) (e *Event)

NewInfoPipeline returns a new pipeline info event

func NewWarnCluster

func NewWarnCluster(msg string) (e *Event)

NewWarnCluster returns a new cluster warn event

func NewWarnNode

func NewWarnNode(msg string) (e *Event)

NewWarnNode returns a new node warn event

func NewWarnPipeline

func NewWarnPipeline(name string, msg string) (e *Event)

NewWarnPipeline returns a new pipeline warn event

type MessageType

type MessageType string

MessageType todo

const (
	// MSG_EMPTY default type
	MSG_EMPTY MessageType = ""
)

type ResourceType

type ResourceType string

ResourceType pipeline or node or etc.

const (
	// PIPELINE resource type
	PIPELINE ResourceType = "pipeline"
	// ResourceType resource type
	NODE ResourceType = "node"
	// CLUSTER resource type
	CLUSTER ResourceType = "cluster"
)

type Type

type Type string

Type event level

const (
	// WARN level
	WARN Type = "warn"
	// ERROR level
	ERROR Type = "error"
	// INFO level
	INFO Type = "info"
)