api

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: 23 Imported by: 0

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

v1.proto

It has these top-level messages: 

ConsoleIn
ConsoleOut
RunReply
StopRequest
StopReply
DestroyRequest
DestroyReply
CopyRequest
CopyReply
ForceStateRequest
ForceStateReply
ConsoleRequest
ConsoleReply
CreateRequest
CreateReply
StartRequest
StartReply
RebootRequest
RebootReply
InstanceIDRequest
InstanceReply
InstanceListRequest
InstanceListReply
InstanceLogRequest
InstanceLogReply
InstanceEventRequest
InstanceEventReply

Index

Constants

This section is empty.

Variables

View Source 
var ConsoleOut_Channel_name = map[int32]string{
	0: "stdout",
	1: "stderr",
}
View Source 
var ConsoleOut_Channel_value = map[string]int32{
	"stdout": 0,
	"stderr": 1,
}
View Source 
var InstanceEventReply_EventType_name = map[int32]string{
	0: "EventNone",
	1: "EventState",
}
View Source 
var InstanceEventReply_EventType_value = map[string]int32{
	"EventNone":  0,
	"EventState": 1,
}

Functions

func RegisterInstanceConsoleServer 

func RegisterInstanceConsoleServer(s *grpc.Server, srv InstanceConsoleServer)

func RegisterInstanceServer 

func RegisterInstanceServer(s *grpc.Server, srv InstanceServer)

Types

type APIServer 

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

func NewAPIServer 

func NewAPIServer(modelAddr backend.ConnectionAddress, driver sched.SchedulerDriver, ctx context.Context) *APIServer

func (*APIServer) GetMesosMasterAddr 

func (s *APIServer) GetMesosMasterAddr() *mesos.Address

func (*APIServer) GracefulStop 

func (s *APIServer) GracefulStop()

func (*APIServer) OnMasterChanged 

func (s *APIServer) OnMasterChanged(info *mesos.MasterInfo)

detector.MasterChanged interface

func (*APIServer) Serve 

func (s *APIServer) Serve(listen net.Listener) error

func (*APIServer) Stop 

func (s *APIServer) Stop()

type ConsoleIn 

type ConsoleIn struct {
	Buf        string `protobuf:"bytes,1,opt,name=buf" json:"buf,omitempty"`
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*ConsoleIn) Descriptor 

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

func (*ConsoleIn) GetBuf 

func (m *ConsoleIn) GetBuf() string

func (*ConsoleIn) GetInstanceId 

func (m *ConsoleIn) GetInstanceId() string

func (*ConsoleIn) ProtoMessage 

func (*ConsoleIn) ProtoMessage()

func (*ConsoleIn) Reset 

func (m *ConsoleIn) Reset()

func (*ConsoleIn) String 

func (m *ConsoleIn) String() string

type ConsoleOut 

type ConsoleOut struct {
	Ch  ConsoleOut_Channel `protobuf:"varint,1,opt,name=ch,enum=api.ConsoleOut_Channel" json:"ch,omitempty"`
	Buf string             `protobuf:"bytes,2,opt,name=buf" json:"buf,omitempty"`
}

func (*ConsoleOut) Descriptor 

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

func (*ConsoleOut) GetBuf 

func (m *ConsoleOut) GetBuf() string

func (*ConsoleOut) GetCh 

func (m *ConsoleOut) GetCh() ConsoleOut_Channel

func (*ConsoleOut) ProtoMessage 

func (*ConsoleOut) ProtoMessage()

func (*ConsoleOut) Reset 

func (m *ConsoleOut) Reset()

func (*ConsoleOut) String 

func (m *ConsoleOut) String() string

type ConsoleOut_Channel 

type ConsoleOut_Channel int32
const (
	ConsoleOut_stdout ConsoleOut_Channel = 0
	ConsoleOut_stderr ConsoleOut_Channel = 1
)

func (ConsoleOut_Channel) EnumDescriptor 

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

func (ConsoleOut_Channel) String 

func (x ConsoleOut_Channel) String() string

type ConsoleReply 

type ConsoleReply struct {
	InstanceId string                   `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
	Type       model1.Console_Transport `protobuf:"varint,2,opt,name=type,enum=model.Console_Transport" json:"type,omitempty"`
	Address    string                   `protobuf:"bytes,3,opt,name=address" json:"address,omitempty"`
}

func (*ConsoleReply) Descriptor 

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

func (*ConsoleReply) GetAddress 

func (m *ConsoleReply) GetAddress() string

func (*ConsoleReply) GetInstanceId 

func (m *ConsoleReply) GetInstanceId() string

func (*ConsoleReply) GetType 

func (m *ConsoleReply) GetType() model1.Console_Transport

func (*ConsoleReply) ProtoMessage 

func (*ConsoleReply) ProtoMessage()

func (*ConsoleReply) Reset 

func (m *ConsoleReply) Reset()

func (*ConsoleReply) String 

func (m *ConsoleReply) String() string

type ConsoleRequest 

type ConsoleRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*ConsoleRequest) Descriptor 

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

func (*ConsoleRequest) GetInstanceId 

func (m *ConsoleRequest) GetInstanceId() string

func (*ConsoleRequest) ProtoMessage 

func (*ConsoleRequest) ProtoMessage()

func (*ConsoleRequest) Reset 

func (m *ConsoleRequest) Reset()

func (*ConsoleRequest) String 

func (m *ConsoleRequest) String() string

type CopyReply 

type CopyReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
	Address    string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
}

func (*CopyReply) Descriptor 

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

func (*CopyReply) GetAddress 

func (m *CopyReply) GetAddress() string

func (*CopyReply) GetInstanceId 

func (m *CopyReply) GetInstanceId() string

func (*CopyReply) ProtoMessage 

func (*CopyReply) ProtoMessage()

func (*CopyReply) Reset 

func (m *CopyReply) Reset()

func (*CopyReply) String 

func (m *CopyReply) String() string

type CopyRequest 

type CopyRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*CopyRequest) Descriptor 

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

func (*CopyRequest) GetInstanceId 

func (m *CopyRequest) GetInstanceId() string

func (*CopyRequest) ProtoMessage 

func (*CopyRequest) ProtoMessage()

func (*CopyRequest) Reset 

func (m *CopyRequest) Reset()

func (*CopyRequest) String 

func (m *CopyRequest) String() string

type CreateReply 

type CreateReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*CreateReply) Descriptor 

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

func (*CreateReply) GetInstanceId 

func (m *CreateReply) GetInstanceId() string

func (*CreateReply) ProtoMessage 

func (*CreateReply) ProtoMessage()

func (*CreateReply) Reset 

func (m *CreateReply) Reset()

func (*CreateReply) String 

func (m *CreateReply) String() string

type CreateRequest 

type CreateRequest struct {
	// string resource_id = 1; // Obsolete
	Template     *model.Template `protobuf:"bytes,2,opt,name=template" json:"template,omitempty"`
	AutoRecovery bool            `protobuf:"varint,3,opt,name=auto_recovery,json=autoRecovery" json:"auto_recovery,omitempty"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetAutoRecovery 

func (m *CreateRequest) GetAutoRecovery() bool

func (*CreateRequest) GetTemplate 

func (m *CreateRequest) GetTemplate() *model.Template

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

type DestroyReply 

type DestroyReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*DestroyReply) Descriptor 

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

func (*DestroyReply) GetInstanceId 

func (m *DestroyReply) GetInstanceId() string

func (*DestroyReply) ProtoMessage 

func (*DestroyReply) ProtoMessage()

func (*DestroyReply) Reset 

func (m *DestroyReply) Reset()

func (*DestroyReply) String 

func (m *DestroyReply) String() string

type DestroyRequest 

type DestroyRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
	Force      bool   `protobuf:"varint,2,opt,name=force" json:"force,omitempty"`
}

func (*DestroyRequest) Descriptor 

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

func (*DestroyRequest) GetForce 

func (m *DestroyRequest) GetForce() bool

func (*DestroyRequest) GetInstanceId 

func (m *DestroyRequest) GetInstanceId() string

func (*DestroyRequest) ProtoMessage 

func (*DestroyRequest) ProtoMessage()

func (*DestroyRequest) Reset 

func (m *DestroyRequest) Reset()

func (*DestroyRequest) String 

func (m *DestroyRequest) String() string

type ForceStateReply 

type ForceStateReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*ForceStateReply) Descriptor 

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

func (*ForceStateReply) GetInstanceId 

func (m *ForceStateReply) GetInstanceId() string

func (*ForceStateReply) ProtoMessage 

func (*ForceStateReply) ProtoMessage()

func (*ForceStateReply) Reset 

func (m *ForceStateReply) Reset()

func (*ForceStateReply) String 

func (m *ForceStateReply) String() string

type ForceStateRequest 

type ForceStateRequest struct {
	InstanceId string                    `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
	State      model.InstanceState_State `protobuf:"varint,2,opt,name=state,enum=model.InstanceState_State" json:"state,omitempty"`
}

func (*ForceStateRequest) Descriptor 

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

func (*ForceStateRequest) GetInstanceId 

func (m *ForceStateRequest) GetInstanceId() string

func (*ForceStateRequest) GetState 

func (m *ForceStateRequest) GetState() model.InstanceState_State

func (*ForceStateRequest) ProtoMessage 

func (*ForceStateRequest) ProtoMessage()

func (*ForceStateRequest) Reset 

func (m *ForceStateRequest) Reset()

func (*ForceStateRequest) String 

func (m *ForceStateRequest) String() string

type InstanceAPI 

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

func (*InstanceAPI) Console 

func (s *InstanceAPI) Console(ctx context.Context, in *ConsoleRequest) (*ConsoleReply, error)

func (*InstanceAPI) Copy 

func (s *InstanceAPI) Copy(ctx context.Context, in *CopyRequest) (*CopyReply, error)

func (*InstanceAPI) Create 

func (s *InstanceAPI) Create(ctx context.Context, in *CreateRequest) (*CreateReply, error)

func (*InstanceAPI) Destroy 

func (s *InstanceAPI) Destroy(ctx context.Context, in *DestroyRequest) (*DestroyReply, error)

func (*InstanceAPI) Event 

func (s *InstanceAPI) Event(in *InstanceEventRequest, stream Instance_EventServer) error

func (*InstanceAPI) ForceState 

func (s *InstanceAPI) ForceState(ctx context.Context, in *ForceStateRequest) (*ForceStateReply, error)

func (*InstanceAPI) List 

func (s *InstanceAPI) List(ctx context.Context, in *InstanceListRequest) (*InstanceListReply, error)

func (*InstanceAPI) Log 

func (s *InstanceAPI) Log(in *InstanceLogRequest, stream Instance_LogServer) error

func (*InstanceAPI) Reboot 

func (s *InstanceAPI) Reboot(ctx context.Context, in *RebootRequest) (*RebootReply, error)

func (*InstanceAPI) Run 

func (s *InstanceAPI) Run(ctx context.Context, in *CreateRequest) (*RunReply, error)

func (*InstanceAPI) Show 

func (s *InstanceAPI) Show(ctx context.Context, in *InstanceIDRequest) (*InstanceReply, error)

func (*InstanceAPI) Start 

func (s *InstanceAPI) Start(ctx context.Context, in *StartRequest) (*StartReply, error)

func (*InstanceAPI) Stop 

func (s *InstanceAPI) Stop(ctx context.Context, in *StopRequest) (*StopReply, error)

type InstanceClient 

type InstanceClient interface {
	Copy(ctx context.Context, in *CopyRequest, opts ...grpc.CallOption) (*CopyReply, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateReply, error)
	ForceState(ctx context.Context, in *ForceStateRequest, opts ...grpc.CallOption) (*ForceStateReply, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartReply, error)
	Run(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*RunReply, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopReply, error)
	Destroy(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*DestroyReply, error)
	Reboot(ctx context.Context, in *RebootRequest, opts ...grpc.CallOption) (*RebootReply, error)
	Console(ctx context.Context, in *ConsoleRequest, opts ...grpc.CallOption) (*ConsoleReply, error)
	Show(ctx context.Context, in *InstanceIDRequest, opts ...grpc.CallOption) (*InstanceReply, error)
	List(ctx context.Context, in *InstanceListRequest, opts ...grpc.CallOption) (*InstanceListReply, error)
	Log(ctx context.Context, in *InstanceLogRequest, opts ...grpc.CallOption) (Instance_LogClient, error)
	Event(ctx context.Context, in *InstanceEventRequest, opts ...grpc.CallOption) (Instance_EventClient, error)
}

func NewInstanceClient 

func NewInstanceClient(cc *grpc.ClientConn) InstanceClient

type InstanceConsoleAPI 

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

func (*InstanceConsoleAPI) Attach 

func (i *InstanceConsoleAPI) Attach(stream InstanceConsole_AttachServer) error

type InstanceConsoleClient 

type InstanceConsoleClient interface {
	Attach(ctx context.Context, opts ...grpc.CallOption) (InstanceConsole_AttachClient, error)
}

func NewInstanceConsoleClient 

func NewInstanceConsoleClient(cc *grpc.ClientConn) InstanceConsoleClient

type InstanceConsoleServer 

type InstanceConsoleServer interface {
	Attach(InstanceConsole_AttachServer) error
}

type InstanceConsole_AttachClient 

type InstanceConsole_AttachClient interface {
	Send(*ConsoleIn) error
	Recv() (*ConsoleOut, error)
	grpc.ClientStream
}

type InstanceConsole_AttachServer 

type InstanceConsole_AttachServer interface {
	Send(*ConsoleOut) error
	Recv() (*ConsoleIn, error)
	grpc.ServerStream
}

type InstanceEventReply 

type InstanceEventReply struct {
	EventType InstanceEventReply_EventType `protobuf:"varint,1,opt,name=event_type,enum=api.InstanceEventReply_EventType" json:"event_type,omitempty"`
	EventAt   *google_protobuf.Timestamp   `protobuf:"bytes,2,opt,name=event_at" json:"event_at,omitempty"`
	// Types that are valid to be assigned to Body:
	//	*InstanceEventReply_State
	Body isInstanceEventReply_Body `protobuf_oneof:"Body"`
}

func (*InstanceEventReply) Descriptor 

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

func (*InstanceEventReply) GetBody 

func (m *InstanceEventReply) GetBody() isInstanceEventReply_Body

func (*InstanceEventReply) GetEventAt 

func (m *InstanceEventReply) GetEventAt() *google_protobuf.Timestamp

func (*InstanceEventReply) GetEventType 

func (m *InstanceEventReply) GetEventType() InstanceEventReply_EventType

func (*InstanceEventReply) GetState 

func (m *InstanceEventReply) GetState() *model.InstanceState

func (*InstanceEventReply) ProtoMessage 

func (*InstanceEventReply) ProtoMessage()

func (*InstanceEventReply) Reset 

func (m *InstanceEventReply) Reset()

func (*InstanceEventReply) String 

func (m *InstanceEventReply) String() string

func (*InstanceEventReply) XXX_OneofFuncs 

func (*InstanceEventReply) 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 InstanceEventReply_EventType 

type InstanceEventReply_EventType int32
const (
	InstanceEventReply_EventNone  InstanceEventReply_EventType = 0
	InstanceEventReply_EventState InstanceEventReply_EventType = 1
)

func (InstanceEventReply_EventType) EnumDescriptor 

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

func (InstanceEventReply_EventType) String 

func (x InstanceEventReply_EventType) String() string

type InstanceEventReply_State 

type InstanceEventReply_State struct {
	State *model.InstanceState `protobuf:"bytes,3,opt,name=state,oneof"`
}

type InstanceEventRequest 

type InstanceEventRequest struct {
	Target *InstanceIDRequest `protobuf:"bytes,1,opt,name=Target" json:"Target,omitempty"`
}

func (*InstanceEventRequest) Descriptor 

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

func (*InstanceEventRequest) GetTarget 

func (m *InstanceEventRequest) GetTarget() *InstanceIDRequest

func (*InstanceEventRequest) ProtoMessage 

func (*InstanceEventRequest) ProtoMessage()

func (*InstanceEventRequest) Reset 

func (m *InstanceEventRequest) Reset()

func (*InstanceEventRequest) String 

func (m *InstanceEventRequest) String() string

type InstanceIDRequest 

type InstanceIDRequest struct {
	// Types that are valid to be assigned to Key:
	//	*InstanceIDRequest_ID
	//	*InstanceIDRequest_Name
	Key isInstanceIDRequest_Key `protobuf_oneof:"Key"`
}

func (*InstanceIDRequest) Descriptor 

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

func (*InstanceIDRequest) GetID 

func (m *InstanceIDRequest) GetID() string

func (*InstanceIDRequest) GetKey 

func (m *InstanceIDRequest) GetKey() isInstanceIDRequest_Key

func (*InstanceIDRequest) GetName 

func (m *InstanceIDRequest) GetName() string

func (*InstanceIDRequest) ProtoMessage 

func (*InstanceIDRequest) ProtoMessage()

func (*InstanceIDRequest) Reset 

func (m *InstanceIDRequest) Reset()

func (*InstanceIDRequest) String 

func (m *InstanceIDRequest) String() string

func (*InstanceIDRequest) XXX_OneofFuncs 

func (*InstanceIDRequest) 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 InstanceIDRequest_ID 

type InstanceIDRequest_ID struct {
	ID string `protobuf:"bytes,1,opt,name=ID,oneof"`
}

type InstanceIDRequest_Name 

type InstanceIDRequest_Name struct {
	Name string `protobuf:"bytes,2,opt,name=Name,oneof"`
}

type InstanceListReply 

type InstanceListReply struct {
	Page  *InstanceListReply_PageReply          `protobuf:"bytes,1,opt,name=page" json:"page,omitempty"`
	Items []*InstanceListReply_InstanceListItem `protobuf:"bytes,2,rep,name=items" json:"items,omitempty"`
}

func (*InstanceListReply) Descriptor 

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

func (*InstanceListReply) GetItems 

func (m *InstanceListReply) GetItems() []*InstanceListReply_InstanceListItem

func (*InstanceListReply) GetPage 

func (m *InstanceListReply) GetPage() *InstanceListReply_PageReply

func (*InstanceListReply) ProtoMessage 

func (*InstanceListReply) ProtoMessage()

func (*InstanceListReply) Reset 

func (m *InstanceListReply) Reset()

func (*InstanceListReply) String 

func (m *InstanceListReply) String() string

type InstanceListReply_InstanceListItem 

type InstanceListReply_InstanceListItem struct {
	Id    string                    `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	State model.InstanceState_State `protobuf:"varint,2,opt,name=state,enum=model.InstanceState_State" json:"state,omitempty"`
}

func (*InstanceListReply_InstanceListItem) Descriptor 

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

func (*InstanceListReply_InstanceListItem) GetId 

func (m *InstanceListReply_InstanceListItem) GetId() string

func (*InstanceListReply_InstanceListItem) GetState 

func (m *InstanceListReply_InstanceListItem) GetState() model.InstanceState_State

func (*InstanceListReply_InstanceListItem) ProtoMessage 

func (*InstanceListReply_InstanceListItem) ProtoMessage()

func (*InstanceListReply_InstanceListItem) Reset 

func (m *InstanceListReply_InstanceListItem) Reset()

func (*InstanceListReply_InstanceListItem) String 

func (m *InstanceListReply_InstanceListItem) String() string

type InstanceListReply_PageReply 

type InstanceListReply_PageReply struct {
	Total   int32 `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
	Current int32 `protobuf:"varint,2,opt,name=current" json:"current,omitempty"`
	Limit   int32 `protobuf:"varint,3,opt,name=limit" json:"limit,omitempty"`
}

func (*InstanceListReply_PageReply) Descriptor 

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

func (*InstanceListReply_PageReply) GetCurrent 

func (m *InstanceListReply_PageReply) GetCurrent() int32

func (*InstanceListReply_PageReply) GetLimit 

func (m *InstanceListReply_PageReply) GetLimit() int32

func (*InstanceListReply_PageReply) GetTotal 

func (m *InstanceListReply_PageReply) GetTotal() int32

func (*InstanceListReply_PageReply) ProtoMessage 

func (*InstanceListReply_PageReply) ProtoMessage()

func (*InstanceListReply_PageReply) Reset 

func (m *InstanceListReply_PageReply) Reset()

func (*InstanceListReply_PageReply) String 

func (m *InstanceListReply_PageReply) String() string

type InstanceListRequest 

type InstanceListRequest struct {
	Page   *InstanceListRequest_PageRequest `protobuf:"bytes,1,opt,name=page" json:"page,omitempty"`
	Filter *InstanceListRequest_Filter      `protobuf:"bytes,2,opt,name=filter" json:"filter,omitempty"`
}

func (*InstanceListRequest) Descriptor 

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

func (*InstanceListRequest) GetFilter 

func (m *InstanceListRequest) GetFilter() *InstanceListRequest_Filter

func (*InstanceListRequest) GetPage 

func (m *InstanceListRequest) GetPage() *InstanceListRequest_PageRequest

func (*InstanceListRequest) ProtoMessage 

func (*InstanceListRequest) ProtoMessage()

func (*InstanceListRequest) Reset 

func (m *InstanceListRequest) Reset()

func (*InstanceListRequest) String 

func (m *InstanceListRequest) String() string

type InstanceListRequest_Filter 

type InstanceListRequest_Filter struct {
	State model.InstanceState_State `protobuf:"varint,1,opt,name=state,enum=model.InstanceState_State" json:"state,omitempty"`
}

func (*InstanceListRequest_Filter) Descriptor 

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

func (*InstanceListRequest_Filter) GetState 

func (m *InstanceListRequest_Filter) GetState() model.InstanceState_State

func (*InstanceListRequest_Filter) ProtoMessage 

func (*InstanceListRequest_Filter) ProtoMessage()

func (*InstanceListRequest_Filter) Reset 

func (m *InstanceListRequest_Filter) Reset()

func (*InstanceListRequest_Filter) String 

func (m *InstanceListRequest_Filter) String() string

type InstanceListRequest_PageRequest 

type InstanceListRequest_PageRequest struct {
	Offset int32 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
	Limit  int32 `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
}

func (*InstanceListRequest_PageRequest) Descriptor 

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

func (*InstanceListRequest_PageRequest) GetLimit 

func (m *InstanceListRequest_PageRequest) GetLimit() int32

func (*InstanceListRequest_PageRequest) GetOffset 

func (m *InstanceListRequest_PageRequest) GetOffset() int32

func (*InstanceListRequest_PageRequest) ProtoMessage 

func (*InstanceListRequest_PageRequest) ProtoMessage()

func (*InstanceListRequest_PageRequest) Reset 

func (m *InstanceListRequest_PageRequest) Reset()

func (*InstanceListRequest_PageRequest) String 

func (m *InstanceListRequest_PageRequest) String() string

type InstanceLogReply 

type InstanceLogReply struct {
	Line []string `protobuf:"bytes,1,rep,name=Line" json:"Line,omitempty"`
}

func (*InstanceLogReply) Descriptor 

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

func (*InstanceLogReply) GetLine 

func (m *InstanceLogReply) GetLine() []string

func (*InstanceLogReply) ProtoMessage 

func (*InstanceLogReply) ProtoMessage()

func (*InstanceLogReply) Reset 

func (m *InstanceLogReply) Reset()

func (*InstanceLogReply) String 

func (m *InstanceLogReply) String() string

type InstanceLogRequest 

type InstanceLogRequest struct {
	Target *InstanceIDRequest `protobuf:"bytes,1,opt,name=Target" json:"Target,omitempty"`
}

func (*InstanceLogRequest) Descriptor 

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

func (*InstanceLogRequest) GetTarget 

func (m *InstanceLogRequest) GetTarget() *InstanceIDRequest

func (*InstanceLogRequest) ProtoMessage 

func (*InstanceLogRequest) ProtoMessage()

func (*InstanceLogRequest) Reset 

func (m *InstanceLogRequest) Reset()

func (*InstanceLogRequest) String 

func (m *InstanceLogRequest) String() string

type InstanceReply 

type InstanceReply struct {
	ID       string          `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	Instance *model.Instance `protobuf:"bytes,2,opt,name=instance" json:"instance,omitempty"`
}

func (*InstanceReply) Descriptor 

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

func (*InstanceReply) GetID 

func (m *InstanceReply) GetID() string

func (*InstanceReply) GetInstance 

func (m *InstanceReply) GetInstance() *model.Instance

func (*InstanceReply) ProtoMessage 

func (*InstanceReply) ProtoMessage()

func (*InstanceReply) Reset 

func (m *InstanceReply) Reset()

func (*InstanceReply) String 

func (m *InstanceReply) String() string

type InstanceServer 

type InstanceServer interface {
	Copy(context.Context, *CopyRequest) (*CopyReply, error)
	Create(context.Context, *CreateRequest) (*CreateReply, error)
	ForceState(context.Context, *ForceStateRequest) (*ForceStateReply, error)
	Start(context.Context, *StartRequest) (*StartReply, error)
	Run(context.Context, *CreateRequest) (*RunReply, error)
	Stop(context.Context, *StopRequest) (*StopReply, error)
	Destroy(context.Context, *DestroyRequest) (*DestroyReply, error)
	Reboot(context.Context, *RebootRequest) (*RebootReply, error)
	Console(context.Context, *ConsoleRequest) (*ConsoleReply, error)
	Show(context.Context, *InstanceIDRequest) (*InstanceReply, error)
	List(context.Context, *InstanceListRequest) (*InstanceListReply, error)
	Log(*InstanceLogRequest, Instance_LogServer) error
	Event(*InstanceEventRequest, Instance_EventServer) error
}

type Instance_EventClient 

type Instance_EventClient interface {
	Recv() (*InstanceEventReply, error)
	grpc.ClientStream
}

type Instance_EventServer 

type Instance_EventServer interface {
	Send(*InstanceEventReply) error
	grpc.ServerStream
}

type Instance_LogClient 

type Instance_LogClient interface {
	Recv() (*InstanceLogReply, error)
	grpc.ClientStream
}

type Instance_LogServer 

type Instance_LogServer interface {
	Send(*InstanceLogReply) error
	grpc.ServerStream
}

type RebootReply 

type RebootReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*RebootReply) Descriptor 

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

func (*RebootReply) GetInstanceId 

func (m *RebootReply) GetInstanceId() string

func (*RebootReply) ProtoMessage 

func (*RebootReply) ProtoMessage()

func (*RebootReply) Reset 

func (m *RebootReply) Reset()

func (*RebootReply) String 

func (m *RebootReply) String() string

type RebootRequest 

type RebootRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*RebootRequest) Descriptor 

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

func (*RebootRequest) GetInstanceId 

func (m *RebootRequest) GetInstanceId() string

func (*RebootRequest) ProtoMessage 

func (*RebootRequest) ProtoMessage()

func (*RebootRequest) Reset 

func (m *RebootRequest) Reset()

func (*RebootRequest) String 

func (m *RebootRequest) String() string

type RunReply 

type RunReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*RunReply) Descriptor 

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

func (*RunReply) GetInstanceId 

func (m *RunReply) GetInstanceId() string

func (*RunReply) ProtoMessage 

func (*RunReply) ProtoMessage()

func (*RunReply) Reset 

func (m *RunReply) Reset()

func (*RunReply) String 

func (m *RunReply) String() string

type StartReply 

type StartReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*StartReply) Descriptor 

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

func (*StartReply) GetInstanceId 

func (m *StartReply) GetInstanceId() string

func (*StartReply) ProtoMessage 

func (*StartReply) ProtoMessage()

func (*StartReply) Reset 

func (m *StartReply) Reset()

func (*StartReply) String 

func (m *StartReply) String() string

type StartRequest 

type StartRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*StartRequest) Descriptor 

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

func (*StartRequest) GetInstanceId 

func (m *StartRequest) GetInstanceId() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

type StopReply 

type StopReply struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*StopReply) Descriptor 

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

func (*StopReply) GetInstanceId 

func (m *StopReply) GetInstanceId() string

func (*StopReply) ProtoMessage 

func (*StopReply) ProtoMessage()

func (*StopReply) Reset 

func (m *StopReply) Reset()

func (*StopReply) String 

func (m *StopReply) String() string

type StopRequest 

type StopRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id" json:"instance_id,omitempty"`
}

func (*StopRequest) Descriptor 

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

func (*StopRequest) GetInstanceId 

func (m *StopRequest) GetInstanceId() string

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

Source Files

View all Source files

Directories

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

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.