core

package
v0.68.0 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2023 License: GPL-3.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source 
const MAX_ERROR_LENGTH = 6000 // gRPC seems to impose this limit on the status message
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

func TruncateString added in v0.60.3 

func TruncateString(str string, length int) string

func VarSpecMapToPbVarSpecMap added in v0.22.80 

func VarSpecMapToPbVarSpecMap(varSpecMap map[string]repos.VarSpec) map[string]*pb.VarSpecMessage

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) GetActiveDetectors added in v0.26.3 

func (m *RpcServer) GetActiveDetectors(_ context.Context, _ *pb.Empty) (*pb.GetActiveDetectorsReply, error)

func (*RpcServer) GetEnvironment 

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

func (*RpcServer) GetEnvironments 

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

func (*RpcServer) GetFrameworkInfo 

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

func (*RpcServer) GetIntegratedServices added in v0.22.80 

func (m *RpcServer) GetIntegratedServices(ctx context.Context, empty *pb.Empty) (*pb.ListIntegratedServicesReply, 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) (reply *pb.NewEnvironmentReply, err 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) Subscribe added in v0.14.4 

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
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.
bookkeeping
bookkeeping/protos
ccdb
dcs
dcs/protos
ddsched
ddsched/protos
kafka
kafka/protos
odc
odc/odcutils
odc/protos
testplugin
trg
trg/protos
Deprecated: package metrics is being phased out, don't use it.
 Deprecated: package metrics is being phased out, don't use it.
varsource
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
taskclass
taskclass/port
taskop
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

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.