core

package

v0.12.1 Latest Latest Go to latest Published: Jan 22, 2020 License: GPL-3.0 Imports: 64 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
Variables
func KillTask(ctx context.Context, state *internalState, ...) (err error)
func NewConfig() (err error)
func NewServer(state *internalState, fidStore store.Singleton) *grpc.Server
func Run() error
func SendCommand(ctx context.Context, state *internalState, ...) (err error)
type EnvironmentInfos
type Labels
- func (labels *Labels) Set(value string) error
- func (labels Labels) String() string
type RpcServer
type StateError
- func (err StateError) Error() string
type URL
- func (u *URL) Set(value string) error

Constants ¶

View Source

const AuthModeBasic = "basic"

Variables ¶

View Source

var (
	RegistrationMinBackoff = 1 * time.Second
	RegistrationMaxBackoff = 15 * time.Second
)

Functions ¶

func KillTask ¶ added in v0.9.0

func KillTask(ctx context.Context, state *internalState, receiver controlcommands.MesosCommandTarget) (err error)

func NewConfig ¶

func NewConfig() (err error)

NewConfig is the constructor for a new config.

func NewServer ¶

func NewServer(state *internalState, fidStore store.Singleton) *grpc.Server

func Run ¶

func Run() error

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

func SendCommand ¶

func SendCommand(ctx context.Context, state *internalState, command controlcommands.MesosCommand, receiver controlcommands.MesosCommandTarget) (err error)

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 Labels ¶

type Labels []mesos.Label

func (*Labels) Set ¶

func (labels *Labels) Set(value string) error

func (Labels) String ¶

func (labels Labels) String() string

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.Empty, 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) Teardown ¶

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

func (*RpcServer) TrackStatus ¶

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

type StateError ¶

type StateError string

StateError is returned when the system encounters an unresolvable state transition error and should likely exit.

func (StateError) Error ¶

func (err StateError) Error() string

type URL ¶

type URL struct{ url.URL }

func (*URL) Set ¶

func (u *URL) Set(value string) 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.
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.

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