core

Documentation

Index

• Constants
• Variables
• 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
  • func (infos EnvironmentInfos) Len() int
  • func (infos EnvironmentInfos) Less(i, j int) bool
  • func (infos EnvironmentInfos) Swap(i, j int)
• type Labels
  • func (labels *Labels) Set(value string) error
  • func (labels Labels) String() string
• type RpcServer
  • 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) GetEnvironment(cxt context.Context, req *pb.GetEnvironmentRequest) (*pb.GetEnvironmentReply, error)
  • func (m *RpcServer) GetEnvironments(context.Context, *pb.GetEnvironmentsRequest) (*pb.GetEnvironmentsReply, error)
  • func (m *RpcServer) GetFrameworkInfo(context.Context, *pb.GetFrameworkInfoRequest) (*pb.GetFrameworkInfoReply, 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 (*RpcServer) ModifyEnvironment(context.Context, *pb.ModifyEnvironmentRequest) (*pb.ModifyEnvironmentReply, error)
  • func (m *RpcServer) NewEnvironment(cxt context.Context, request *pb.NewEnvironmentRequest) (*pb.NewEnvironmentReply, error)
  • func (*RpcServer) Teardown(context.Context, *pb.TeardownRequest) (*pb.TeardownReply, error)
  • func (*RpcServer) TrackStatus(*pb.StatusRequest, pb.Control_TrackStatusServer) error
• type StateError
  • func (err StateError) Error() string
• type URL
  • func (u *URL) Set(value string) error

Constants

const AuthModeBasic = "basic"

Variables

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

Functions

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) 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) 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) 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