controller

Documentation

Index

• type Controller
  • func New(ifacePrefix, nodeName string, syncInterval time.Duration, ...) (*Controller, error)
  • func (c *Controller) Start()
  • func (c *Controller) Stop()
• type TraceServer
  • func NewTraceServer(ring *ring.Ring) (*TraceServer, error)
  • func (o *TraceServer) GetTraces(req *pb.GetTracesRequest, gfs pb.Tracer_GetTracesServer) error
  • func (srv *TraceServer) Serve(ctx context.Context)
  • func (o *TraceServer) ServerStatus(context.Context, *pb.ServerStatusRequest) (*pb.ServerStatusResponse, error)
  • func (srv *TraceServer) Stop()

Types

type Controller

type Controller struct {
	Tracer *tracer.Tracer
	// contains filtered or unexported fields
}

Controller ...

func New

func New(
	ifacePrefix, nodeName string,
	syncInterval time.Duration,
	perfPollInterval time.Duration) (*Controller, error)

New ...

func (*Controller) Start

func (c *Controller) Start()

Start ..

func (*Controller) Stop

func (c *Controller) Stop()

Stop ..

type TraceServer

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

TraceServer ..

func NewTraceServer

func NewTraceServer(ring *ring.Ring) (*TraceServer, error)

NewTraceServer ..

func (*TraceServer) GetTraces

func (o *TraceServer) GetTraces(req *pb.GetTracesRequest, gfs pb.Tracer_GetTracesServer) error

GetTraces ..

func (*TraceServer) Serve

func (srv *TraceServer) Serve(ctx context.Context)

Serve ..

func (*TraceServer) ServerStatus

func (o *TraceServer) ServerStatus(context.Context, *pb.ServerStatusRequest) (*pb.ServerStatusResponse, error)

ServerStatus returns some details

func (*TraceServer) Stop

func (srv *TraceServer) Stop()

Stop ..