Documentation ¶
Index ¶
- Constants
- func NewConfig() (err error)
- func NewServer(state *globalState) *grpc.Server
- func Run() error
- func TruncateString(str string, length int) string
- func VarSpecMapToPbVarSpecMap(varSpecMap map[string]repos.VarSpec) map[string]*pb.VarSpecMessage
- type EnvironmentInfos
- type RpcServer
- func (m *RpcServer) AddRepo(cxt context.Context, req *pb.AddRepoRequest) (*pb.AddRepoReply, error)
- func (m *RpcServer) CleanupTasks(cxt context.Context, req *pb.CleanupTasksRequest) (*pb.CleanupTasksReply, error)
- func (m *RpcServer) ControlEnvironment(cxt context.Context, req *pb.ControlEnvironmentRequest) (*pb.ControlEnvironmentReply, error)
- func (m *RpcServer) DestroyEnvironment(cxt context.Context, req *pb.DestroyEnvironmentRequest) (*pb.DestroyEnvironmentReply, error)
- func (m *RpcServer) GetActiveDetectors(_ context.Context, _ *pb.Empty) (*pb.GetActiveDetectorsReply, error)
- func (m *RpcServer) GetAvailableDetectors(_ context.Context, _ *pb.Empty) (*pb.GetAvailableDetectorsReply, error)
- func (m *RpcServer) GetEnvironment(cxt context.Context, req *pb.GetEnvironmentRequest) (reply *pb.GetEnvironmentReply, err error)
- func (m *RpcServer) GetEnvironments(cxt context.Context, request *pb.GetEnvironmentsRequest) (*pb.GetEnvironmentsReply, error)
- func (m *RpcServer) GetFrameworkInfo(context.Context, *pb.GetFrameworkInfoRequest) (*pb.GetFrameworkInfoReply, error)
- func (m *RpcServer) GetIntegratedServices(ctx context.Context, empty *pb.Empty) (*pb.ListIntegratedServicesReply, error)
- func (m *RpcServer) GetRoles(cxt context.Context, req *pb.GetRolesRequest) (*pb.GetRolesReply, error)
- func (m *RpcServer) GetTask(cxt context.Context, req *pb.GetTaskRequest) (*pb.GetTaskReply, error)
- func (m *RpcServer) GetTasks(context.Context, *pb.GetTasksRequest) (*pb.GetTasksReply, error)
- func (m *RpcServer) GetWorkflowTemplates(cxt context.Context, req *pb.GetWorkflowTemplatesRequest) (*pb.GetWorkflowTemplatesReply, error)
- func (m *RpcServer) ListRepos(cxt context.Context, req *pb.ListReposRequest) (*pb.ListReposReply, error)
- func (*RpcServer) ModifyEnvironment(context.Context, *pb.ModifyEnvironmentRequest) (*pb.ModifyEnvironmentReply, error)
- func (m *RpcServer) NewAutoEnvironment(cxt context.Context, request *pb.NewAutoEnvironmentRequest) (*pb.NewAutoEnvironmentReply, error)
- func (m *RpcServer) NewEnvironment(cxt context.Context, request *pb.NewEnvironmentRequest) (reply *pb.NewEnvironmentReply, err error)
- func (m *RpcServer) NewEnvironmentAsync(cxt context.Context, request *pb.NewEnvironmentRequest) (reply *pb.NewEnvironmentReply, err error)
- func (m *RpcServer) RefreshRepos(cxt context.Context, req *pb.RefreshReposRequest) (*pb.Empty, error)
- func (m *RpcServer) RemoveRepo(cxt context.Context, req *pb.RemoveRepoRequest) (*pb.RemoveRepoReply, error)
- func (m *RpcServer) SetDefaultRepo(cxt context.Context, req *pb.SetDefaultRepoRequest) (*pb.Empty, error)
- func (m *RpcServer) SetGlobalDefaultRevision(cxt context.Context, req *pb.SetGlobalDefaultRevisionRequest) (*pb.Empty, error)
- 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(context.Context, *pb.TeardownRequest) (*pb.TeardownReply, error)
- type SafeStreamsMap
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 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
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) CleanupTasks ¶
func (*RpcServer) ControlEnvironment ¶
func (*RpcServer) DestroyEnvironment ¶
func (*RpcServer) GetActiveDetectors ¶ added in v0.26.3
func (*RpcServer) GetAvailableDetectors ¶ added in v1.4.0
func (*RpcServer) GetEnvironment ¶
func (*RpcServer) GetEnvironments ¶
func (*RpcServer) GetFrameworkInfo ¶
func (*RpcServer) GetIntegratedServices ¶ added in v0.22.80
func (*RpcServer) GetWorkflowTemplates ¶
func (*RpcServer) ModifyEnvironment ¶
func (*RpcServer) NewAutoEnvironment ¶ added in v0.19.80
func (*RpcServer) NewEnvironment ¶
func (*RpcServer) NewEnvironmentAsync ¶ added in v1.7.0
func (*RpcServer) RefreshRepos ¶ added in v0.10.0
func (*RpcServer) RemoveRepo ¶ added in v0.10.0
func (*RpcServer) SetDefaultRepo ¶ added in v0.10.0
func (*RpcServer) SetGlobalDefaultRevision ¶ added in v0.12.90
func (*RpcServer) SetRepoDefaultRevision ¶ added in v0.12.90
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 ¶
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. |
Click to show internal directories.
Click to hide internal directories.