core

package
v0.12.90 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 13, 2020 License: GPL-3.0 Imports: 66 Imported by: 0

Documentation

Index

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.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 (*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

Directories

Path Synopsis
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.
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.
Deprecated: package metrics is being phased out, don't use it.
Deprecated: package metrics is being phased out, don't use it.
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.
constraint
Package constraint implements support for predicates on agent attributes.
Package constraint implements support for predicates on agent attributes.
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.

Jump to

Keyboard shortcuts

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