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

Source Files

View all Source files

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.
channel
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.
template

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.