proto

package
v0.0.0-...-89e0d77 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2019 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var VoskhodClientCommand = &cobra.Command{
	Use: "voskhod",
}

Functions

func RegisterVoskhodServer 

func RegisterVoskhodServer(s *grpc.Server, srv VoskhodServer)

Types

type Agent 

type Agent struct {
	// Unique id of the agent.
	// Which is either generated or provided.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// A canonical name for the agent.
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Agent is representing an agent to scheduler

This is the identification of an agent to the scheduler. It contains all the information about an agent.

func (*Agent) Descriptor 

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

func (*Agent) GetName 

func (m *Agent) GetName() string

func (*Agent) GetUuid 

func (m *Agent) GetUuid() string

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) String 

func (m *Agent) String() string

func (*Agent) XXX_DiscardUnknown 

func (m *Agent) XXX_DiscardUnknown()

func (*Agent) XXX_Marshal 

func (m *Agent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Agent) XXX_Merge 

func (m *Agent) XXX_Merge(src proto.Message)

func (*Agent) XXX_Size 

func (m *Agent) XXX_Size() int

func (*Agent) XXX_Unmarshal 

func (m *Agent) XXX_Unmarshal(b []byte) error

type Cluster 

type Cluster struct {
	// The unique identifier of a cluster.
	// It has to be unique to cluster resources accordingly,
	// and transport offers and ACKs.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// The canonical name of a cluster.
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Cluster is representing a set of agents with resources

A cluster is a logical collection of agents.

func (*Cluster) Descriptor 

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

func (*Cluster) GetName 

func (m *Cluster) GetName() string

func (*Cluster) GetUuid 

func (m *Cluster) GetUuid() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cluster) XXX_Merge 

func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

func (m *Cluster) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	// Types that are valid to be assigned to Event:
	//	*Event_Reserve
	Event                isEvent_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewReserve 

func NewReserve() *Event

func (*Event) Descriptor 

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

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetReserve 

func (m *Event) GetReserve() *Reserve

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Event_Reserve 

type Event_Reserve struct {
	Reserve *Reserve `protobuf:"bytes,1,opt,name=reserve,proto3,oneof"`
}

type RegisterAgentRequest 

type RegisterAgentRequest struct {
	// The agent which wants to register.
	Agent                *Agent   `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for RegisterAgent

func (*RegisterAgentRequest) Descriptor 

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

func (*RegisterAgentRequest) GetAgent 

func (m *RegisterAgentRequest) GetAgent() *Agent

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) Reset 

func (m *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (m *RegisterAgentRequest) String() string

func (*RegisterAgentRequest) XXX_DiscardUnknown 

func (m *RegisterAgentRequest) XXX_DiscardUnknown()

func (*RegisterAgentRequest) XXX_Marshal 

func (m *RegisterAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterAgentRequest) XXX_Merge 

func (m *RegisterAgentRequest) XXX_Merge(src proto.Message)

func (*RegisterAgentRequest) XXX_Size 

func (m *RegisterAgentRequest) XXX_Size() int

func (*RegisterAgentRequest) XXX_Unmarshal 

func (m *RegisterAgentRequest) XXX_Unmarshal(b []byte) error

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	// The cluster the agent is register to.
	Cluster              *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for RegisterAgent

func (*RegisterAgentResponse) Descriptor 

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

func (*RegisterAgentResponse) GetCluster 

func (m *RegisterAgentResponse) GetCluster() *Cluster

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) Reset 

func (m *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (m *RegisterAgentResponse) String() string

func (*RegisterAgentResponse) XXX_DiscardUnknown 

func (m *RegisterAgentResponse) XXX_DiscardUnknown()

func (*RegisterAgentResponse) XXX_Marshal 

func (m *RegisterAgentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterAgentResponse) XXX_Merge 

func (m *RegisterAgentResponse) XXX_Merge(src proto.Message)

func (*RegisterAgentResponse) XXX_Size 

func (m *RegisterAgentResponse) XXX_Size() int

func (*RegisterAgentResponse) XXX_Unmarshal 

func (m *RegisterAgentResponse) XXX_Unmarshal(b []byte) error

type Reserve 

type Reserve struct {
	Memory               uint64   `protobuf:"varint,1,opt,name=memory,proto3" json:"memory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Reserve) Descriptor 

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

func (*Reserve) GetMemory 

func (m *Reserve) GetMemory() uint64

func (*Reserve) ProtoMessage 

func (*Reserve) ProtoMessage()

func (*Reserve) Reset 

func (m *Reserve) Reset()

func (*Reserve) String 

func (m *Reserve) String() string

func (*Reserve) XXX_DiscardUnknown 

func (m *Reserve) XXX_DiscardUnknown()

func (*Reserve) XXX_Marshal 

func (m *Reserve) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Reserve) XXX_Merge 

func (m *Reserve) XXX_Merge(src proto.Message)

func (*Reserve) XXX_Size 

func (m *Reserve) XXX_Size() int

func (*Reserve) XXX_Unmarshal 

func (m *Reserve) XXX_Unmarshal(b []byte) error

type VoskhodClient 

type VoskhodClient interface {
	RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
}

VoskhodClient is the client API for Voskhod service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVoskhodClient 

func NewVoskhodClient(cc *grpc.ClientConn) VoskhodClient

type VoskhodServer 

type VoskhodServer interface {
	RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
}

VoskhodServer is the server API for Voskhod service.

Source Files

View all Source files

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.