background

Documentation

Index

• func ColdPortHandler(args ...interface{})
• func Filter(log string) error
• func Handler(arg *rpc.LogMessage, isHot bool)
• func HotPortHandler(args ...interface{})
• func SendMessage(idx string, data string, isHot bool) error

Functions

func ColdPortHandler

func ColdPortHandler(args ...interface{})

ColdPortHandler is processing unit with ColdRing. Running for goroutine with daemon.

func Filter

func Filter(log string) error

Filter rerturn map[string][]string Read from local filter file. Search log with filterword based filter. Create Map filter is filtering key, data is log.

func Handler

func Handler(arg *rpc.LogMessage, isHot bool)

Handler RPC Port Handler

func HotPortHandler

func HotPortHandler(args ...interface{})

HotPortHandler is processing unit with HotRing. Running for goroutine with daemon.

func SendMessage

func SendMessage(idx string, data string, isHot bool) error

SendMessage send esdocs type data to soy_log_explorer