core

package

v0.22.1 Latest Latest Go to latest Published: Apr 12, 2021 License: GPL-3.0 Imports: 42 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/AliceO2Group/Control

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewConfig() (err error)
func NewServer(state *globalState) *grpc.Server
func Run() error
type EnvironmentInfos
type RpcServer
type SafeStreamsMap
- func (s *SafeStreamsMap) GetChannel(id string) (ch chan *pb.Event, ok bool)

Constants ¶

View Source

const MESOS_AGENT_PORT = 5051

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)

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) NewAutoEnvironment ¶ added in v0.19.80

func (m *RpcServer) NewAutoEnvironment(cxt context.Context, request *pb.NewAutoEnvironmentRequest) (*pb.NewAutoEnvironmentReply, 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

type SafeStreamsMap ¶ added in v0.19.80

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

SafeStreamsMap is a safe map where the key is usually a subscriptionID received from the grpc call and as a value a channel where get events from the environment and we stream them to the grpc client.

func (*SafeStreamsMap) GetChannel ¶ added in v0.19.80

func (s *SafeStreamsMap) GetChannel(id string) (ch chan *pb.Event, ok bool)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
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.
integration
dcs
dcs/protos
ddsched
ddsched/protos
odc
odc/odcutils
odc/protos
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.
callable

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