core

package

v0.17.82 Latest Latest Go to latest Published: Nov 13, 2020 License: GPL-3.0 Imports: 38 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AliceO2Group/Control

Links

Open Source Insights

Documentation ¶

Index ¶

func NewConfig() (err error)
func NewServer(state *globalState) *grpc.Server
func Run() error
type EnvironmentInfos
type RpcServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewConfig ¶

func NewConfig() (err error)

NewConfig is the constructor for a new config.

func NewServer ¶

func NewServer(state *globalState) *grpc.Server

func Run ¶

func Run() error

Run is the entry point for this scheduler. TODO: refactor Config to reflect our specific requirements

Types ¶

type EnvironmentInfos ¶

type EnvironmentInfos []*pb.EnvironmentInfo

func (EnvironmentInfos) Len ¶

func (infos EnvironmentInfos) Len() int

func (EnvironmentInfos) Less ¶

func (infos EnvironmentInfos) Less(i, j int) bool

func (EnvironmentInfos) Swap ¶

func (infos EnvironmentInfos) Swap(i, j int)

type RpcServer ¶

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

Implements interface pb.ControlServer

func (*RpcServer) AddRepo ¶ added in v0.10.0

func (m *RpcServer) AddRepo(cxt context.Context, req *pb.AddRepoRequest) (*pb.AddRepoReply, error)

func (*RpcServer) CleanupTasks ¶

func (m *RpcServer) CleanupTasks(cxt context.Context, req *pb.CleanupTasksRequest) (*pb.CleanupTasksReply, error)

func (*RpcServer) ControlEnvironment ¶

func (m *RpcServer) ControlEnvironment(cxt context.Context, req *pb.ControlEnvironmentRequest) (*pb.ControlEnvironmentReply, error)

func (*RpcServer) DestroyEnvironment ¶

func (m *RpcServer) DestroyEnvironment(cxt context.Context, req *pb.DestroyEnvironmentRequest) (*pb.DestroyEnvironmentReply, error)

func (*RpcServer) GetEnvironment ¶

func (m *RpcServer) GetEnvironment(cxt context.Context, req *pb.GetEnvironmentRequest) (*pb.GetEnvironmentReply, error)

func (*RpcServer) GetEnvironments ¶

func (m *RpcServer) GetEnvironments(context.Context, *pb.GetEnvironmentsRequest) (*pb.GetEnvironmentsReply, error)

func (*RpcServer) GetFrameworkInfo ¶

func (m *RpcServer) GetFrameworkInfo(context.Context, *pb.GetFrameworkInfoRequest) (*pb.GetFrameworkInfoReply, error)

func (*RpcServer) GetRoles ¶

func (m *RpcServer) GetRoles(cxt context.Context, req *pb.GetRolesRequest) (*pb.GetRolesReply, error)

func (*RpcServer) GetTask ¶

func (m *RpcServer) GetTask(cxt context.Context, req *pb.GetTaskRequest) (*pb.GetTaskReply, error)

func (*RpcServer) GetTasks ¶

func (m *RpcServer) GetTasks(context.Context, *pb.GetTasksRequest) (*pb.GetTasksReply, error)

func (*RpcServer) GetWorkflowTemplates ¶

func (m *RpcServer) GetWorkflowTemplates(cxt context.Context, req *pb.GetWorkflowTemplatesRequest) (*pb.GetWorkflowTemplatesReply, error)

func (*RpcServer) ListRepos ¶ added in v0.10.0

func (m *RpcServer) ListRepos(cxt context.Context, req *pb.ListReposRequest) (*pb.ListReposReply, error)

func (*RpcServer) ModifyEnvironment ¶

func (*RpcServer) ModifyEnvironment(context.Context, *pb.ModifyEnvironmentRequest) (*pb.ModifyEnvironmentReply, error)

func (*RpcServer) NewEnvironment ¶

func (m *RpcServer) NewEnvironment(cxt context.Context, request *pb.NewEnvironmentRequest) (*pb.NewEnvironmentReply, error)

func (*RpcServer) RefreshRepos ¶ added in v0.10.0

func (m *RpcServer) RefreshRepos(cxt context.Context, req *pb.RefreshReposRequest) (*pb.Empty, error)

func (*RpcServer) RemoveRepo ¶ added in v0.10.0

func (m *RpcServer) RemoveRepo(cxt context.Context, req *pb.RemoveRepoRequest) (*pb.RemoveRepoReply, error)

func (*RpcServer) SetDefaultRepo ¶ added in v0.10.0

func (m *RpcServer) SetDefaultRepo(cxt context.Context, req *pb.SetDefaultRepoRequest) (*pb.Empty, error)

func (*RpcServer) SetGlobalDefaultRevision ¶ added in v0.12.90

func (m *RpcServer) SetGlobalDefaultRevision(cxt context.Context, req *pb.SetGlobalDefaultRevisionRequest) (*pb.Empty, error)

func (*RpcServer) SetRepoDefaultRevision ¶ added in v0.12.90

func (m *RpcServer) SetRepoDefaultRevision(cxt context.Context, req *pb.SetRepoDefaultRevisionRequest) (*pb.SetRepoDefaultRevisionReply, error)

func (m *RpcServer) Subscribe(req *pb.SubscribeRequest, srv pb.Control_SubscribeServer) error

func (*RpcServer) Teardown ¶

func (*RpcServer) Teardown(context.Context, *pb.TeardownRequest) (*pb.TeardownReply, error)

func (*RpcServer) TrackStatus ¶

func (*RpcServer) TrackStatus(*pb.StatusRequest, pb.Control_TrackStatusServer) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
confsys
controlcommands Package controlcommands defines the Command interface, plus several types including MesosCommand, MesosCommandResponse and related.	Package controlcommands defines the Command interface, plus several types including MesosCommand, MesosCommandResponse and related.
environment Package environment defines Environment, environment.Manager and other types and methods related to handling O² environments.	Package environment defines Environment, environment.Manager and other types and methods related to handling O² environments.
metrics Deprecated: package metrics is being phased out, don't use it.	Deprecated: package metrics is being phased out, don't use it.
protos
repos
task Package task defines the Task type and its Manager, with the purpose of handling the lifetime of O² Task objects.	Package task defines the Task type and its Manager, with the purpose of handling the lifetime of O² Task objects.
channel
constraint Package constraint implements support for predicates on agent attributes.	Package constraint implements support for predicates on agent attributes.
schedutil
taskop
the
workflow Package workflow defines the Role interface, along with tooling to build the control tree.	Package workflow defines the Role interface, along with tooling to build the control tree.
template

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL