rpc

Documentation

Index

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

Functions

func NewGrpcServer

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

Types

type ActionDefinitionService

type ActionDefinitionService interface {
	SaveActionDefinition(action model.ActionDefinition) error
}

type ActionService

type ActionService interface {
	Poll(action string, batchSize int) (*api.Actions, error)
	Push(*api.ActionResult) error
}

type ClusterRefresher

type ClusterRefresher interface {
	RefreshCluster()
}

type GetServerer

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

type GrpcConfig

type GrpcConfig struct {
	ActionService           ActionService
	ActionDefinitionService ActionDefinitionService
	GetServerer             GetServerer
}