rpc

Documentation

Index

• func NewGrpcServer(config *GrpcConfig) (*grpc.Server, error)
• type ClusterRefresher
• type GetServerer
• type GrpcConfig
• type TaskDefService
• type TaskService

Functions

func NewGrpcServer

func NewGrpcServer(config *GrpcConfig) (*grpc.Server, error)

Types

type ClusterRefresher

type ClusterRefresher interface {
	RefreshCluster()
}

type GetServerer

type GetServerer interface {
	GetServers() ([]*api.Server, error)
}

type GrpcConfig

type GrpcConfig struct {
	TaskService      TaskService
	TaskDefService   TaskDefService
	GetServerer      GetServerer
	ClusterRefresher ClusterRefresher
}

type TaskDefService

type TaskDefService interface {
	SaveTask(task model.TaskDef) error
}

type TaskService

type TaskService interface {
	Poll(taskName string, batchSize int) (*api.Tasks, error)
	Push(*api.TaskResult) error
}