grpc

Documentation

Index

• type Client
  • func MakeClient(host string, port int32) (*Client, error)
• type Config
• type Server
  • func NewServer(agent agent, conf *Config) *Server
  • func (srv *Server) Start(ctx context.Context)
  • func (srv *Server) SubmitTask(ctx context.Context, request *agent_external.SubmitTaskRequest) (*agent_external.SubmitTaskResponse, error)

Types

type Client

type Client struct {
	agent_external.AgentServiceClient
	Close func() error
}

func MakeClient

func MakeClient(host string, port int32) (*Client, error)

type Config

type Config struct {
	ListenAddr string
	Logger     *logrus.Logger
}

type Server

type Server struct {
	agent_external.UnimplementedAgentServiceServer

	ListenAddr string
	// contains filtered or unexported fields
}

func NewServer

func NewServer(agent agent, conf *Config) *Server

func (*Server) Start

func (srv *Server) Start(ctx context.Context)

func (*Server) SubmitTask

func (srv *Server) SubmitTask(ctx context.Context, request *agent_external.SubmitTaskRequest) (*agent_external.SubmitTaskResponse, error)