pkg

Documentation

Index

• Variables
• func GetActiveLogs(pn string) string
• func SetPort(sport string)
• func StartServer()
• func SubscribeListeners()
• type StreamClient
  • func New(servicePort string, masterIp string) *StreamClient
  • func (c *StreamClient) StartClient(probename []string, pidList [][]string)
• type StreamServer
  • func (s *StreamServer) RouteLog(stream pb.SentLog_RouteLogServer) error

Variables

var (
	Probe_Num int64
)

Functions

func GetActiveLogs

func GetActiveLogs(pn string) string

func SetPort

func SetPort(sport string)

func StartServer

func StartServer()

func SubscribeListeners

func SubscribeListeners()

Types

type StreamClient

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

func New

func New(servicePort string, masterIp string) *StreamClient

func (*StreamClient) StartClient

func (c *StreamClient) StartClient(probename []string, pidList [][]string)

type StreamServer

type StreamServer struct {
}

func (*StreamServer) RouteLog

func (s *StreamServer) RouteLog(stream pb.SentLog_RouteLogServer) error