model

package
v0.0.0-...-88bc37c Latest Latest
Warning

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

Go to latest
Published: Oct 9, 2018 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Package model is a generated protocol buffer package.

It is generated from these files:

model.proto
cluster.proto

It has these top-level messages:

Instance
ConnectionStatus
InstanceState
FailureMessage
Template
NoneTemplate
LxcTemplate
QemuTemplate
EsxiTemplate
NullTemplate
Console
ExecutorNode
SchedulerNode
AgentNode
CrashedNode
NodeState

Index

Examples

Constants

This section is empty.

Variables

View Source
var ConnectionStatus_Status_name = map[int32]string{
	0: "NONE",
	1: "CONNECTED",
	2: "NOT_CONNECTED",
}
View Source
var ConnectionStatus_Status_value = map[string]int32{
	"NONE":          0,
	"CONNECTED":     1,
	"NOT_CONNECTED": 2,
}
View Source
var Console_Transport_name = map[int32]string{
	0: "SSH",
}
View Source
var Console_Transport_value = map[string]int32{
	"SSH": 0,
}
View Source
var ErrBackendNotInContext = errors.New("Given context does not have the backend object")
View Source
var ErrInvalidID = errors.New("ID is missing")
View Source
var FailureMessage_ErrorType_name = map[int32]string{
	0: "FAILED_BOOT",
	1: "FAILED_START",
	2: "FAILED_STOP",
	3: "FAILED_REBOOT",
	4: "FAILED_TERMINATE",
}
View Source
var FailureMessage_ErrorType_value = map[string]int32{
	"FAILED_BOOT":      0,
	"FAILED_START":     1,
	"FAILED_STOP":      2,
	"FAILED_REBOOT":    3,
	"FAILED_TERMINATE": 4,
}
View Source
var InstanceState_State_name = map[int32]string{
	0: "REGISTERED",
	1: "QUEUED",
	2: "STARTING",
	3: "RUNNING",
	4: "STOPPING",
	5: "STOPPED",
	6: "REBOOTING",
	7: "SHUTTINGDOWN",
	8: "TERMINATED",
	9: "FAILED",
}
View Source
var InstanceState_State_value = map[string]int32{
	"REGISTERED":   0,
	"QUEUED":       1,
	"STARTING":     2,
	"RUNNING":      3,
	"STOPPING":     4,
	"STOPPED":      5,
	"REBOOTING":    6,
	"SHUTTINGDOWN": 7,
	"TERMINATED":   8,
	"FAILED":       9,
}
View Source
var NodeState_State_name = map[int32]string{
	0: "REGISTERED",
}
View Source
var NodeState_State_value = map[string]int32{
	"REGISTERED": 0,
}
View Source
var NullTemplate_CrashStage_name = map[int32]string{
	0: "NONE",
	1: "START",
	2: "STOP",
	3: "CREATE",
	4: "DESTROY",
	5: "REBOOT",
}
View Source
var NullTemplate_CrashStage_value = map[string]int32{
	"NONE":    0,
	"START":   1,
	"STOP":    2,
	"CREATE":  3,
	"DESTROY": 4,
	"REBOOT":  5,
}
View Source
var QemuTemplate_Image_Format_name = map[int32]string{
	0: "RAW",
	1: "QCOW2",
}
View Source
var QemuTemplate_Image_Format_value = map[string]int32{
	"RAW":   0,
	"QCOW2": 1,
}

Functions

func Close

func Close(ctx context.Context) error

func ClusterClose

func ClusterClose(ctx context.Context) error

func ClusterConnect

func ClusterConnect(ctx context.Context, dest backend.ConnectionAddress) (context.Context, error)

func GetBackendCtx

func GetBackendCtx(ctx context.Context) backend.ModelBackend

func GetClusterBackendCtx

func GetClusterBackendCtx(ctx context.Context) backend.ClusterBackend

func GrpcInterceptor

func GrpcInterceptor(modelAddr backend.ConnectionAddress, clusterCtx context.Context) grpc.UnaryServerInterceptor

func GrpcStreamInterceptor

func GrpcStreamInterceptor(modelAddr backend.ConnectionAddress, clusterCtx context.Context) grpc.StreamServerInterceptor

func InstallSchemas

func InstallSchemas(bk backend.ModelSchema) error

func IsMatchingNodeGroups

func IsMatchingNodeGroups(res InstanceResource, offered []string) bool

func WithMockClusterBackendCtx

func WithMockClusterBackendCtx(ctx context.Context) context.Context

Types

type AgentNode

type AgentNode struct {
	AgentMesosId string                     `protobuf:"bytes,1,opt,name=agent_mesos_id,json=agentMesosId" json:"agent_mesos_id,omitempty"`
	AgentId      string                     `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	CreatedAt    *google_protobuf.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
}

func (*AgentNode) Descriptor

func (*AgentNode) Descriptor() ([]byte, []int)

func (*AgentNode) GetAgentId

func (m *AgentNode) GetAgentId() string

func (*AgentNode) GetAgentMesosId

func (m *AgentNode) GetAgentMesosId() string

func (*AgentNode) GetCreatedAt

func (m *AgentNode) GetCreatedAt() *google_protobuf.Timestamp

func (*AgentNode) ProtoMessage

func (*AgentNode) ProtoMessage()

func (*AgentNode) Reset

func (m *AgentNode) Reset()

func (*AgentNode) String

func (m *AgentNode) String() string

type ClusterNode

type ClusterNode interface {
	proto.Message

	GetId() string
	// contains filtered or unexported methods
}

ClusterNode is a marker interface. Protobuf object implements this is allowed to store in /cluster key space.

type ClusterOps

type ClusterOps interface {
	Register(node ClusterNode) error
	Find(nodeID string, node ClusterNode) error
	Unregister(nodeID string) error
}

func Cluster

func Cluster(ctx context.Context) ClusterOps

type ConnectionStatus

type ConnectionStatus struct {
	Status ConnectionStatus_Status `protobuf:"varint,1,opt,name=status,enum=model.ConnectionStatus_Status" json:"status,omitempty"`
}

func (*ConnectionStatus) Descriptor

func (*ConnectionStatus) Descriptor() ([]byte, []int)

func (*ConnectionStatus) GetStatus

func (*ConnectionStatus) ProtoMessage

func (*ConnectionStatus) ProtoMessage()

func (*ConnectionStatus) Reset

func (m *ConnectionStatus) Reset()

func (*ConnectionStatus) String

func (m *ConnectionStatus) String() string

type ConnectionStatus_Status

type ConnectionStatus_Status int32
const (
	ConnectionStatus_NONE          ConnectionStatus_Status = 0
	ConnectionStatus_CONNECTED     ConnectionStatus_Status = 1
	ConnectionStatus_NOT_CONNECTED ConnectionStatus_Status = 2
)

func (ConnectionStatus_Status) EnumDescriptor

func (ConnectionStatus_Status) EnumDescriptor() ([]byte, []int)

func (ConnectionStatus_Status) String

func (x ConnectionStatus_Status) String() string

type Console

type Console struct {
	Type     Console_Transport `protobuf:"varint,1,opt,name=type,enum=model.Console_Transport" json:"type,omitempty"`
	BindAddr string            `protobuf:"bytes,2,opt,name=bind_addr" json:"bind_addr,omitempty"`
}

func (*Console) Descriptor

func (*Console) Descriptor() ([]byte, []int)

func (*Console) GetBindAddr

func (m *Console) GetBindAddr() string

func (*Console) GetType

func (m *Console) GetType() Console_Transport

func (*Console) ProtoMessage

func (*Console) ProtoMessage()

func (*Console) Reset

func (m *Console) Reset()

func (*Console) String

func (m *Console) String() string

type Console_Transport

type Console_Transport int32
const (
	Console_SSH Console_Transport = 0
)

func (Console_Transport) EnumDescriptor

func (Console_Transport) EnumDescriptor() ([]byte, []int)

func (Console_Transport) String

func (x Console_Transport) String() string

type CrashedAgentNode

type CrashedAgentNode interface {
	proto.Message
	GetReconnected() bool
	GetAgentId() string
	GetUuid() string
}

type CrashedNode

type CrashedNode struct {
	Uuid          string                     `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"`
	AgentId       string                     `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	AgentMesosId  string                     `protobuf:"bytes,3,opt,name=agent_mesos_id,json=agentMesosId" json:"agent_mesos_id,omitempty"`
	Reconnected   bool                       `protobuf:"varint,4,opt,name=reconnected" json:"reconnected,omitempty"`
	CreatedAt     *google_protobuf.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	ReconnectedAt *google_protobuf.Timestamp `protobuf:"bytes,6,opt,name=reconnected_at,json=reconnectedAt" json:"reconnected_at,omitempty"`
}

func (*CrashedNode) Descriptor

func (*CrashedNode) Descriptor() ([]byte, []int)

func (*CrashedNode) GetAgentId

func (m *CrashedNode) GetAgentId() string

func (*CrashedNode) GetAgentMesosId

func (m *CrashedNode) GetAgentMesosId() string

func (*CrashedNode) GetCreatedAt

func (m *CrashedNode) GetCreatedAt() *google_protobuf.Timestamp

func (*CrashedNode) GetReconnected

func (m *CrashedNode) GetReconnected() bool

func (*CrashedNode) GetReconnectedAt

func (m *CrashedNode) GetReconnectedAt() *google_protobuf.Timestamp

func (*CrashedNode) GetUuid

func (m *CrashedNode) GetUuid() string

func (*CrashedNode) ProtoMessage

func (*CrashedNode) ProtoMessage()

func (*CrashedNode) Reset

func (m *CrashedNode) Reset()

func (*CrashedNode) String

func (m *CrashedNode) String() string

type CrashedNodesOps

type CrashedNodesOps interface {
	Add(node *CrashedNode) error
	FindByAgentMesosIDNotReconnected(agentMesosID string) (*CrashedNode, error)
	FindByAgentMesosID(agentMesosID string) (*CrashedNode, error)
	FindByAgentID(agentID string) (*CrashedNode, error)
	FindByUUID(nodeUUID string) (*CrashedNode, error)
	Filter(limit int, cb func(*CrashedNode) int) error
	SetReconnected(node *CrashedNode) error
}

func CrashedNodes

func CrashedNodes(ctx context.Context) CrashedNodesOps

type EsxiTemplate

type EsxiTemplate struct {
	Vcpu        int32                     `protobuf:"varint,1,opt,name=vcpu" json:"vcpu,omitempty"`
	MemoryGb    int32                     `protobuf:"varint,2,opt,name=memory_gb" json:"memory_gb,omitempty"`
	MinVcpu     int32                     `protobuf:"varint,3,opt,name=min_vcpu" json:"min_vcpu,omitempty"`
	MinMemoryGb int32                     `protobuf:"varint,4,opt,name=min_memory_gb" json:"min_memory_gb,omitempty"`
	EsxiImage   *EsxiTemplate_Image       `protobuf:"bytes,5,opt,name=esxi_image" json:"esxi_image,omitempty"`
	Interfaces  []*EsxiTemplate_Interface `protobuf:"bytes,6,rep,name=interfaces" json:"interfaces,omitempty"`
	NodeGroups  []string                  `protobuf:"bytes,7,rep,name=node_groups" json:"node_groups,omitempty"`
}

func (*EsxiTemplate) Descriptor

func (*EsxiTemplate) Descriptor() ([]byte, []int)

func (*EsxiTemplate) GetEsxiImage

func (m *EsxiTemplate) GetEsxiImage() *EsxiTemplate_Image

func (*EsxiTemplate) GetInterfaces

func (m *EsxiTemplate) GetInterfaces() []*EsxiTemplate_Interface

func (*EsxiTemplate) GetMemoryGb

func (m *EsxiTemplate) GetMemoryGb() int32

func (*EsxiTemplate) GetMinMemoryGb

func (m *EsxiTemplate) GetMinMemoryGb() int32

func (*EsxiTemplate) GetMinVcpu

func (m *EsxiTemplate) GetMinVcpu() int32

func (*EsxiTemplate) GetNodeGroups

func (m *EsxiTemplate) GetNodeGroups() []string

func (*EsxiTemplate) GetVcpu

func (m *EsxiTemplate) GetVcpu() int32

func (*EsxiTemplate) ProtoMessage

func (*EsxiTemplate) ProtoMessage()

func (*EsxiTemplate) Reset

func (m *EsxiTemplate) Reset()

func (*EsxiTemplate) ResourceName

func (*EsxiTemplate) ResourceName() string

func (*EsxiTemplate) String

func (m *EsxiTemplate) String() string

type EsxiTemplate_Image

type EsxiTemplate_Image struct {
	Name       string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Datastore  string `protobuf:"bytes,2,opt,name=datastore" json:"datastore,omitempty"`
	ChksumType string `protobuf:"bytes,3,opt,name=chksum_type" json:"chksum_type,omitempty"`
	Chksum     string `protobuf:"bytes,4,opt,name=chksum" json:"chksum,omitempty"`
}

func (*EsxiTemplate_Image) Descriptor

func (*EsxiTemplate_Image) Descriptor() ([]byte, []int)

func (*EsxiTemplate_Image) GetChksum

func (m *EsxiTemplate_Image) GetChksum() string

func (*EsxiTemplate_Image) GetChksumType

func (m *EsxiTemplate_Image) GetChksumType() string

func (*EsxiTemplate_Image) GetDatastore

func (m *EsxiTemplate_Image) GetDatastore() string

func (*EsxiTemplate_Image) GetName

func (m *EsxiTemplate_Image) GetName() string

func (*EsxiTemplate_Image) ProtoMessage

func (*EsxiTemplate_Image) ProtoMessage()

func (*EsxiTemplate_Image) Reset

func (m *EsxiTemplate_Image) Reset()

func (*EsxiTemplate_Image) String

func (m *EsxiTemplate_Image) String() string

type EsxiTemplate_Interface

type EsxiTemplate_Interface struct {
	NetworkId   string `protobuf:"bytes,1,opt,name=network_id,json=networkId" json:"network_id,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	Macaddr     string `protobuf:"bytes,3,opt,name=macaddr" json:"macaddr,omitempty"`
	Ipv4Addr    string `protobuf:"bytes,4,opt,name=ipv4addr" json:"ipv4addr,omitempty"`
	Ipv4Gateway string `protobuf:"bytes,5,opt,name=ipv4gateway" json:"ipv4gateway,omitempty"`
}

func (*EsxiTemplate_Interface) Descriptor

func (*EsxiTemplate_Interface) Descriptor() ([]byte, []int)

func (*EsxiTemplate_Interface) GetIpv4Addr

func (m *EsxiTemplate_Interface) GetIpv4Addr() string

func (*EsxiTemplate_Interface) GetIpv4Gateway

func (m *EsxiTemplate_Interface) GetIpv4Gateway() string

func (*EsxiTemplate_Interface) GetMacaddr

func (m *EsxiTemplate_Interface) GetMacaddr() string

func (*EsxiTemplate_Interface) GetNetworkId

func (m *EsxiTemplate_Interface) GetNetworkId() string

func (*EsxiTemplate_Interface) GetType

func (m *EsxiTemplate_Interface) GetType() string

func (*EsxiTemplate_Interface) ProtoMessage

func (*EsxiTemplate_Interface) ProtoMessage()

func (*EsxiTemplate_Interface) Reset

func (m *EsxiTemplate_Interface) Reset()

func (*EsxiTemplate_Interface) String

func (m *EsxiTemplate_Interface) String() string

type ExecutorNode

type ExecutorNode struct {
	Id        string                     `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=created_at" json:"created_at,omitempty"`
	Console   *Console                   `protobuf:"bytes,3,opt,name=console" json:"console,omitempty"`
	GrpcAddr  string                     `protobuf:"bytes,4,opt,name=grpc_addr" json:"grpc_addr,omitempty"`
	LastState *NodeState                 `protobuf:"bytes,5,opt,name=last_state" json:"last_state,omitempty"`
}

func (*ExecutorNode) Descriptor

func (*ExecutorNode) Descriptor() ([]byte, []int)

func (*ExecutorNode) GetConsole

func (m *ExecutorNode) GetConsole() *Console

func (*ExecutorNode) GetCreatedAt

func (m *ExecutorNode) GetCreatedAt() *google_protobuf.Timestamp

func (*ExecutorNode) GetGrpcAddr

func (m *ExecutorNode) GetGrpcAddr() string

func (*ExecutorNode) GetId

func (m *ExecutorNode) GetId() string

func (*ExecutorNode) GetLastState

func (m *ExecutorNode) GetLastState() *NodeState

func (*ExecutorNode) ProtoMessage

func (*ExecutorNode) ProtoMessage()

func (*ExecutorNode) Reset

func (m *ExecutorNode) Reset()

func (*ExecutorNode) String

func (m *ExecutorNode) String() string

type FailureMessage

type FailureMessage struct {
	ErrorType FailureMessage_ErrorType   `protobuf:"varint,1,opt,name=error_type,enum=model.FailureMessage_ErrorType" json:"error_type,omitempty"`
	FailedAt  *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=failed_at" json:"failed_at,omitempty"`
}

func (*FailureMessage) Descriptor

func (*FailureMessage) Descriptor() ([]byte, []int)

func (*FailureMessage) GetErrorType

func (m *FailureMessage) GetErrorType() FailureMessage_ErrorType

func (*FailureMessage) GetFailedAt

func (m *FailureMessage) GetFailedAt() *google_protobuf.Timestamp

func (*FailureMessage) ProtoMessage

func (*FailureMessage) ProtoMessage()

func (*FailureMessage) Reset

func (m *FailureMessage) Reset()

func (*FailureMessage) String

func (m *FailureMessage) String() string

type FailureMessage_ErrorType

type FailureMessage_ErrorType int32
const (
	FailureMessage_FAILED_BOOT      FailureMessage_ErrorType = 0
	FailureMessage_FAILED_START     FailureMessage_ErrorType = 1
	FailureMessage_FAILED_STOP      FailureMessage_ErrorType = 2
	FailureMessage_FAILED_REBOOT    FailureMessage_ErrorType = 3
	FailureMessage_FAILED_TERMINATE FailureMessage_ErrorType = 4
)

func (FailureMessage_ErrorType) EnumDescriptor

func (FailureMessage_ErrorType) EnumDescriptor() ([]byte, []int)

func (FailureMessage_ErrorType) String

func (x FailureMessage_ErrorType) String() string

type Instance

type Instance struct {
	Id      string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	SlaveId string `protobuf:"bytes,2,opt,name=slave_id" json:"slave_id,omitempty"`
	// string resource_id = 3; // Obsolete
	LastState        *InstanceState             `protobuf:"bytes,4,opt,name=last_state" json:"last_state,omitempty"`
	CreatedAt        *google_protobuf.Timestamp `protobuf:"bytes,5,opt,name=created_at" json:"created_at,omitempty"`
	Template         *Template                  `protobuf:"bytes,6,opt,name=template" json:"template,omitempty"`
	LatestFailure    *FailureMessage            `protobuf:"bytes,7,opt,name=latest_failure" json:"latest_failure,omitempty"`
	AutoRecovery     bool                       `protobuf:"varint,8,opt,name=auto_recovery" json:"auto_recovery,omitempty"`
	ConnectionStatus *ConnectionStatus          `protobuf:"bytes,9,opt,name=connection_status" json:"connection_status,omitempty"`
}

func (*Instance) Descriptor

func (*Instance) Descriptor() ([]byte, []int)

func (*Instance) GetAutoRecovery

func (m *Instance) GetAutoRecovery() bool

func (*Instance) GetConnectionStatus

func (m *Instance) GetConnectionStatus() *ConnectionStatus

func (*Instance) GetCreatedAt

func (m *Instance) GetCreatedAt() *google_protobuf.Timestamp

func (*Instance) GetId

func (m *Instance) GetId() string

func (*Instance) GetLastState

func (m *Instance) GetLastState() *InstanceState

func (*Instance) GetLatestFailure

func (m *Instance) GetLatestFailure() *FailureMessage

func (*Instance) GetSlaveId

func (m *Instance) GetSlaveId() string

func (*Instance) GetTemplate

func (m *Instance) GetTemplate() *Template

func (*Instance) ProtoMessage

func (*Instance) ProtoMessage()

func (*Instance) Reset

func (m *Instance) Reset()

func (*Instance) ResourceTemplate

func (i *Instance) ResourceTemplate() ResourceTemplate

func (*Instance) String

func (m *Instance) String() string

type InstanceOps

type InstanceOps interface {
	Create(*Instance) (*Instance, error)
	FindByID(string) (*Instance, error)
	AddFailureMessage(id string, failureMessage FailureMessage_ErrorType) error
	//GetLatestFailureMessage(id string) (*FailureMessage, error)
	ForceUpdateState(id string, next InstanceState_State) error
	UpdateState(id string, next InstanceState_State) error
	UpdateConnectionStatus(id string, connStatus ConnectionStatus_Status) error
	FilterByState(state InstanceState_State) ([]*Instance, error)
	FilterByAgentMesosID(agentID string) ([]*Instance, error)
	Update(*Instance) error
	Filter(limit int, cb func(*Instance) int) error
	WaitStateUpdate(id string) (*InstanceState, error)
}

func Instances

func Instances(ctx context.Context) InstanceOps

type InstanceResource

type InstanceResource interface {

	// protobuf message belongs to InstanceResource should have fields below:
	//  int32 vcpu = xx;
	//  int32 memory_gb = xx;
	//  repeated string node_groups = xx;
	GetVcpu() int32
	GetMemoryGb() int32
	GetNodeGroups() []string
	// contains filtered or unexported methods
}

InstanceResource is a marker interface for instance template structs.

type InstanceState

type InstanceState struct {
	State     InstanceState_State        `protobuf:"varint,1,opt,name=state,enum=model.InstanceState_State" json:"state,omitempty"`
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=created_at" json:"created_at,omitempty"`
}

func (*InstanceState) Descriptor

func (*InstanceState) Descriptor() ([]byte, []int)

func (*InstanceState) GetCreatedAt

func (m *InstanceState) GetCreatedAt() *google_protobuf.Timestamp

func (*InstanceState) GetState

func (m *InstanceState) GetState() InstanceState_State

func (*InstanceState) ProtoMessage

func (*InstanceState) ProtoMessage()

func (*InstanceState) ReadyForConsole

func (i *InstanceState) ReadyForConsole() error

func (*InstanceState) Reset

func (m *InstanceState) Reset()

func (*InstanceState) String

func (m *InstanceState) String() string

func (*InstanceState) ValidateGoalState

func (i *InstanceState) ValidateGoalState(goal InstanceState_State) error

func (*InstanceState) ValidateNextState

func (i *InstanceState) ValidateNextState(next InstanceState_State) error

type InstanceStateSlice

type InstanceStateSlice []InstanceState_State

func (InstanceStateSlice) Contains

func (s InstanceStateSlice) Contains(state InstanceState_State) bool

type InstanceState_State

type InstanceState_State int32
const (
	InstanceState_REGISTERED   InstanceState_State = 0
	InstanceState_QUEUED       InstanceState_State = 1
	InstanceState_STARTING     InstanceState_State = 2
	InstanceState_RUNNING      InstanceState_State = 3
	InstanceState_STOPPING     InstanceState_State = 4
	InstanceState_STOPPED      InstanceState_State = 5
	InstanceState_REBOOTING    InstanceState_State = 6
	InstanceState_SHUTTINGDOWN InstanceState_State = 7
	InstanceState_TERMINATED   InstanceState_State = 8
	InstanceState_FAILED       InstanceState_State = 9
)

func (InstanceState_State) EnumDescriptor

func (InstanceState_State) EnumDescriptor() ([]byte, []int)

func (InstanceState_State) String

func (x InstanceState_State) String() string

type LxcTemplate

type LxcTemplate struct {
	Vcpu        int32                    `protobuf:"varint,1,opt,name=vcpu" json:"vcpu,omitempty"`
	MemoryGb    int32                    `protobuf:"varint,2,opt,name=memory_gb" json:"memory_gb,omitempty"`
	MinVcpu     int32                    `protobuf:"varint,3,opt,name=min_vcpu" json:"min_vcpu,omitempty"`
	MinMemoryGb int32                    `protobuf:"varint,4,opt,name=min_memory_gb" json:"min_memory_gb,omitempty"`
	LxcImage    *LxcTemplate_Image       `protobuf:"bytes,5,opt,name=lxc_image" json:"lxc_image,omitempty"`
	Interfaces  []*LxcTemplate_Interface `protobuf:"bytes,6,rep,name=interfaces" json:"interfaces,omitempty"`
	LxcTemplate *LxcTemplate_Template    `protobuf:"bytes,7,opt,name=lxc_template" json:"lxc_template,omitempty"`
	NodeGroups  []string                 `protobuf:"bytes,8,rep,name=node_groups" json:"node_groups,omitempty"`
}

func (*LxcTemplate) Descriptor

func (*LxcTemplate) Descriptor() ([]byte, []int)

func (*LxcTemplate) GetInterfaces

func (m *LxcTemplate) GetInterfaces() []*LxcTemplate_Interface

func (*LxcTemplate) GetLxcImage

func (m *LxcTemplate) GetLxcImage() *LxcTemplate_Image

func (*LxcTemplate) GetLxcTemplate

func (m *LxcTemplate) GetLxcTemplate() *LxcTemplate_Template

func (*LxcTemplate) GetMemoryGb

func (m *LxcTemplate) GetMemoryGb() int32

func (*LxcTemplate) GetMinMemoryGb

func (m *LxcTemplate) GetMinMemoryGb() int32

func (*LxcTemplate) GetMinVcpu

func (m *LxcTemplate) GetMinVcpu() int32

func (*LxcTemplate) GetNodeGroups

func (m *LxcTemplate) GetNodeGroups() []string

func (*LxcTemplate) GetVcpu

func (m *LxcTemplate) GetVcpu() int32

func (*LxcTemplate) ProtoMessage

func (*LxcTemplate) ProtoMessage()

func (*LxcTemplate) Reset

func (m *LxcTemplate) Reset()

func (*LxcTemplate) ResourceName

func (*LxcTemplate) ResourceName() string

func (*LxcTemplate) String

func (m *LxcTemplate) String() string

type LxcTemplate_Image

type LxcTemplate_Image struct {
	DownloadUrl string `protobuf:"bytes,1,opt,name=download_url" json:"download_url,omitempty"`
	ChksumType  string `protobuf:"bytes,2,opt,name=chksum_type" json:"chksum_type,omitempty"`
	Chksum      string `protobuf:"bytes,3,opt,name=chksum" json:"chksum,omitempty"`
}

func (*LxcTemplate_Image) Descriptor

func (*LxcTemplate_Image) Descriptor() ([]byte, []int)

func (*LxcTemplate_Image) GetChksum

func (m *LxcTemplate_Image) GetChksum() string

func (*LxcTemplate_Image) GetChksumType

func (m *LxcTemplate_Image) GetChksumType() string

func (*LxcTemplate_Image) GetDownloadUrl

func (m *LxcTemplate_Image) GetDownloadUrl() string

func (*LxcTemplate_Image) ProtoMessage

func (*LxcTemplate_Image) ProtoMessage()

func (*LxcTemplate_Image) Reset

func (m *LxcTemplate_Image) Reset()

func (*LxcTemplate_Image) String

func (m *LxcTemplate_Image) String() string

type LxcTemplate_Interface

type LxcTemplate_Interface struct {
	Type     string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Macaddr  string `protobuf:"bytes,2,opt,name=macaddr" json:"macaddr,omitempty"`
	Ipv4Addr string `protobuf:"bytes,3,opt,name=ipv4addr" json:"ipv4addr,omitempty"`
	// string bridge = 4; // Obsolete
	Ipv4Gateway string `protobuf:"bytes,5,opt,name=ipv4gateway" json:"ipv4gateway,omitempty"`
}

func (*LxcTemplate_Interface) Descriptor

func (*LxcTemplate_Interface) Descriptor() ([]byte, []int)

func (*LxcTemplate_Interface) GetIpv4Addr

func (m *LxcTemplate_Interface) GetIpv4Addr() string

func (*LxcTemplate_Interface) GetIpv4Gateway

func (m *LxcTemplate_Interface) GetIpv4Gateway() string

func (*LxcTemplate_Interface) GetMacaddr

func (m *LxcTemplate_Interface) GetMacaddr() string

func (*LxcTemplate_Interface) GetType

func (m *LxcTemplate_Interface) GetType() string

func (*LxcTemplate_Interface) ProtoMessage

func (*LxcTemplate_Interface) ProtoMessage()

func (*LxcTemplate_Interface) Reset

func (m *LxcTemplate_Interface) Reset()

func (*LxcTemplate_Interface) String

func (m *LxcTemplate_Interface) String() string

type LxcTemplate_Template

type LxcTemplate_Template struct {
	// Template specifies the name of the template.
	Template string `protobuf:"bytes,1,opt,name=template" json:"template,omitempty"`
	// Backend specifies the type of the backend.
	Backend int32 `protobuf:"varint,2,opt,name=backend" json:"backend,omitempty"`
	// Distro specifies the name of the distribution.
	Distro string `protobuf:"bytes,3,opt,name=distro" json:"distro,omitempty"`
	// Release specifies the name/version of the distribution.
	Release string `protobuf:"bytes,4,opt,name=release" json:"release,omitempty"`
	// Arch specified the architecture of the container.
	Arch string `protobuf:"bytes,5,opt,name=arch" json:"arch,omitempty"`
	// Variant specifies the variant of the image (default: "default").
	Variant string `protobuf:"bytes,6,opt,name=variant" json:"variant,omitempty"`
	// Image server (default: "images.linuxcontainers.org").
	Server string `protobuf:"bytes,7,opt,name=server" json:"server,omitempty"`
	// GPG keyid (default: 0x...).
	KeyId string `protobuf:"bytes,8,opt,name=key_id" json:"key_id,omitempty"`
	// GPG keyserver to use.
	KeyServer string `protobuf:"bytes,9,opt,name=key_server" json:"key_server,omitempty"`
	// Disable GPG validation (not recommended).
	DisableGpgValidation bool `protobuf:"varint,10,opt,name=disable_gpg_validation" json:"disable_gpg_validation,omitempty"`
	// Flush the local copy (if present).
	FlushCache bool `protobuf:"varint,11,opt,name=flush_cache" json:"flush_cache,omitempty"`
	// Force the use of the local copy even if expired.
	ForceCache bool `protobuf:"varint,12,opt,name=force_cache" json:"force_cache,omitempty"`
	// ExtraArgs provides a way to specify template specific args.
	ExtraArgs []string `protobuf:"bytes,13,rep,name=extra_args" json:"extra_args,omitempty"`
}

func (*LxcTemplate_Template) Descriptor

func (*LxcTemplate_Template) Descriptor() ([]byte, []int)

func (*LxcTemplate_Template) GetArch

func (m *LxcTemplate_Template) GetArch() string

func (*LxcTemplate_Template) GetBackend

func (m *LxcTemplate_Template) GetBackend() int32

func (*LxcTemplate_Template) GetDisableGpgValidation

func (m *LxcTemplate_Template) GetDisableGpgValidation() bool

func (*LxcTemplate_Template) GetDistro

func (m *LxcTemplate_Template) GetDistro() string

func (*LxcTemplate_Template) GetExtraArgs

func (m *LxcTemplate_Template) GetExtraArgs() []string

func (*LxcTemplate_Template) GetFlushCache

func (m *LxcTemplate_Template) GetFlushCache() bool

func (*LxcTemplate_Template) GetForceCache

func (m *LxcTemplate_Template) GetForceCache() bool

func (*LxcTemplate_Template) GetKeyId

func (m *LxcTemplate_Template) GetKeyId() string

func (*LxcTemplate_Template) GetKeyServer

func (m *LxcTemplate_Template) GetKeyServer() string

func (*LxcTemplate_Template) GetRelease

func (m *LxcTemplate_Template) GetRelease() string

func (*LxcTemplate_Template) GetServer

func (m *LxcTemplate_Template) GetServer() string

func (*LxcTemplate_Template) GetTemplate

func (m *LxcTemplate_Template) GetTemplate() string

func (*LxcTemplate_Template) GetVariant

func (m *LxcTemplate_Template) GetVariant() string

func (*LxcTemplate_Template) ProtoMessage

func (*LxcTemplate_Template) ProtoMessage()

func (*LxcTemplate_Template) Reset

func (m *LxcTemplate_Template) Reset()

func (*LxcTemplate_Template) String

func (m *LxcTemplate_Template) String() string

type Node

type Node interface {
	proto.Message
	GetAgentId() string
	GetAgentMesosId() string
}

type NodeOps

type NodeOps interface {
	Add(node Node) error
	FindByAgentMesosID(agentMesosID string) (*AgentNode, error)
	FindByAgentID(agentID string) (*AgentNode, error)
	Filter(limit int, cb func(*AgentNode) int) error
	UpdateAgentMesosID(agentID string, agentMesosID string) error
}

func Nodes

func Nodes(ctx context.Context) NodeOps

type NodeState

type NodeState struct {
	State     NodeState_State            `protobuf:"varint,1,opt,name=state,enum=model.NodeState_State" json:"state,omitempty"`
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=created_at" json:"created_at,omitempty"`
}

func (*NodeState) Descriptor

func (*NodeState) Descriptor() ([]byte, []int)

func (*NodeState) GetCreatedAt

func (m *NodeState) GetCreatedAt() *google_protobuf.Timestamp

func (*NodeState) GetState

func (m *NodeState) GetState() NodeState_State

func (*NodeState) ProtoMessage

func (*NodeState) ProtoMessage()

func (*NodeState) Reset

func (m *NodeState) Reset()

func (*NodeState) String

func (m *NodeState) String() string

type NodeState_State

type NodeState_State int32
const (
	NodeState_REGISTERED NodeState_State = 0
)

func (NodeState_State) EnumDescriptor

func (NodeState_State) EnumDescriptor() ([]byte, []int)

func (NodeState_State) String

func (x NodeState_State) String() string

type NoneTemplate

type NoneTemplate struct {
}

func (*NoneTemplate) Descriptor

func (*NoneTemplate) Descriptor() ([]byte, []int)

func (*NoneTemplate) ProtoMessage

func (*NoneTemplate) ProtoMessage()

func (*NoneTemplate) Reset

func (m *NoneTemplate) Reset()

func (*NoneTemplate) ResourceName

func (*NoneTemplate) ResourceName() string

func (*NoneTemplate) String

func (m *NoneTemplate) String() string

type NullTemplate

type NullTemplate struct {
	Vcpu       int32                   `protobuf:"varint,1,opt,name=vcpu" json:"vcpu,omitempty"`
	MemoryGb   int32                   `protobuf:"varint,2,opt,name=memory_gb" json:"memory_gb,omitempty"`
	CrashStage NullTemplate_CrashStage `protobuf:"varint,3,opt,name=crash_stage,enum=model.NullTemplate_CrashStage" json:"crash_stage,omitempty"`
	NodeGroups []string                `protobuf:"bytes,4,rep,name=node_groups" json:"node_groups,omitempty"`
}

func (*NullTemplate) Descriptor

func (*NullTemplate) Descriptor() ([]byte, []int)

func (*NullTemplate) GetCrashStage

func (m *NullTemplate) GetCrashStage() NullTemplate_CrashStage

func (*NullTemplate) GetMemoryGb

func (m *NullTemplate) GetMemoryGb() int32

func (*NullTemplate) GetNodeGroups

func (m *NullTemplate) GetNodeGroups() []string

func (*NullTemplate) GetVcpu

func (m *NullTemplate) GetVcpu() int32

func (*NullTemplate) ProtoMessage

func (*NullTemplate) ProtoMessage()

func (*NullTemplate) Reset

func (m *NullTemplate) Reset()

func (*NullTemplate) ResourceName

func (*NullTemplate) ResourceName() string

func (*NullTemplate) String

func (m *NullTemplate) String() string

type NullTemplate_CrashStage

type NullTemplate_CrashStage int32
const (
	NullTemplate_NONE    NullTemplate_CrashStage = 0
	NullTemplate_START   NullTemplate_CrashStage = 1
	NullTemplate_STOP    NullTemplate_CrashStage = 2
	NullTemplate_CREATE  NullTemplate_CrashStage = 3
	NullTemplate_DESTROY NullTemplate_CrashStage = 4
	NullTemplate_REBOOT  NullTemplate_CrashStage = 5
)

func (NullTemplate_CrashStage) EnumDescriptor

func (NullTemplate_CrashStage) EnumDescriptor() ([]byte, []int)

func (NullTemplate_CrashStage) String

func (x NullTemplate_CrashStage) String() string

type QemuTemplate

type QemuTemplate struct {
	Vcpu        int32                     `protobuf:"varint,1,opt,name=vcpu" json:"vcpu,omitempty"`
	MemoryGb    int32                     `protobuf:"varint,2,opt,name=memory_gb" json:"memory_gb,omitempty"`
	MinVcpu     int32                     `protobuf:"varint,3,opt,name=min_vcpu" json:"min_vcpu,omitempty"`
	MinMemoryGb int32                     `protobuf:"varint,4,opt,name=min_memory_gb" json:"min_memory_gb,omitempty"`
	QemuImage   *QemuTemplate_Image       `protobuf:"bytes,5,opt,name=qemu_image" json:"qemu_image,omitempty"`
	UseKvm      bool                      `protobuf:"varint,6,opt,name=use_kvm" json:"use_kvm,omitempty"`
	Interfaces  []*QemuTemplate_Interface `protobuf:"bytes,7,rep,name=interfaces" json:"interfaces,omitempty"`
	NodeGroups  []string                  `protobuf:"bytes,8,rep,name=node_groups" json:"node_groups,omitempty"`
}

func (*QemuTemplate) Descriptor

func (*QemuTemplate) Descriptor() ([]byte, []int)

func (*QemuTemplate) GetInterfaces

func (m *QemuTemplate) GetInterfaces() []*QemuTemplate_Interface

func (*QemuTemplate) GetMemoryGb

func (m *QemuTemplate) GetMemoryGb() int32

func (*QemuTemplate) GetMinMemoryGb

func (m *QemuTemplate) GetMinMemoryGb() int32

func (*QemuTemplate) GetMinVcpu

func (m *QemuTemplate) GetMinVcpu() int32

func (*QemuTemplate) GetNodeGroups

func (m *QemuTemplate) GetNodeGroups() []string

func (*QemuTemplate) GetQemuImage

func (m *QemuTemplate) GetQemuImage() *QemuTemplate_Image

func (*QemuTemplate) GetUseKvm

func (m *QemuTemplate) GetUseKvm() bool

func (*QemuTemplate) GetVcpu

func (m *QemuTemplate) GetVcpu() int32

func (*QemuTemplate) ProtoMessage

func (*QemuTemplate) ProtoMessage()

func (*QemuTemplate) Reset

func (m *QemuTemplate) Reset()

func (*QemuTemplate) ResourceName

func (*QemuTemplate) ResourceName() string

func (*QemuTemplate) String

func (m *QemuTemplate) String() string

type QemuTemplate_Image

type QemuTemplate_Image struct {
	DownloadUrl string                    `protobuf:"bytes,1,opt,name=download_url" json:"download_url,omitempty"`
	ChksumType  string                    `protobuf:"bytes,2,opt,name=chksum_type" json:"chksum_type,omitempty"`
	Chksum      string                    `protobuf:"bytes,3,opt,name=chksum" json:"chksum,omitempty"`
	Format      QemuTemplate_Image_Format `protobuf:"varint,4,opt,name=format,enum=model.QemuTemplate_Image_Format" json:"format,omitempty"`
}

func (*QemuTemplate_Image) Descriptor

func (*QemuTemplate_Image) Descriptor() ([]byte, []int)

func (*QemuTemplate_Image) GetChksum

func (m *QemuTemplate_Image) GetChksum() string

func (*QemuTemplate_Image) GetChksumType

func (m *QemuTemplate_Image) GetChksumType() string

func (*QemuTemplate_Image) GetDownloadUrl

func (m *QemuTemplate_Image) GetDownloadUrl() string

func (*QemuTemplate_Image) GetFormat

func (*QemuTemplate_Image) ProtoMessage

func (*QemuTemplate_Image) ProtoMessage()

func (*QemuTemplate_Image) Reset

func (m *QemuTemplate_Image) Reset()

func (*QemuTemplate_Image) String

func (m *QemuTemplate_Image) String() string

type QemuTemplate_Image_Format

type QemuTemplate_Image_Format int32
const (
	QemuTemplate_Image_RAW   QemuTemplate_Image_Format = 0
	QemuTemplate_Image_QCOW2 QemuTemplate_Image_Format = 1
)

func (QemuTemplate_Image_Format) EnumDescriptor

func (QemuTemplate_Image_Format) EnumDescriptor() ([]byte, []int)

func (QemuTemplate_Image_Format) String

func (x QemuTemplate_Image_Format) String() string

type QemuTemplate_Interface

type QemuTemplate_Interface struct {
	Type     string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Macaddr  string `protobuf:"bytes,2,opt,name=macaddr" json:"macaddr,omitempty"`
	Ipv4Addr string `protobuf:"bytes,3,opt,name=ipv4addr" json:"ipv4addr,omitempty"`
	// string bridge = 4; // Obsolete
	Ipv4Gateway string `protobuf:"bytes,5,opt,name=ipv4gateway" json:"ipv4gateway,omitempty"`
}

func (*QemuTemplate_Interface) Descriptor

func (*QemuTemplate_Interface) Descriptor() ([]byte, []int)

func (*QemuTemplate_Interface) GetIpv4Addr

func (m *QemuTemplate_Interface) GetIpv4Addr() string

func (*QemuTemplate_Interface) GetIpv4Gateway

func (m *QemuTemplate_Interface) GetIpv4Gateway() string

func (*QemuTemplate_Interface) GetMacaddr

func (m *QemuTemplate_Interface) GetMacaddr() string

func (*QemuTemplate_Interface) GetType

func (m *QemuTemplate_Interface) GetType() string

func (*QemuTemplate_Interface) ProtoMessage

func (*QemuTemplate_Interface) ProtoMessage()

func (*QemuTemplate_Interface) Reset

func (m *QemuTemplate_Interface) Reset()

func (*QemuTemplate_Interface) String

func (m *QemuTemplate_Interface) String() string

type ResourceTemplate

type ResourceTemplate interface {
	ResourceName() string
	// contains filtered or unexported methods
}

ResourceTemplate is a marker interface for all resource template structs.

Example (Reflection)
// Normal type assertion
rl, ok := res1.Template.Item.(*Template_Lxc)
fmt.Println(rl.Lxc, ok)
// Using reflection API
v := reflect.ValueOf(res1.Template.Item)
fmt.Println(v.Kind())
fmt.Println(v.Type().String())
fmt.Println(
	"ConvertibleTo(*Template_Lxc) ->",
	v.Type().ConvertibleTo(reflect.TypeOf((*Template_Lxc)(nil))),
)
fmt.Println(
	"ConvertibleTo(*Template_Null) ->",
	v.Type().ConvertibleTo(reflect.TypeOf((*Template_Null)(nil))),
)
fieldName := strings.TrimPrefix(v.Type().String(), "*model.Template_")
fmt.Println(fieldName)
f := v.Elem().FieldByName(fieldName)
fmt.Println(f.Type().String())
fmt.Println(f.MethodByName("ResourceName").Call([]reflect.Value{})[0])
Output:

vcpu:1 memory_gb:10 lxc_image:<download_url:"http://example.com/image.raw" chksum:"1234567890abcdef" >  true
ptr
*model.Template_Lxc
ConvertibleTo(*Template_Lxc) -> true
ConvertibleTo(*Template_Null) -> false
Lxc
*model.LxcTemplate
vm/lxc

func GetResourceTemplate

func GetResourceTemplate(tmpl *Template) ResourceTemplate

ResourceTemplate resolves the assigned object type of "Template" OneOf field and cast to ResourceTemplate interface. So that you can get the resource name in string.

type SchedulerNode

type SchedulerNode struct {
	Id        string                     `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=created_at" json:"created_at,omitempty"`
}

func (*SchedulerNode) Descriptor

func (*SchedulerNode) Descriptor() ([]byte, []int)

func (*SchedulerNode) GetCreatedAt

func (m *SchedulerNode) GetCreatedAt() *google_protobuf.Timestamp

func (*SchedulerNode) GetId

func (m *SchedulerNode) GetId() string

func (*SchedulerNode) ProtoMessage

func (*SchedulerNode) ProtoMessage()

func (*SchedulerNode) Reset

func (m *SchedulerNode) Reset()

func (*SchedulerNode) String

func (m *SchedulerNode) String() string

type Template

type Template struct {
	TemplateUri string `protobuf:"bytes,1,opt,name=template_uri" json:"template_uri,omitempty"`
	// Types that are valid to be assigned to Item:
	//	*Template_None
	//	*Template_Lxc
	//	*Template_Null
	//	*Template_Qemu
	//	*Template_Esxi
	Item      isTemplate_Item            `protobuf_oneof:"Item"`
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=created_at" json:"created_at,omitempty"`
}

func (*Template) Descriptor

func (*Template) Descriptor() ([]byte, []int)

func (*Template) GetCreatedAt

func (m *Template) GetCreatedAt() *google_protobuf.Timestamp

func (*Template) GetEsxi

func (m *Template) GetEsxi() *EsxiTemplate

func (*Template) GetItem

func (m *Template) GetItem() isTemplate_Item

func (*Template) GetLxc

func (m *Template) GetLxc() *LxcTemplate

func (*Template) GetNone

func (m *Template) GetNone() *NoneTemplate

func (*Template) GetNull

func (m *Template) GetNull() *NullTemplate

func (*Template) GetQemu

func (m *Template) GetQemu() *QemuTemplate

func (*Template) GetTemplateUri

func (m *Template) GetTemplateUri() string

func (*Template) ProtoMessage

func (*Template) ProtoMessage()

func (*Template) Reset

func (m *Template) Reset()

func (*Template) ResourceTemplate

func (t *Template) ResourceTemplate() ResourceTemplate

func (*Template) String

func (m *Template) String() string

func (*Template) XXX_OneofFuncs

func (*Template) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Template_Esxi

type Template_Esxi struct {
	Esxi *EsxiTemplate `protobuf:"bytes,504,opt,name=esxi,oneof"`
}

type Template_Lxc

type Template_Lxc struct {
	Lxc *LxcTemplate `protobuf:"bytes,501,opt,name=lxc,oneof"`
}

type Template_None

type Template_None struct {
	None *NoneTemplate `protobuf:"bytes,500,opt,name=none,oneof"`
}

type Template_Null

type Template_Null struct {
	Null *NullTemplate `protobuf:"bytes,502,opt,name=null,oneof"`
}

type Template_Qemu

type Template_Qemu struct {
	Qemu *QemuTemplate `protobuf:"bytes,503,opt,name=qemu,oneof"`
}

Directories

Path Synopsis
Package backend is a generated protocol buffer package.
Package backend is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL