v1

package
v0.0.0-...-f1bde72 Latest Latest
Warning

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

Go to latest
Published: Nov 18, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTerra = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTerra   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTerraServer

func RegisterTerraServer(s *grpc.Server, srv TerraServer)

Types

type MachinesResponse

type MachinesResponse struct {
	Machines             []*v1.Machine `protobuf:"bytes,1,rep,name=machines,proto3" json:"machines,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MachinesResponse) Descriptor

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

func (*MachinesResponse) Marshal

func (m *MachinesResponse) Marshal() (dAtA []byte, err error)

func (*MachinesResponse) MarshalTo

func (m *MachinesResponse) MarshalTo(dAtA []byte) (int, error)

func (*MachinesResponse) ProtoMessage

func (*MachinesResponse) ProtoMessage()

func (*MachinesResponse) Reset

func (m *MachinesResponse) Reset()

func (*MachinesResponse) Size

func (m *MachinesResponse) Size() (n int)

func (*MachinesResponse) String

func (this *MachinesResponse) String() string

func (*MachinesResponse) Unmarshal

func (m *MachinesResponse) Unmarshal(dAtA []byte) error

func (*MachinesResponse) XXX_DiscardUnknown

func (m *MachinesResponse) XXX_DiscardUnknown()

func (*MachinesResponse) XXX_Marshal

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

func (*MachinesResponse) XXX_Merge

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

func (*MachinesResponse) XXX_Size

func (m *MachinesResponse) XXX_Size() int

func (*MachinesResponse) XXX_Unmarshal

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

type RegisterRequest

type RegisterRequest struct {
	Cpus                 uint32       `protobuf:"varint,1,opt,name=cpus,proto3" json:"cpus,omitempty"`
	Memory               uint64       `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"`
	NetworkDevices       []*v1.Netdev `protobuf:"bytes,3,rep,name=network_devices,json=networkDevices,proto3" json:"network_devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RegisterRequest) Descriptor

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

func (*RegisterRequest) Marshal

func (m *RegisterRequest) Marshal() (dAtA []byte, err error)

func (*RegisterRequest) MarshalTo

func (m *RegisterRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset

func (m *RegisterRequest) Reset()

func (*RegisterRequest) Size

func (m *RegisterRequest) Size() (n int)

func (*RegisterRequest) String

func (this *RegisterRequest) String() string

func (*RegisterRequest) Unmarshal

func (m *RegisterRequest) Unmarshal(dAtA []byte) error

func (*RegisterRequest) XXX_DiscardUnknown

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal

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

func (*RegisterRequest) XXX_Merge

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

func (*RegisterRequest) XXX_Size

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal

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

type RegisterResponse

type RegisterResponse struct {
	Machine              *v1.Machine `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RegisterResponse) Descriptor

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

func (*RegisterResponse) Marshal

func (m *RegisterResponse) Marshal() (dAtA []byte, err error)

func (*RegisterResponse) MarshalTo

func (m *RegisterResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterResponse) ProtoMessage

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset

func (m *RegisterResponse) Reset()

func (*RegisterResponse) Size

func (m *RegisterResponse) Size() (n int)

func (*RegisterResponse) String

func (this *RegisterResponse) String() string

func (*RegisterResponse) Unmarshal

func (m *RegisterResponse) Unmarshal(dAtA []byte) error

func (*RegisterResponse) XXX_DiscardUnknown

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal

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

func (*RegisterResponse) XXX_Merge

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

func (*RegisterResponse) XXX_Size

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal

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

type TerraClient

type TerraClient interface {
	// Register a new machine to terra
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Machines returns all registered machines
	Machines(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*MachinesResponse, error)
}

TerraClient is the client API for Terra service.

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

func NewTerraClient

func NewTerraClient(cc *grpc.ClientConn) TerraClient

type TerraServer

type TerraServer interface {
	// Register a new machine to terra
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Machines returns all registered machines
	Machines(context.Context, *types.Empty) (*MachinesResponse, error)
}

TerraServer is the server API for Terra service.

Jump to

Keyboard shortcuts

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