machine

package
v0.3.0-alpha.3 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2019 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMachineServer 

func RegisterMachineServer(s *grpc.Server, srv MachineServer)

Types

type CopyOutRequest 

type CopyOutRequest struct {
	// Root path to start copying data out, it might be either a file or directory
	RootPath             string   `protobuf:"bytes,1,opt,name=root_path,json=rootPath,proto3" json:"root_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CopyOutRequest describes a request to copy data out of Talos node

CopyOut produces .tar.gz archive which is streamed back to the caller

func (*CopyOutRequest) Descriptor 

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

func (*CopyOutRequest) GetRootPath 

func (m *CopyOutRequest) GetRootPath() string

func (*CopyOutRequest) ProtoMessage 

func (*CopyOutRequest) ProtoMessage()

func (*CopyOutRequest) Reset 

func (m *CopyOutRequest) Reset()

func (*CopyOutRequest) String 

func (m *CopyOutRequest) String() string

func (*CopyOutRequest) XXX_DiscardUnknown 

func (m *CopyOutRequest) XXX_DiscardUnknown()

func (*CopyOutRequest) XXX_Marshal 

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

func (*CopyOutRequest) XXX_Merge 

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

func (*CopyOutRequest) XXX_Size 

func (m *CopyOutRequest) XXX_Size() int

func (*CopyOutRequest) XXX_Unmarshal 

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

type FileInfo 

type FileInfo struct {
	// Name is the name (including prefixed path) of the file or directory
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Size indicates the number of bytes contained within the file
	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// Mode is the bitmap of UNIX mode/permission flags of the file
	Mode uint32 `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// Modified indicates the UNIX timestamp at which the file was last modified
	Modified int64 `protobuf:"varint,4,opt,name=modified,proto3" json:"modified,omitempty"`
	// IsDir indicates that the file is a directory
	IsDir bool `protobuf:"varint,5,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// Error describes any error encountered while trying to read the file
	// information.
	Error string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// Link is filled with symlink target
	Link string `protobuf:"bytes,7,opt,name=link,proto3" json:"link,omitempty"`
	// RelativeName is the name of the file or directory relative to the RootPath
	RelativeName         string   `protobuf:"bytes,8,opt,name=relative_name,json=relativeName,proto3" json:"relative_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FileInfo describes a file or directory's information

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetError 

func (m *FileInfo) GetError() string

func (*FileInfo) GetIsDir 

func (m *FileInfo) GetIsDir() bool
func (m *FileInfo) GetLink() string

func (*FileInfo) GetMode 

func (m *FileInfo) GetMode() uint32

func (*FileInfo) GetModified 

func (m *FileInfo) GetModified() int64

func (*FileInfo) GetName 

func (m *FileInfo) GetName() string

func (*FileInfo) GetRelativeName 

func (m *FileInfo) GetRelativeName() string

func (*FileInfo) GetSize 

func (m *FileInfo) GetSize() int64

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) String 

func (m *FileInfo) String() string

func (*FileInfo) XXX_DiscardUnknown 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal 

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

func (*FileInfo) XXX_Merge 

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

func (*FileInfo) XXX_Size 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal 

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

type LSRequest 

type LSRequest struct {
	// Root indicates the root directory for the list.  If not indicated, '/' is
	// presumed.
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// Recurse indicates that subdirectories should be recursed.
	Recurse bool `protobuf:"varint,2,opt,name=recurse,proto3" json:"recurse,omitempty"`
	// RecursionDepth indicates how many levels of subdirectories should be
	// recursed.  The default (0) indicates that no limit should be enforced.
	RecursionDepth       int32    `protobuf:"varint,3,opt,name=recursion_depth,json=recursionDepth,proto3" json:"recursion_depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LSRequest describes a request to list the contents of a directory

func (*LSRequest) Descriptor 

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

func (*LSRequest) GetRecurse 

func (m *LSRequest) GetRecurse() bool

func (*LSRequest) GetRecursionDepth 

func (m *LSRequest) GetRecursionDepth() int32

func (*LSRequest) GetRoot 

func (m *LSRequest) GetRoot() string

func (*LSRequest) ProtoMessage 

func (*LSRequest) ProtoMessage()

func (*LSRequest) Reset 

func (m *LSRequest) Reset()

func (*LSRequest) String 

func (m *LSRequest) String() string

func (*LSRequest) XXX_DiscardUnknown 

func (m *LSRequest) XXX_DiscardUnknown()

func (*LSRequest) XXX_Marshal 

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

func (*LSRequest) XXX_Merge 

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

func (*LSRequest) XXX_Size 

func (m *LSRequest) XXX_Size() int

func (*LSRequest) XXX_Unmarshal 

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

type MachineClient 

type MachineClient interface {
	CopyOut(ctx context.Context, in *CopyOutRequest, opts ...grpc.CallOption) (Machine_CopyOutClient, error)
	Mounts(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*MountsReply, error)
	LS(ctx context.Context, in *LSRequest, opts ...grpc.CallOption) (Machine_LSClient, error)
	Reboot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RebootReply, error)
	Reset(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ResetReply, error)
	Shutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ShutdownReply, error)
	Upgrade(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (*UpgradeReply, error)
	ServiceList(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ServiceListReply, error)
	ServiceStart(ctx context.Context, in *ServiceStartRequest, opts ...grpc.CallOption) (*ServiceStartReply, error)
	ServiceStop(ctx context.Context, in *ServiceStopRequest, opts ...grpc.CallOption) (*ServiceStopReply, error)
	ServiceRestart(ctx context.Context, in *ServiceRestartRequest, opts ...grpc.CallOption) (*ServiceRestartReply, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartReply, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopReply, error)
	Version(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VersionReply, error)
}

MachineClient is the client API for Machine service.

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

func NewMachineClient 

func NewMachineClient(cc *grpc.ClientConn) MachineClient

type MachineServer 

type MachineServer interface {
	CopyOut(*CopyOutRequest, Machine_CopyOutServer) error
	Mounts(context.Context, *empty.Empty) (*MountsReply, error)
	LS(*LSRequest, Machine_LSServer) error
	Reboot(context.Context, *empty.Empty) (*RebootReply, error)
	Reset(context.Context, *empty.Empty) (*ResetReply, error)
	Shutdown(context.Context, *empty.Empty) (*ShutdownReply, error)
	Upgrade(context.Context, *UpgradeRequest) (*UpgradeReply, error)
	ServiceList(context.Context, *empty.Empty) (*ServiceListReply, error)
	ServiceStart(context.Context, *ServiceStartRequest) (*ServiceStartReply, error)
	ServiceStop(context.Context, *ServiceStopRequest) (*ServiceStopReply, error)
	ServiceRestart(context.Context, *ServiceRestartRequest) (*ServiceRestartReply, error)
	Start(context.Context, *StartRequest) (*StartReply, error)
	Stop(context.Context, *StopRequest) (*StopReply, error)
	Version(context.Context, *empty.Empty) (*VersionReply, error)
}

MachineServer is the server API for Machine service.

type Machine_CopyOutClient 

type Machine_CopyOutClient interface {
	Recv() (*StreamingData, error)
	grpc.ClientStream
}

type Machine_CopyOutServer 

type Machine_CopyOutServer interface {
	Send(*StreamingData) error
	grpc.ServerStream
}

type Machine_LSClient 

type Machine_LSClient interface {
	Recv() (*FileInfo, error)
	grpc.ClientStream
}

type Machine_LSServer 

type Machine_LSServer interface {
	Send(*FileInfo) error
	grpc.ServerStream
}

type MountStat 

type MountStat struct {
	Filesystem           string   `protobuf:"bytes,1,opt,name=filesystem,proto3" json:"filesystem,omitempty"`
	Size                 uint64   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Available            uint64   `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
	MountedOn            string   `protobuf:"bytes,4,opt,name=mounted_on,json=mountedOn,proto3" json:"mounted_on,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the requested processes.

func (*MountStat) Descriptor 

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

func (*MountStat) GetAvailable 

func (m *MountStat) GetAvailable() uint64

func (*MountStat) GetFilesystem 

func (m *MountStat) GetFilesystem() string

func (*MountStat) GetMountedOn 

func (m *MountStat) GetMountedOn() string

func (*MountStat) GetSize 

func (m *MountStat) GetSize() uint64

func (*MountStat) ProtoMessage 

func (*MountStat) ProtoMessage()

func (*MountStat) Reset 

func (m *MountStat) Reset()

func (*MountStat) String 

func (m *MountStat) String() string

func (*MountStat) XXX_DiscardUnknown 

func (m *MountStat) XXX_DiscardUnknown()

func (*MountStat) XXX_Marshal 

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

func (*MountStat) XXX_Merge 

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

func (*MountStat) XXX_Size 

func (m *MountStat) XXX_Size() int

func (*MountStat) XXX_Unmarshal 

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

type MountsReply 

type MountsReply struct {
	Response             []*MountsResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MountsReply) Descriptor 

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

func (*MountsReply) GetResponse 

func (m *MountsReply) GetResponse() []*MountsResponse

func (*MountsReply) ProtoMessage 

func (*MountsReply) ProtoMessage()

func (*MountsReply) Reset 

func (m *MountsReply) Reset()

func (*MountsReply) String 

func (m *MountsReply) String() string

func (*MountsReply) XXX_DiscardUnknown 

func (m *MountsReply) XXX_DiscardUnknown()

func (*MountsReply) XXX_Marshal 

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

func (*MountsReply) XXX_Merge 

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

func (*MountsReply) XXX_Size 

func (m *MountsReply) XXX_Size() int

func (*MountsReply) XXX_Unmarshal 

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

type MountsResponse 

type MountsResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Stats                []*MountStat         `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The response message containing the requested df stats.

func (*MountsResponse) Descriptor 

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

func (*MountsResponse) GetMetadata 

func (m *MountsResponse) GetMetadata() *common.NodeMetadata

func (*MountsResponse) GetStats 

func (m *MountsResponse) GetStats() []*MountStat

func (*MountsResponse) ProtoMessage 

func (*MountsResponse) ProtoMessage()

func (*MountsResponse) Reset 

func (m *MountsResponse) Reset()

func (*MountsResponse) String 

func (m *MountsResponse) String() string

func (*MountsResponse) XXX_DiscardUnknown 

func (m *MountsResponse) XXX_DiscardUnknown()

func (*MountsResponse) XXX_Marshal 

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

func (*MountsResponse) XXX_Merge 

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

func (*MountsResponse) XXX_Size 

func (m *MountsResponse) XXX_Size() int

func (*MountsResponse) XXX_Unmarshal 

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

type RebootReply 

type RebootReply struct {
	Response             []*RebootResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RebootReply) Descriptor 

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

func (*RebootReply) GetResponse 

func (m *RebootReply) GetResponse() []*RebootResponse

func (*RebootReply) ProtoMessage 

func (*RebootReply) ProtoMessage()

func (*RebootReply) Reset 

func (m *RebootReply) Reset()

func (*RebootReply) String 

func (m *RebootReply) String() string

func (*RebootReply) XXX_DiscardUnknown 

func (m *RebootReply) XXX_DiscardUnknown()

func (*RebootReply) XXX_Marshal 

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

func (*RebootReply) XXX_Merge 

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

func (*RebootReply) XXX_Size 

func (m *RebootReply) XXX_Size() int

func (*RebootReply) XXX_Unmarshal 

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

type RebootResponse 

type RebootResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

rpc reboot The response message containing the reboot status.

func (*RebootResponse) Descriptor 

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

func (*RebootResponse) GetMetadata 

func (m *RebootResponse) GetMetadata() *common.NodeMetadata

func (*RebootResponse) ProtoMessage 

func (*RebootResponse) ProtoMessage()

func (*RebootResponse) Reset 

func (m *RebootResponse) Reset()

func (*RebootResponse) String 

func (m *RebootResponse) String() string

func (*RebootResponse) XXX_DiscardUnknown 

func (m *RebootResponse) XXX_DiscardUnknown()

func (*RebootResponse) XXX_Marshal 

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

func (*RebootResponse) XXX_Merge 

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

func (*RebootResponse) XXX_Size 

func (m *RebootResponse) XXX_Size() int

func (*RebootResponse) XXX_Unmarshal 

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

type ResetReply 

type ResetReply struct {
	Response             []*ResetResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ResetReply) Descriptor 

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

func (*ResetReply) GetResponse 

func (m *ResetReply) GetResponse() []*ResetResponse

func (*ResetReply) ProtoMessage 

func (*ResetReply) ProtoMessage()

func (*ResetReply) Reset 

func (m *ResetReply) Reset()

func (*ResetReply) String 

func (m *ResetReply) String() string

func (*ResetReply) XXX_DiscardUnknown 

func (m *ResetReply) XXX_DiscardUnknown()

func (*ResetReply) XXX_Marshal 

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

func (*ResetReply) XXX_Merge 

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

func (*ResetReply) XXX_Size 

func (m *ResetReply) XXX_Size() int

func (*ResetReply) XXX_Unmarshal 

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

type ResetResponse 

type ResetResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

rpc reset The response message containing the restart status.

func (*ResetResponse) Descriptor 

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

func (*ResetResponse) GetMetadata 

func (m *ResetResponse) GetMetadata() *common.NodeMetadata

func (*ResetResponse) ProtoMessage 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) Reset 

func (m *ResetResponse) Reset()

func (*ResetResponse) String 

func (m *ResetResponse) String() string

func (*ResetResponse) XXX_DiscardUnknown 

func (m *ResetResponse) XXX_DiscardUnknown()

func (*ResetResponse) XXX_Marshal 

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

func (*ResetResponse) XXX_Merge 

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

func (*ResetResponse) XXX_Size 

func (m *ResetResponse) XXX_Size() int

func (*ResetResponse) XXX_Unmarshal 

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

type ServiceEvent 

type ServiceEvent struct {
	Msg                  string               `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	State                string               `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ServiceEvent) Descriptor 

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

func (*ServiceEvent) GetMsg 

func (m *ServiceEvent) GetMsg() string

func (*ServiceEvent) GetState 

func (m *ServiceEvent) GetState() string

func (*ServiceEvent) GetTs 

func (m *ServiceEvent) GetTs() *timestamp.Timestamp

func (*ServiceEvent) ProtoMessage 

func (*ServiceEvent) ProtoMessage()

func (*ServiceEvent) Reset 

func (m *ServiceEvent) Reset()

func (*ServiceEvent) String 

func (m *ServiceEvent) String() string

func (*ServiceEvent) XXX_DiscardUnknown 

func (m *ServiceEvent) XXX_DiscardUnknown()

func (*ServiceEvent) XXX_Marshal 

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

func (*ServiceEvent) XXX_Merge 

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

func (*ServiceEvent) XXX_Size 

func (m *ServiceEvent) XXX_Size() int

func (*ServiceEvent) XXX_Unmarshal 

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

type ServiceEvents 

type ServiceEvents struct {
	Events               []*ServiceEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ServiceEvents) Descriptor 

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

func (*ServiceEvents) GetEvents 

func (m *ServiceEvents) GetEvents() []*ServiceEvent

func (*ServiceEvents) ProtoMessage 

func (*ServiceEvents) ProtoMessage()

func (*ServiceEvents) Reset 

func (m *ServiceEvents) Reset()

func (*ServiceEvents) String 

func (m *ServiceEvents) String() string

func (*ServiceEvents) XXX_DiscardUnknown 

func (m *ServiceEvents) XXX_DiscardUnknown()

func (*ServiceEvents) XXX_Marshal 

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

func (*ServiceEvents) XXX_Merge 

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

func (*ServiceEvents) XXX_Size 

func (m *ServiceEvents) XXX_Size() int

func (*ServiceEvents) XXX_Unmarshal 

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

type ServiceHealth 

type ServiceHealth struct {
	Unknown              bool                 `protobuf:"varint,1,opt,name=unknown,proto3" json:"unknown,omitempty"`
	Healthy              bool                 `protobuf:"varint,2,opt,name=healthy,proto3" json:"healthy,omitempty"`
	LastMessage          string               `protobuf:"bytes,3,opt,name=last_message,json=lastMessage,proto3" json:"last_message,omitempty"`
	LastChange           *timestamp.Timestamp `protobuf:"bytes,4,opt,name=last_change,json=lastChange,proto3" json:"last_change,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ServiceHealth) Descriptor 

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

func (*ServiceHealth) GetHealthy 

func (m *ServiceHealth) GetHealthy() bool

func (*ServiceHealth) GetLastChange 

func (m *ServiceHealth) GetLastChange() *timestamp.Timestamp

func (*ServiceHealth) GetLastMessage 

func (m *ServiceHealth) GetLastMessage() string

func (*ServiceHealth) GetUnknown 

func (m *ServiceHealth) GetUnknown() bool

func (*ServiceHealth) ProtoMessage 

func (*ServiceHealth) ProtoMessage()

func (*ServiceHealth) Reset 

func (m *ServiceHealth) Reset()

func (*ServiceHealth) String 

func (m *ServiceHealth) String() string

func (*ServiceHealth) XXX_DiscardUnknown 

func (m *ServiceHealth) XXX_DiscardUnknown()

func (*ServiceHealth) XXX_Marshal 

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

func (*ServiceHealth) XXX_Merge 

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

func (*ServiceHealth) XXX_Size 

func (m *ServiceHealth) XXX_Size() int

func (*ServiceHealth) XXX_Unmarshal 

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

type ServiceInfo 

type ServiceInfo struct {
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                string         `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Events               *ServiceEvents `protobuf:"bytes,3,opt,name=events,proto3" json:"events,omitempty"`
	Health               *ServiceHealth `protobuf:"bytes,4,opt,name=health,proto3" json:"health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ServiceInfo) Descriptor 

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

func (*ServiceInfo) GetEvents 

func (m *ServiceInfo) GetEvents() *ServiceEvents

func (*ServiceInfo) GetHealth 

func (m *ServiceInfo) GetHealth() *ServiceHealth

func (*ServiceInfo) GetId 

func (m *ServiceInfo) GetId() string

func (*ServiceInfo) GetState 

func (m *ServiceInfo) GetState() string

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset 

func (m *ServiceInfo) Reset()

func (*ServiceInfo) String 

func (m *ServiceInfo) String() string

func (*ServiceInfo) XXX_DiscardUnknown 

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal 

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

func (*ServiceInfo) XXX_Merge 

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

func (*ServiceInfo) XXX_Size 

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal 

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

type ServiceListReply 

type ServiceListReply struct {
	Response             []*ServiceListResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ServiceListReply) Descriptor 

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

func (*ServiceListReply) GetResponse 

func (m *ServiceListReply) GetResponse() []*ServiceListResponse

func (*ServiceListReply) ProtoMessage 

func (*ServiceListReply) ProtoMessage()

func (*ServiceListReply) Reset 

func (m *ServiceListReply) Reset()

func (*ServiceListReply) String 

func (m *ServiceListReply) String() string

func (*ServiceListReply) XXX_DiscardUnknown 

func (m *ServiceListReply) XXX_DiscardUnknown()

func (*ServiceListReply) XXX_Marshal 

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

func (*ServiceListReply) XXX_Merge 

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

func (*ServiceListReply) XXX_Size 

func (m *ServiceListReply) XXX_Size() int

func (*ServiceListReply) XXX_Unmarshal 

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

type ServiceListResponse 

type ServiceListResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Services             []*ServiceInfo       `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

rpc servicelist

func (*ServiceListResponse) Descriptor 

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

func (*ServiceListResponse) GetMetadata 

func (m *ServiceListResponse) GetMetadata() *common.NodeMetadata

func (*ServiceListResponse) GetServices 

func (m *ServiceListResponse) GetServices() []*ServiceInfo

func (*ServiceListResponse) ProtoMessage 

func (*ServiceListResponse) ProtoMessage()

func (*ServiceListResponse) Reset 

func (m *ServiceListResponse) Reset()

func (*ServiceListResponse) String 

func (m *ServiceListResponse) String() string

func (*ServiceListResponse) XXX_DiscardUnknown 

func (m *ServiceListResponse) XXX_DiscardUnknown()

func (*ServiceListResponse) XXX_Marshal 

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

func (*ServiceListResponse) XXX_Merge 

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

func (*ServiceListResponse) XXX_Size 

func (m *ServiceListResponse) XXX_Size() int

func (*ServiceListResponse) XXX_Unmarshal 

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

type ServiceRestartReply 

type ServiceRestartReply struct {
	Response             []*ServiceRestartResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ServiceRestartReply) Descriptor 

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

func (*ServiceRestartReply) GetResponse 

func (m *ServiceRestartReply) GetResponse() []*ServiceRestartResponse

func (*ServiceRestartReply) ProtoMessage 

func (*ServiceRestartReply) ProtoMessage()

func (*ServiceRestartReply) Reset 

func (m *ServiceRestartReply) Reset()

func (*ServiceRestartReply) String 

func (m *ServiceRestartReply) String() string

func (*ServiceRestartReply) XXX_DiscardUnknown 

func (m *ServiceRestartReply) XXX_DiscardUnknown()

func (*ServiceRestartReply) XXX_Marshal 

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

func (*ServiceRestartReply) XXX_Merge 

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

func (*ServiceRestartReply) XXX_Size 

func (m *ServiceRestartReply) XXX_Size() int

func (*ServiceRestartReply) XXX_Unmarshal 

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

type ServiceRestartRequest 

type ServiceRestartRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceRestartRequest) Descriptor 

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

func (*ServiceRestartRequest) GetId 

func (m *ServiceRestartRequest) GetId() string

func (*ServiceRestartRequest) ProtoMessage 

func (*ServiceRestartRequest) ProtoMessage()

func (*ServiceRestartRequest) Reset 

func (m *ServiceRestartRequest) Reset()

func (*ServiceRestartRequest) String 

func (m *ServiceRestartRequest) String() string

func (*ServiceRestartRequest) XXX_DiscardUnknown 

func (m *ServiceRestartRequest) XXX_DiscardUnknown()

func (*ServiceRestartRequest) XXX_Marshal 

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

func (*ServiceRestartRequest) XXX_Merge 

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

func (*ServiceRestartRequest) XXX_Size 

func (m *ServiceRestartRequest) XXX_Size() int

func (*ServiceRestartRequest) XXX_Unmarshal 

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

type ServiceRestartResponse 

type ServiceRestartResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Resp                 string               `protobuf:"bytes,2,opt,name=resp,proto3" json:"resp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ServiceRestartResponse) Descriptor 

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

func (*ServiceRestartResponse) GetMetadata 

func (m *ServiceRestartResponse) GetMetadata() *common.NodeMetadata

func (*ServiceRestartResponse) GetResp 

func (m *ServiceRestartResponse) GetResp() string

func (*ServiceRestartResponse) ProtoMessage 

func (*ServiceRestartResponse) ProtoMessage()

func (*ServiceRestartResponse) Reset 

func (m *ServiceRestartResponse) Reset()

func (*ServiceRestartResponse) String 

func (m *ServiceRestartResponse) String() string

func (*ServiceRestartResponse) XXX_DiscardUnknown 

func (m *ServiceRestartResponse) XXX_DiscardUnknown()

func (*ServiceRestartResponse) XXX_Marshal 

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

func (*ServiceRestartResponse) XXX_Merge 

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

func (*ServiceRestartResponse) XXX_Size 

func (m *ServiceRestartResponse) XXX_Size() int

func (*ServiceRestartResponse) XXX_Unmarshal 

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

type ServiceStartReply 

type ServiceStartReply struct {
	Response             []*ServiceStartResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ServiceStartReply) Descriptor 

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

func (*ServiceStartReply) GetResponse 

func (m *ServiceStartReply) GetResponse() []*ServiceStartResponse

func (*ServiceStartReply) ProtoMessage 

func (*ServiceStartReply) ProtoMessage()

func (*ServiceStartReply) Reset 

func (m *ServiceStartReply) Reset()

func (*ServiceStartReply) String 

func (m *ServiceStartReply) String() string

func (*ServiceStartReply) XXX_DiscardUnknown 

func (m *ServiceStartReply) XXX_DiscardUnknown()

func (*ServiceStartReply) XXX_Marshal 

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

func (*ServiceStartReply) XXX_Merge 

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

func (*ServiceStartReply) XXX_Size 

func (m *ServiceStartReply) XXX_Size() int

func (*ServiceStartReply) XXX_Unmarshal 

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

type ServiceStartRequest 

type ServiceStartRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

rpc servicestart

func (*ServiceStartRequest) Descriptor 

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

func (*ServiceStartRequest) GetId 

func (m *ServiceStartRequest) GetId() string

func (*ServiceStartRequest) ProtoMessage 

func (*ServiceStartRequest) ProtoMessage()

func (*ServiceStartRequest) Reset 

func (m *ServiceStartRequest) Reset()

func (*ServiceStartRequest) String 

func (m *ServiceStartRequest) String() string

func (*ServiceStartRequest) XXX_DiscardUnknown 

func (m *ServiceStartRequest) XXX_DiscardUnknown()

func (*ServiceStartRequest) XXX_Marshal 

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

func (*ServiceStartRequest) XXX_Merge 

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

func (*ServiceStartRequest) XXX_Size 

func (m *ServiceStartRequest) XXX_Size() int

func (*ServiceStartRequest) XXX_Unmarshal 

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

type ServiceStartResponse 

type ServiceStartResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Resp                 string               `protobuf:"bytes,2,opt,name=resp,proto3" json:"resp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ServiceStartResponse) Descriptor 

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

func (*ServiceStartResponse) GetMetadata 

func (m *ServiceStartResponse) GetMetadata() *common.NodeMetadata

func (*ServiceStartResponse) GetResp 

func (m *ServiceStartResponse) GetResp() string

func (*ServiceStartResponse) ProtoMessage 

func (*ServiceStartResponse) ProtoMessage()

func (*ServiceStartResponse) Reset 

func (m *ServiceStartResponse) Reset()

func (*ServiceStartResponse) String 

func (m *ServiceStartResponse) String() string

func (*ServiceStartResponse) XXX_DiscardUnknown 

func (m *ServiceStartResponse) XXX_DiscardUnknown()

func (*ServiceStartResponse) XXX_Marshal 

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

func (*ServiceStartResponse) XXX_Merge 

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

func (*ServiceStartResponse) XXX_Size 

func (m *ServiceStartResponse) XXX_Size() int

func (*ServiceStartResponse) XXX_Unmarshal 

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

type ServiceStopReply 

type ServiceStopReply struct {
	Response             []*ServiceStopResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ServiceStopReply) Descriptor 

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

func (*ServiceStopReply) GetResponse 

func (m *ServiceStopReply) GetResponse() []*ServiceStopResponse

func (*ServiceStopReply) ProtoMessage 

func (*ServiceStopReply) ProtoMessage()

func (*ServiceStopReply) Reset 

func (m *ServiceStopReply) Reset()

func (*ServiceStopReply) String 

func (m *ServiceStopReply) String() string

func (*ServiceStopReply) XXX_DiscardUnknown 

func (m *ServiceStopReply) XXX_DiscardUnknown()

func (*ServiceStopReply) XXX_Marshal 

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

func (*ServiceStopReply) XXX_Merge 

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

func (*ServiceStopReply) XXX_Size 

func (m *ServiceStopReply) XXX_Size() int

func (*ServiceStopReply) XXX_Unmarshal 

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

type ServiceStopRequest 

type ServiceStopRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceStopRequest) Descriptor 

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

func (*ServiceStopRequest) GetId 

func (m *ServiceStopRequest) GetId() string

func (*ServiceStopRequest) ProtoMessage 

func (*ServiceStopRequest) ProtoMessage()

func (*ServiceStopRequest) Reset 

func (m *ServiceStopRequest) Reset()

func (*ServiceStopRequest) String 

func (m *ServiceStopRequest) String() string

func (*ServiceStopRequest) XXX_DiscardUnknown 

func (m *ServiceStopRequest) XXX_DiscardUnknown()

func (*ServiceStopRequest) XXX_Marshal 

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

func (*ServiceStopRequest) XXX_Merge 

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

func (*ServiceStopRequest) XXX_Size 

func (m *ServiceStopRequest) XXX_Size() int

func (*ServiceStopRequest) XXX_Unmarshal 

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

type ServiceStopResponse 

type ServiceStopResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Resp                 string               `protobuf:"bytes,2,opt,name=resp,proto3" json:"resp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ServiceStopResponse) Descriptor 

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

func (*ServiceStopResponse) GetMetadata 

func (m *ServiceStopResponse) GetMetadata() *common.NodeMetadata

func (*ServiceStopResponse) GetResp 

func (m *ServiceStopResponse) GetResp() string

func (*ServiceStopResponse) ProtoMessage 

func (*ServiceStopResponse) ProtoMessage()

func (*ServiceStopResponse) Reset 

func (m *ServiceStopResponse) Reset()

func (*ServiceStopResponse) String 

func (m *ServiceStopResponse) String() string

func (*ServiceStopResponse) XXX_DiscardUnknown 

func (m *ServiceStopResponse) XXX_DiscardUnknown()

func (*ServiceStopResponse) XXX_Marshal 

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

func (*ServiceStopResponse) XXX_Merge 

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

func (*ServiceStopResponse) XXX_Size 

func (m *ServiceStopResponse) XXX_Size() int

func (*ServiceStopResponse) XXX_Unmarshal 

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

type ShutdownReply 

type ShutdownReply struct {
	Response             []*ShutdownResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ShutdownReply) Descriptor 

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

func (*ShutdownReply) GetResponse 

func (m *ShutdownReply) GetResponse() []*ShutdownResponse

func (*ShutdownReply) ProtoMessage 

func (*ShutdownReply) ProtoMessage()

func (*ShutdownReply) Reset 

func (m *ShutdownReply) Reset()

func (*ShutdownReply) String 

func (m *ShutdownReply) String() string

func (*ShutdownReply) XXX_DiscardUnknown 

func (m *ShutdownReply) XXX_DiscardUnknown()

func (*ShutdownReply) XXX_Marshal 

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

func (*ShutdownReply) XXX_Merge 

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

func (*ShutdownReply) XXX_Size 

func (m *ShutdownReply) XXX_Size() int

func (*ShutdownReply) XXX_Unmarshal 

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

type ShutdownResponse 

type ShutdownResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

rpc shutdown The response message containing the shutdown status.

func (*ShutdownResponse) Descriptor 

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

func (*ShutdownResponse) GetMetadata 

func (m *ShutdownResponse) GetMetadata() *common.NodeMetadata

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) Reset 

func (m *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (m *ShutdownResponse) String() string

func (*ShutdownResponse) XXX_DiscardUnknown 

func (m *ShutdownResponse) XXX_DiscardUnknown()

func (*ShutdownResponse) XXX_Marshal 

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

func (*ShutdownResponse) XXX_Merge 

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

func (*ShutdownResponse) XXX_Size 

func (m *ShutdownResponse) XXX_Size() int

func (*ShutdownResponse) XXX_Unmarshal 

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

type StartReply deprecated 

type StartReply struct {
	Resp                 string   `protobuf:"bytes,1,opt,name=resp,proto3" json:"resp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: Do not use.

func (*StartReply) Descriptor 

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

func (*StartReply) GetResp 

func (m *StartReply) GetResp() string

func (*StartReply) ProtoMessage 

func (*StartReply) ProtoMessage()

func (*StartReply) Reset 

func (m *StartReply) Reset()

func (*StartReply) String 

func (m *StartReply) String() string

func (*StartReply) XXX_DiscardUnknown 

func (m *StartReply) XXX_DiscardUnknown()

func (*StartReply) XXX_Marshal 

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

func (*StartReply) XXX_Merge 

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

func (*StartReply) XXX_Size 

func (m *StartReply) XXX_Size() int

func (*StartReply) XXX_Unmarshal 

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

type StartRequest deprecated 

type StartRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: Do not use.

func (*StartRequest) Descriptor 

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

func (*StartRequest) GetId 

func (m *StartRequest) GetId() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) XXX_DiscardUnknown 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal 

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

func (*StartRequest) XXX_Merge 

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

func (*StartRequest) XXX_Size 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal 

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

type StopReply deprecated 

type StopReply struct {
	Resp                 string   `protobuf:"bytes,1,opt,name=resp,proto3" json:"resp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: Do not use.

func (*StopReply) Descriptor 

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

func (*StopReply) GetResp 

func (m *StopReply) GetResp() string

func (*StopReply) ProtoMessage 

func (*StopReply) ProtoMessage()

func (*StopReply) Reset 

func (m *StopReply) Reset()

func (*StopReply) String 

func (m *StopReply) String() string

func (*StopReply) XXX_DiscardUnknown 

func (m *StopReply) XXX_DiscardUnknown()

func (*StopReply) XXX_Marshal 

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

func (*StopReply) XXX_Merge 

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

func (*StopReply) XXX_Size 

func (m *StopReply) XXX_Size() int

func (*StopReply) XXX_Unmarshal 

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

type StopRequest deprecated 

type StopRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: Do not use.

func (*StopRequest) Descriptor 

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

func (*StopRequest) GetId 

func (m *StopRequest) GetId() string

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

func (*StopRequest) XXX_DiscardUnknown 

func (m *StopRequest) XXX_DiscardUnknown()

func (*StopRequest) XXX_Marshal 

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

func (*StopRequest) XXX_Merge 

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

func (*StopRequest) XXX_Size 

func (m *StopRequest) XXX_Size() int

func (*StopRequest) XXX_Unmarshal 

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

type StreamingData 

type StreamingData struct {
	Bytes                []byte   `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Errors               string   `protobuf:"bytes,2,opt,name=errors,proto3" json:"errors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StreamingData is used to stream back responses

func (*StreamingData) Descriptor 

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

func (*StreamingData) GetBytes 

func (m *StreamingData) GetBytes() []byte

func (*StreamingData) GetErrors 

func (m *StreamingData) GetErrors() string

func (*StreamingData) ProtoMessage 

func (*StreamingData) ProtoMessage()

func (*StreamingData) Reset 

func (m *StreamingData) Reset()

func (*StreamingData) String 

func (m *StreamingData) String() string

func (*StreamingData) XXX_DiscardUnknown 

func (m *StreamingData) XXX_DiscardUnknown()

func (*StreamingData) XXX_Marshal 

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

func (*StreamingData) XXX_Merge 

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

func (*StreamingData) XXX_Size 

func (m *StreamingData) XXX_Size() int

func (*StreamingData) XXX_Unmarshal 

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

type UpgradeReply 

type UpgradeReply struct {
	Response             []*UpgradeResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*UpgradeReply) Descriptor 

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

func (*UpgradeReply) GetResponse 

func (m *UpgradeReply) GetResponse() []*UpgradeResponse

func (*UpgradeReply) ProtoMessage 

func (*UpgradeReply) ProtoMessage()

func (*UpgradeReply) Reset 

func (m *UpgradeReply) Reset()

func (*UpgradeReply) String 

func (m *UpgradeReply) String() string

func (*UpgradeReply) XXX_DiscardUnknown 

func (m *UpgradeReply) XXX_DiscardUnknown()

func (*UpgradeReply) XXX_Marshal 

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

func (*UpgradeReply) XXX_Merge 

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

func (*UpgradeReply) XXX_Size 

func (m *UpgradeReply) XXX_Size() int

func (*UpgradeReply) XXX_Unmarshal 

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

type UpgradeRequest 

type UpgradeRequest struct {
	Image                string   `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

rpc upgrade

func (*UpgradeRequest) Descriptor 

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

func (*UpgradeRequest) GetImage 

func (m *UpgradeRequest) GetImage() string

func (*UpgradeRequest) ProtoMessage 

func (*UpgradeRequest) ProtoMessage()

func (*UpgradeRequest) Reset 

func (m *UpgradeRequest) Reset()

func (*UpgradeRequest) String 

func (m *UpgradeRequest) String() string

func (*UpgradeRequest) XXX_DiscardUnknown 

func (m *UpgradeRequest) XXX_DiscardUnknown()

func (*UpgradeRequest) XXX_Marshal 

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

func (*UpgradeRequest) XXX_Merge 

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

func (*UpgradeRequest) XXX_Size 

func (m *UpgradeRequest) XXX_Size() int

func (*UpgradeRequest) XXX_Unmarshal 

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

type UpgradeResponse 

type UpgradeResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Ack                  string               `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UpgradeResponse) Descriptor 

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

func (*UpgradeResponse) GetAck 

func (m *UpgradeResponse) GetAck() string

func (*UpgradeResponse) GetMetadata 

func (m *UpgradeResponse) GetMetadata() *common.NodeMetadata

func (*UpgradeResponse) ProtoMessage 

func (*UpgradeResponse) ProtoMessage()

func (*UpgradeResponse) Reset 

func (m *UpgradeResponse) Reset()

func (*UpgradeResponse) String 

func (m *UpgradeResponse) String() string

func (*UpgradeResponse) XXX_DiscardUnknown 

func (m *UpgradeResponse) XXX_DiscardUnknown()

func (*UpgradeResponse) XXX_Marshal 

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

func (*UpgradeResponse) XXX_Merge 

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

func (*UpgradeResponse) XXX_Size 

func (m *UpgradeResponse) XXX_Size() int

func (*UpgradeResponse) XXX_Unmarshal 

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

type VersionInfo 

type VersionInfo struct {
	Tag                  string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Sha                  string   `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"`
	Built                string   `protobuf:"bytes,3,opt,name=built,proto3" json:"built,omitempty"`
	GoVersion            string   `protobuf:"bytes,4,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	Os                   string   `protobuf:"bytes,5,opt,name=os,proto3" json:"os,omitempty"`
	Arch                 string   `protobuf:"bytes,6,opt,name=arch,proto3" json:"arch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionInfo) Descriptor 

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

func (*VersionInfo) GetArch 

func (m *VersionInfo) GetArch() string

func (*VersionInfo) GetBuilt 

func (m *VersionInfo) GetBuilt() string

func (*VersionInfo) GetGoVersion 

func (m *VersionInfo) GetGoVersion() string

func (*VersionInfo) GetOs 

func (m *VersionInfo) GetOs() string

func (*VersionInfo) GetSha 

func (m *VersionInfo) GetSha() string

func (*VersionInfo) GetTag 

func (m *VersionInfo) GetTag() string

func (*VersionInfo) ProtoMessage 

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) Reset 

func (m *VersionInfo) Reset()

func (*VersionInfo) String 

func (m *VersionInfo) String() string

func (*VersionInfo) XXX_DiscardUnknown 

func (m *VersionInfo) XXX_DiscardUnknown()

func (*VersionInfo) XXX_Marshal 

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

func (*VersionInfo) XXX_Merge 

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

func (*VersionInfo) XXX_Size 

func (m *VersionInfo) XXX_Size() int

func (*VersionInfo) XXX_Unmarshal 

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

type VersionReply 

type VersionReply struct {
	Response             []*VersionResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*VersionReply) Descriptor 

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

func (*VersionReply) GetResponse 

func (m *VersionReply) GetResponse() []*VersionResponse

func (*VersionReply) ProtoMessage 

func (*VersionReply) ProtoMessage()

func (*VersionReply) Reset 

func (m *VersionReply) Reset()

func (*VersionReply) String 

func (m *VersionReply) String() string

func (*VersionReply) XXX_DiscardUnknown 

func (m *VersionReply) XXX_DiscardUnknown()

func (*VersionReply) XXX_Marshal 

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

func (*VersionReply) XXX_Merge 

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

func (*VersionReply) XXX_Size 

func (m *VersionReply) XXX_Size() int

func (*VersionReply) XXX_Unmarshal 

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

type VersionResponse 

type VersionResponse struct {
	Metadata             *common.NodeMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Version              []*VersionInfo       `protobuf:"bytes,2,rep,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetMetadata 

func (m *VersionResponse) GetMetadata() *common.NodeMetadata

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() []*VersionInfo

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

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

func (*VersionResponse) XXX_Merge 

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

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

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

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.