server

package

v0.0.1 Latest Latest Go to latest Published: Mar 4, 2018 License: MIT Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

func Node(cfg config.ServerConfig) (*pbc.Node, error)

TODO: this is dup in both agent and central

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

func NewGrpcServer(meta meta.Provider, cfg config.ServerConfig) (*GrpcServer, error)

func (srv *GrpcServer) AgentHeartbeat(ctx context.Context, req *pb.AgentHeartbeatReq) (*pb.AgentHeartbeatRes, error)

func (srv *GrpcServer) GetLogger() *dlog.Logger

func (srv *GrpcServer) ListAgent(ctx context.Context, req *pb.ListAgentReq) (*pb.ListAgentRes, error)

func (srv *GrpcServer) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (srv *GrpcServer) NodeInfo(ctx context.Context, _ *pbc.NodeInfoReq) (*pbc.NodeInfoRes, error)

func (srv *GrpcServer) Ping(ctx context.Context, ping *pbc.Ping) (*pbc.Pong, error)

func (srv *GrpcServer) RegisterAgent(ctx context.Context, req *pb.RegisterAgentReq) (*pb.RegisterAgentRes, error)

func (srv *GrpcServer) SetLogger(logger *dlog.Logger)

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

func NewHttpServer(meta meta.Provider, cfg config.ServerConfig) (*HttpServer, error)

func (srv *HttpServer) GetLogger() *dlog.Logger

func (srv *HttpServer) Handler() http.Handler

func (srv *HttpServer) ListAgent(ctx context.Context) (*pb.ListAgentRes, error)

func (srv *HttpServer) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (srv *HttpServer) NodeInfo(ctx context.Context) (*pbc.NodeInfoRes, error)

func (srv *HttpServer) Ping(ctx context.Context, ping *pbc.Ping) (*pbc.Pong, error)

func (srv *HttpServer) RegisterHandler(mux *ihttp.JsonHandlerMux)

func (srv *HttpServer) SetLogger(logger *dlog.Logger)

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

func NewManager(cfg config.ServerConfig) (*Manager, error)

func (mgr *Manager) GetLogger() *dlog.Logger

func (mgr *Manager) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (mgr *Manager) Run() error

func (mgr *Manager) SetLogger(logger *dlog.Logger)