core

Documentation

Index

• Constants
• Variables
• func NewServer(state *internalState, fidStore store.Singleton) *grpc.Server
• func Run(cfg Config) error
• type Config
  • func NewConfig() Config
  • func (cfg *Config) AddFlags(fs *flag.FlagSet)
• type Labels
  • func (labels *Labels) Set(value string) error
  • func (labels Labels) String() string
• type RpcServer
  • func (*RpcServer) ControlEnvironment(context.Context, *pb.ControlEnvironmentRequest) (*pb.ControlEnvironmentReply, error)
  • func (*RpcServer) DestroyEnvironment(context.Context, *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(context.Context, *pb.GetRolesRequest) (*pb.GetRolesReply, 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.Octl_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 NewServer

func NewServer(state *internalState, fidStore store.Singleton) *grpc.Server

func Run

func Run(cfg Config) error

Run is the entry point for this scheduler. TODO: refactor Config to reflect our specific requirements

Types

type Config

type Config struct {
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig() Config

NewConfig is the constructor for a new config.

func (*Config) AddFlags

func (cfg *Config) AddFlags(fs *flag.FlagSet)

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.OctlServer

func (*RpcServer) ControlEnvironment

func (*RpcServer) ControlEnvironment(context.Context, *pb.ControlEnvironmentRequest) (*pb.ControlEnvironmentReply, error)

func (*RpcServer) DestroyEnvironment

func (*RpcServer) DestroyEnvironment(context.Context, *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(context.Context, *pb.GetRolesRequest) (*pb.GetRolesReply, 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.Octl_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