app

Documentation

Index

• type Server
  • func NewServer(srvManager *srv.ServiceManager) (*Server, error)
  • func (s *Server) Config(ctx context.Context, request *pb.ConfigRequest) (*pb.ConfigResponse, error)
  • func (s *Server) Heartbeat(ctx context.Context, request *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)
  • func (s *Server) Register(ctx context.Context, request *pb.RegisterRequest) (*pb.RegisterResponse, error)
  • func (s *Server) Submit(ctx context.Context, request *pb.SubmitRequest) (*pb.SubmitResponse, error)
  • func (s *Server) Unregister(ctx context.Context, request *pb.UnregisterRequest) (*pb.UnregisterResult, error)
  • func (s *Server) Users(ctx context.Context, request *pb.UsersRequest) (*pb.UsersResponse, error)

Types

type Server

type Server struct {
	pb.UnimplementedAgentServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(srvManager *srv.ServiceManager) (*Server, error)

func (*Server) Config

func (s *Server) Config(ctx context.Context, request *pb.ConfigRequest) (*pb.ConfigResponse, error)

func (*Server) Heartbeat

func (s *Server) Heartbeat(ctx context.Context, request *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)

func (*Server) Register

func (s *Server) Register(ctx context.Context, request *pb.RegisterRequest) (*pb.RegisterResponse, error)

func (*Server) Submit

func (s *Server) Submit(ctx context.Context, request *pb.SubmitRequest) (*pb.SubmitResponse, error)

func (*Server) Unregister

func (s *Server) Unregister(ctx context.Context, request *pb.UnregisterRequest) (*pb.UnregisterResult, error)

func (*Server) Users

func (s *Server) Users(ctx context.Context, request *pb.UsersRequest) (*pb.UsersResponse, error)