broker

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BrokerServiceType_name = map[int32]string{
		0:  "BROKER_SERVICE_UNSPECIFIED",
		1:  "BROKER_SERVICE_SSH_LEGACY",
		3:  "BROKER_SERVICE_SSH",
		2:  "BROKER_SERVICE_TCP_FORWARD_PORT",
		4:  "BROKER_SERVICE_REBOOT",
		5:  "BROKER_SERVICE_SHUTDOWN",
		6:  "BROKER_SERVICE_SCP",
		7:  "BROKER_SERVICE_SCP_LEGACY",
		8:  "BROKER_SYS_LOGS",
		9:  "BROKER_APP_LOGS",
		10: "BROKER_POD_MANAGEMENT",
	}

	BrokerServiceType_value = map[string]int32{
		"BROKER_SERVICE_UNSPECIFIED":      0,
		"BROKER_SERVICE_SSH_LEGACY":       1,
		"BROKER_SERVICE_SSH":              3,
		"BROKER_SERVICE_TCP_FORWARD_PORT": 2,
		"BROKER_SERVICE_REBOOT":           4,
		"BROKER_SERVICE_SHUTDOWN":         5,
		"BROKER_SERVICE_SCP":              6,
		"BROKER_SERVICE_SCP_LEGACY":       7,
		"BROKER_SYS_LOGS":                 8,
		"BROKER_APP_LOGS":                 9,
		"BROKER_POD_MANAGEMENT":           10,
	}
)
View Source 
var (
	SCPService_Configure_Direction_name = map[int32]string{
		0: "DOWNLOAD",
		1: "UPLOAD",
	}

	SCPService_Configure_Direction_value = map[string]int32{
		"DOWNLOAD": 0,
		"UPLOAD":   1,
	}
)
View Source 
var (
	PodManagementService_PodState_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "START",
		2: "STOP",
		3: "RESTART",
	}

	PodManagementService_PodState_value = map[string]int32{
		"UNSPECIFIED": 0,
		"START":       1,
		"STOP":        2,
		"RESTART":     3,
	}
)
View Source 
var (
	SystemStateService_SystemState_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SHUTDOWN",
		2: "REBOOT",
	}

	SystemStateService_SystemState_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SHUTDOWN":    1,
		"REBOOT":      2,
	}
)

Functions

This section is empty.

Types

type BrokerServiceType 

type BrokerServiceType int32

Broker dedicated messages 

const (
	// Service type not specified
	BrokerServiceType_BROKER_SERVICE_UNSPECIFIED BrokerServiceType = 0
	// SSH service
	BrokerServiceType_BROKER_SERVICE_SSH_LEGACY BrokerServiceType = 1
	BrokerServiceType_BROKER_SERVICE_SSH        BrokerServiceType = 3
	// TCP port forward service
	BrokerServiceType_BROKER_SERVICE_TCP_FORWARD_PORT BrokerServiceType = 2
	// Reboot service
	BrokerServiceType_BROKER_SERVICE_REBOOT BrokerServiceType = 4
	// Shutdown service
	BrokerServiceType_BROKER_SERVICE_SHUTDOWN BrokerServiceType = 5
	// SCP service
	BrokerServiceType_BROKER_SERVICE_SCP        BrokerServiceType = 6
	BrokerServiceType_BROKER_SERVICE_SCP_LEGACY BrokerServiceType = 7
	// System Logs service
	BrokerServiceType_BROKER_SYS_LOGS BrokerServiceType = 8
	// Application (Container) Logs service
	BrokerServiceType_BROKER_APP_LOGS BrokerServiceType = 9
	// Pod State Management service
	BrokerServiceType_BROKER_POD_MANAGEMENT BrokerServiceType = 10
)

func (BrokerServiceType) Descriptor 

func (BrokerServiceType) Descriptor() preflect.EnumDescriptor

func (BrokerServiceType) Enum 

func (x BrokerServiceType) Enum() *BrokerServiceType

func (BrokerServiceType) EnumDescriptor 

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

Deprecated, Use BrokerServiceType.ProtoReflect.Descriptor instead.

func (BrokerServiceType) Number 

func (x BrokerServiceType) Number() preflect.EnumNumber

func (BrokerServiceType) String 

func (x BrokerServiceType) String() string

func (BrokerServiceType) Type 

func (BrokerServiceType) Type() preflect.EnumType

type LogsService 

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

func (*LogsService) Descriptor 

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

Deprecated, Use LogsService.ProtoReflect.Descriptor instead.

func (*LogsService) GotenMessage 

func (*LogsService) GotenMessage()

func (*LogsService) GotenValidate 

func (obj *LogsService) GotenValidate() error

func (*LogsService) Marshal 

func (m *LogsService) Marshal() ([]byte, error)

func (*LogsService) MarshalJSON 

func (m *LogsService) MarshalJSON() ([]byte, error)

func (*LogsService) ProtoMessage 

func (*LogsService) ProtoMessage()

func (*LogsService) ProtoReflect 

func (m *LogsService) ProtoReflect() preflect.Message

func (*LogsService) Reset 

func (m *LogsService) Reset()

func (*LogsService) String 

func (m *LogsService) String() string

func (*LogsService) Unmarshal 

func (m *LogsService) Unmarshal(b []byte) error

func (*LogsService) UnmarshalJSON 

func (m *LogsService) UnmarshalJSON(data []byte) error

type LogsService_ToClient 

type LogsService_ToClient struct {

	// Logs data
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty" firestore:"data"`
	// contains filtered or unexported fields
}

Messages sent only to a client

func (*LogsService_ToClient) Descriptor 

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

Deprecated, Use LogsService_ToClient.ProtoReflect.Descriptor instead.

func (*LogsService_ToClient) GetData 

func (m *LogsService_ToClient) GetData() []byte

func (*LogsService_ToClient) GotenMessage 

func (*LogsService_ToClient) GotenMessage()

func (*LogsService_ToClient) GotenValidate 

func (obj *LogsService_ToClient) GotenValidate() error

func (*LogsService_ToClient) Marshal 

func (m *LogsService_ToClient) Marshal() ([]byte, error)

func (*LogsService_ToClient) MarshalJSON 

func (m *LogsService_ToClient) MarshalJSON() ([]byte, error)

func (*LogsService_ToClient) ProtoMessage 

func (*LogsService_ToClient) ProtoMessage()

func (*LogsService_ToClient) ProtoReflect 

func (m *LogsService_ToClient) ProtoReflect() preflect.Message

func (*LogsService_ToClient) Reset 

func (m *LogsService_ToClient) Reset()

func (*LogsService_ToClient) SetData 

func (m *LogsService_ToClient) SetData(fv []byte)

func (*LogsService_ToClient) String 

func (m *LogsService_ToClient) String() string

func (*LogsService_ToClient) Unmarshal 

func (m *LogsService_ToClient) Unmarshal(b []byte) error

func (*LogsService_ToClient) UnmarshalJSON 

func (m *LogsService_ToClient) UnmarshalJSON(data []byte) error

type LogsService_ToDevice 

type LogsService_ToDevice struct {

	// Live follow the logs service
	Follow bool `protobuf:"varint,1,opt,name=follow,proto3" json:"follow,omitempty" firestore:"follow"`
	// Number of lines to get from the logs service
	Lines uint32 `protobuf:"varint,2,opt,name=lines,proto3" json:"lines,omitempty" firestore:"lines"`
	// Source of the logs service (e.g. docker container ID)
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty" firestore:"source"`
	// contains filtered or unexported fields
}

Messages sent only to a device

func (*LogsService_ToDevice) Descriptor 

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

Deprecated, Use LogsService_ToDevice.ProtoReflect.Descriptor instead.

func (*LogsService_ToDevice) GetFollow 

func (m *LogsService_ToDevice) GetFollow() bool

func (*LogsService_ToDevice) GetLines 

func (m *LogsService_ToDevice) GetLines() uint32

func (*LogsService_ToDevice) GetSource 

func (m *LogsService_ToDevice) GetSource() string

func (*LogsService_ToDevice) GotenMessage 

func (*LogsService_ToDevice) GotenMessage()

func (*LogsService_ToDevice) GotenValidate 

func (obj *LogsService_ToDevice) GotenValidate() error

func (*LogsService_ToDevice) Marshal 

func (m *LogsService_ToDevice) Marshal() ([]byte, error)

func (*LogsService_ToDevice) MarshalJSON 

func (m *LogsService_ToDevice) MarshalJSON() ([]byte, error)

func (*LogsService_ToDevice) ProtoMessage 

func (*LogsService_ToDevice) ProtoMessage()

func (*LogsService_ToDevice) ProtoReflect 

func (m *LogsService_ToDevice) ProtoReflect() preflect.Message

func (*LogsService_ToDevice) Reset 

func (m *LogsService_ToDevice) Reset()

func (*LogsService_ToDevice) SetFollow 

func (m *LogsService_ToDevice) SetFollow(fv bool)

func (*LogsService_ToDevice) SetLines 

func (m *LogsService_ToDevice) SetLines(fv uint32)

func (*LogsService_ToDevice) SetSource 

func (m *LogsService_ToDevice) SetSource(fv string)

func (*LogsService_ToDevice) String 

func (m *LogsService_ToDevice) String() string

func (*LogsService_ToDevice) Unmarshal 

func (m *LogsService_ToDevice) Unmarshal(b []byte) error

func (*LogsService_ToDevice) UnmarshalJSON 

func (m *LogsService_ToDevice) UnmarshalJSON(data []byte) error

type PodManagementService 

type PodManagementService struct {

	// Pod state command
	Command PodManagementService_PodState `` /* 138-byte string literal not displayed */
	// Pod to execute the command on
	Pod string `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty" firestore:"pod"`
	// Service (container) name to execute the command on (empty = acts on the
	// entire pod)
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty" firestore:"service"`
	// contains filtered or unexported fields
}

func (*PodManagementService) Descriptor 

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

Deprecated, Use PodManagementService.ProtoReflect.Descriptor instead.

func (*PodManagementService) GetCommand 

func (m *PodManagementService) GetCommand() PodManagementService_PodState

func (*PodManagementService) GetPod 

func (m *PodManagementService) GetPod() string

func (*PodManagementService) GetService 

func (m *PodManagementService) GetService() string

func (*PodManagementService) GotenMessage 

func (*PodManagementService) GotenMessage()

func (*PodManagementService) GotenValidate 

func (obj *PodManagementService) GotenValidate() error

func (*PodManagementService) Marshal 

func (m *PodManagementService) Marshal() ([]byte, error)

func (*PodManagementService) MarshalJSON 

func (m *PodManagementService) MarshalJSON() ([]byte, error)

func (*PodManagementService) ProtoMessage 

func (*PodManagementService) ProtoMessage()

func (*PodManagementService) ProtoReflect 

func (m *PodManagementService) ProtoReflect() preflect.Message

func (*PodManagementService) Reset 

func (m *PodManagementService) Reset()

func (*PodManagementService) SetCommand 

func (m *PodManagementService) SetCommand(fv PodManagementService_PodState)

func (*PodManagementService) SetPod 

func (m *PodManagementService) SetPod(fv string)

func (*PodManagementService) SetService 

func (m *PodManagementService) SetService(fv string)

func (*PodManagementService) String 

func (m *PodManagementService) String() string

func (*PodManagementService) Unmarshal 

func (m *PodManagementService) Unmarshal(b []byte) error

func (*PodManagementService) UnmarshalJSON 

func (m *PodManagementService) UnmarshalJSON(data []byte) error

type PodManagementService_PodState 

type PodManagementService_PodState int32

Commands for pod state management 

const (
	// Unspecified pod state
	PodManagementService_UNSPECIFIED PodManagementService_PodState = 0
	// Start the pod
	PodManagementService_START PodManagementService_PodState = 1
	// Stop the pod
	PodManagementService_STOP PodManagementService_PodState = 2
	// Restart the pod
	PodManagementService_RESTART PodManagementService_PodState = 3
)

func (PodManagementService_PodState) Descriptor 

func (PodManagementService_PodState) Descriptor() preflect.EnumDescriptor

func (PodManagementService_PodState) Enum 

func (x PodManagementService_PodState) Enum() *PodManagementService_PodState

func (PodManagementService_PodState) EnumDescriptor 

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

Deprecated, Use PodManagementService_PodState.ProtoReflect.Descriptor instead.

func (PodManagementService_PodState) Number 

func (x PodManagementService_PodState) Number() preflect.EnumNumber

func (PodManagementService_PodState) String 

func (x PodManagementService_PodState) String() string

func (PodManagementService_PodState) Type 

func (PodManagementService_PodState) Type() preflect.EnumType

type SCPService 

type SCPService struct {

	// Types that are valid to be assigned to Msg:
	//	*SCPService_Dir
	//	*SCPService_File
	//	*SCPService_Eot
	//	*SCPService_Config
	Msg isSCPService_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*SCPService) Descriptor 

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

Deprecated, Use SCPService.ProtoReflect.Descriptor instead.

func (*SCPService) GetConfig 

func (m *SCPService) GetConfig() *SCPService_Configure

func (*SCPService) GetDir 

func (m *SCPService) GetDir() *SCPService_CreateDirectory

func (*SCPService) GetEot 

func (m *SCPService) GetEot() bool

func (*SCPService) GetFile 

func (m *SCPService) GetFile() *SCPService_CreateFile

func (*SCPService) GetMsg 

func (m *SCPService) GetMsg() isSCPService_Msg

func (*SCPService) GotenMessage 

func (*SCPService) GotenMessage()

func (*SCPService) GotenValidate 

func (obj *SCPService) GotenValidate() error

func (*SCPService) Marshal 

func (m *SCPService) Marshal() ([]byte, error)

func (*SCPService) MarshalJSON 

func (m *SCPService) MarshalJSON() ([]byte, error)

func (*SCPService) ProtoMessage 

func (*SCPService) ProtoMessage()

func (*SCPService) ProtoReflect 

func (m *SCPService) ProtoReflect() preflect.Message

func (*SCPService) Reset 

func (m *SCPService) Reset()

func (*SCPService) SetConfig 

func (m *SCPService) SetConfig(fv *SCPService_Configure)

func (*SCPService) SetDir 

func (m *SCPService) SetDir(fv *SCPService_CreateDirectory)

func (*SCPService) SetEot 

func (m *SCPService) SetEot(fv bool)

func (*SCPService) SetFile 

func (m *SCPService) SetFile(fv *SCPService_CreateFile)

func (*SCPService) SetMsg 

func (m *SCPService) SetMsg(ofv isSCPService_Msg)

func (*SCPService) String 

func (m *SCPService) String() string

func (*SCPService) Unmarshal 

func (m *SCPService) Unmarshal(b []byte) error

func (*SCPService) UnmarshalJSON 

func (m *SCPService) UnmarshalJSON(data []byte) error

type SCPService_Config 

type SCPService_Config struct {
	// Request SCP configuration
	Config *SCPService_Configure `protobuf:"bytes,4,opt,name=config,proto3,oneof" firestore:"config"`
}

type SCPService_Configure 

type SCPService_Configure struct {
	Recursive bool                           `protobuf:"varint,1,opt,name=recursive,proto3" json:"recursive,omitempty" firestore:"recursive"`
	Direction SCPService_Configure_Direction `` /* 145-byte string literal not displayed */
	Path      string                         `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty" firestore:"path"`
	// contains filtered or unexported fields
}

func (*SCPService_Configure) Descriptor 

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

Deprecated, Use SCPService_Configure.ProtoReflect.Descriptor instead.

func (*SCPService_Configure) GetDirection 

func (m *SCPService_Configure) GetDirection() SCPService_Configure_Direction

func (*SCPService_Configure) GetPath 

func (m *SCPService_Configure) GetPath() string

func (*SCPService_Configure) GetRecursive 

func (m *SCPService_Configure) GetRecursive() bool

func (*SCPService_Configure) GotenMessage 

func (*SCPService_Configure) GotenMessage()

func (*SCPService_Configure) GotenValidate 

func (obj *SCPService_Configure) GotenValidate() error

func (*SCPService_Configure) Marshal 

func (m *SCPService_Configure) Marshal() ([]byte, error)

func (*SCPService_Configure) MarshalJSON 

func (m *SCPService_Configure) MarshalJSON() ([]byte, error)

func (*SCPService_Configure) ProtoMessage 

func (*SCPService_Configure) ProtoMessage()

func (*SCPService_Configure) ProtoReflect 

func (m *SCPService_Configure) ProtoReflect() preflect.Message

func (*SCPService_Configure) Reset 

func (m *SCPService_Configure) Reset()

func (*SCPService_Configure) SetDirection 

func (m *SCPService_Configure) SetDirection(fv SCPService_Configure_Direction)

func (*SCPService_Configure) SetPath 

func (m *SCPService_Configure) SetPath(fv string)

func (*SCPService_Configure) SetRecursive 

func (m *SCPService_Configure) SetRecursive(fv bool)

func (*SCPService_Configure) String 

func (m *SCPService_Configure) String() string

func (*SCPService_Configure) Unmarshal 

func (m *SCPService_Configure) Unmarshal(b []byte) error

func (*SCPService_Configure) UnmarshalJSON 

func (m *SCPService_Configure) UnmarshalJSON(data []byte) error

type SCPService_Configure_Direction 

type SCPService_Configure_Direction int32
const (
	SCPService_Configure_DOWNLOAD SCPService_Configure_Direction = 0
	SCPService_Configure_UPLOAD   SCPService_Configure_Direction = 1
)

func (SCPService_Configure_Direction) Descriptor 

func (SCPService_Configure_Direction) Descriptor() preflect.EnumDescriptor

func (SCPService_Configure_Direction) Enum 

func (x SCPService_Configure_Direction) Enum() *SCPService_Configure_Direction

func (SCPService_Configure_Direction) EnumDescriptor 

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

Deprecated, Use SCPService_Configure_Direction.ProtoReflect.Descriptor instead.

func (SCPService_Configure_Direction) Number 

func (x SCPService_Configure_Direction) Number() preflect.EnumNumber

func (SCPService_Configure_Direction) String 

func (x SCPService_Configure_Direction) String() string

func (SCPService_Configure_Direction) Type 

func (SCPService_Configure_Direction) Type() preflect.EnumType

type SCPService_CreateDirectory 

type SCPService_CreateDirectory struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty" firestore:"path"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty" firestore:"mode"`
	// contains filtered or unexported fields
}

func (*SCPService_CreateDirectory) Descriptor 

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

Deprecated, Use SCPService_CreateDirectory.ProtoReflect.Descriptor instead.

func (*SCPService_CreateDirectory) GetMode 

func (m *SCPService_CreateDirectory) GetMode() uint32

func (*SCPService_CreateDirectory) GetPath 

func (m *SCPService_CreateDirectory) GetPath() string

func (*SCPService_CreateDirectory) GotenMessage 

func (*SCPService_CreateDirectory) GotenMessage()

func (*SCPService_CreateDirectory) GotenValidate 

func (obj *SCPService_CreateDirectory) GotenValidate() error

func (*SCPService_CreateDirectory) Marshal 

func (m *SCPService_CreateDirectory) Marshal() ([]byte, error)

func (*SCPService_CreateDirectory) MarshalJSON 

func (m *SCPService_CreateDirectory) MarshalJSON() ([]byte, error)

func (*SCPService_CreateDirectory) ProtoMessage 

func (*SCPService_CreateDirectory) ProtoMessage()

func (*SCPService_CreateDirectory) ProtoReflect 

func (m *SCPService_CreateDirectory) ProtoReflect() preflect.Message

func (*SCPService_CreateDirectory) Reset 

func (m *SCPService_CreateDirectory) Reset()

func (*SCPService_CreateDirectory) SetMode 

func (m *SCPService_CreateDirectory) SetMode(fv uint32)

func (*SCPService_CreateDirectory) SetPath 

func (m *SCPService_CreateDirectory) SetPath(fv string)

func (*SCPService_CreateDirectory) String 

func (m *SCPService_CreateDirectory) String() string

func (*SCPService_CreateDirectory) Unmarshal 

func (m *SCPService_CreateDirectory) Unmarshal(b []byte) error

func (*SCPService_CreateDirectory) UnmarshalJSON 

func (m *SCPService_CreateDirectory) UnmarshalJSON(data []byte) error

type SCPService_CreateFile 

type SCPService_CreateFile struct {

	// Types that are valid to be assigned to Msg:
	//	*SCPService_CreateFile_Init
	//	*SCPService_CreateFile_Data
	//	*SCPService_CreateFile_Eof
	Msg isSCPService_CreateFile_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*SCPService_CreateFile) Descriptor 

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

Deprecated, Use SCPService_CreateFile.ProtoReflect.Descriptor instead.

func (*SCPService_CreateFile) GetData 

func (m *SCPService_CreateFile) GetData() []byte

func (*SCPService_CreateFile) GetEof 

func (m *SCPService_CreateFile) GetEof() bool

func (*SCPService_CreateFile) GetInit 

func (m *SCPService_CreateFile) GetInit() *SCPService_CreateFile_Initialize

func (*SCPService_CreateFile) GetMsg 

func (m *SCPService_CreateFile) GetMsg() isSCPService_CreateFile_Msg

func (*SCPService_CreateFile) GotenMessage 

func (*SCPService_CreateFile) GotenMessage()

func (*SCPService_CreateFile) GotenValidate 

func (obj *SCPService_CreateFile) GotenValidate() error

func (*SCPService_CreateFile) Marshal 

func (m *SCPService_CreateFile) Marshal() ([]byte, error)

func (*SCPService_CreateFile) MarshalJSON 

func (m *SCPService_CreateFile) MarshalJSON() ([]byte, error)

func (*SCPService_CreateFile) ProtoMessage 

func (*SCPService_CreateFile) ProtoMessage()

func (*SCPService_CreateFile) ProtoReflect 

func (m *SCPService_CreateFile) ProtoReflect() preflect.Message

func (*SCPService_CreateFile) Reset 

func (m *SCPService_CreateFile) Reset()

func (*SCPService_CreateFile) SetData 

func (m *SCPService_CreateFile) SetData(fv []byte)

func (*SCPService_CreateFile) SetEof 

func (m *SCPService_CreateFile) SetEof(fv bool)

func (*SCPService_CreateFile) SetInit 

func (m *SCPService_CreateFile) SetInit(fv *SCPService_CreateFile_Initialize)

func (*SCPService_CreateFile) SetMsg 

func (m *SCPService_CreateFile) SetMsg(ofv isSCPService_CreateFile_Msg)

func (*SCPService_CreateFile) String 

func (m *SCPService_CreateFile) String() string

func (*SCPService_CreateFile) Unmarshal 

func (m *SCPService_CreateFile) Unmarshal(b []byte) error

func (*SCPService_CreateFile) UnmarshalJSON 

func (m *SCPService_CreateFile) UnmarshalJSON(data []byte) error

type SCPService_CreateFile_Data 

type SCPService_CreateFile_Data struct {
	// Request file data
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof" firestore:"data"`
}

type SCPService_CreateFile_Eof 

type SCPService_CreateFile_Eof struct {
	// Request to end file transfer
	Eof bool `protobuf:"varint,3,opt,name=eof,proto3,oneof" firestore:"eof"`
}

type SCPService_CreateFile_Init 

type SCPService_CreateFile_Init struct {
	// Request file initialization
	Init *SCPService_CreateFile_Initialize `protobuf:"bytes,1,opt,name=init,proto3,oneof" firestore:"init"`
}

type SCPService_CreateFile_Initialize 

type SCPService_CreateFile_Initialize struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty" firestore:"path"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty" firestore:"mode"`
	Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty" firestore:"size"`
	// contains filtered or unexported fields
}

func (*SCPService_CreateFile_Initialize) Descriptor 

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

Deprecated, Use SCPService_CreateFile_Initialize.ProtoReflect.Descriptor instead.

func (*SCPService_CreateFile_Initialize) GetMode 

func (m *SCPService_CreateFile_Initialize) GetMode() uint32

func (*SCPService_CreateFile_Initialize) GetPath 

func (m *SCPService_CreateFile_Initialize) GetPath() string

func (*SCPService_CreateFile_Initialize) GetSize 

func (m *SCPService_CreateFile_Initialize) GetSize() uint64

func (*SCPService_CreateFile_Initialize) GotenMessage 

func (*SCPService_CreateFile_Initialize) GotenMessage()

func (*SCPService_CreateFile_Initialize) GotenValidate 

func (obj *SCPService_CreateFile_Initialize) GotenValidate() error

func (*SCPService_CreateFile_Initialize) Marshal 

func (m *SCPService_CreateFile_Initialize) Marshal() ([]byte, error)

func (*SCPService_CreateFile_Initialize) MarshalJSON 

func (m *SCPService_CreateFile_Initialize) MarshalJSON() ([]byte, error)

func (*SCPService_CreateFile_Initialize) ProtoMessage 

func (*SCPService_CreateFile_Initialize) ProtoMessage()

func (*SCPService_CreateFile_Initialize) ProtoReflect 

func (m *SCPService_CreateFile_Initialize) ProtoReflect() preflect.Message

func (*SCPService_CreateFile_Initialize) Reset 

func (m *SCPService_CreateFile_Initialize) Reset()

func (*SCPService_CreateFile_Initialize) SetMode 

func (m *SCPService_CreateFile_Initialize) SetMode(fv uint32)

func (*SCPService_CreateFile_Initialize) SetPath 

func (m *SCPService_CreateFile_Initialize) SetPath(fv string)

func (*SCPService_CreateFile_Initialize) SetSize 

func (m *SCPService_CreateFile_Initialize) SetSize(fv uint64)

func (*SCPService_CreateFile_Initialize) String 

func (m *SCPService_CreateFile_Initialize) String() string

func (*SCPService_CreateFile_Initialize) Unmarshal 

func (m *SCPService_CreateFile_Initialize) Unmarshal(b []byte) error

func (*SCPService_CreateFile_Initialize) UnmarshalJSON 

func (m *SCPService_CreateFile_Initialize) UnmarshalJSON(data []byte) error

type SCPService_Dir 

type SCPService_Dir struct {
	// Request to create a directory
	Dir *SCPService_CreateDirectory `protobuf:"bytes,1,opt,name=dir,proto3,oneof" firestore:"dir"`
}

type SCPService_Eot 

type SCPService_Eot struct {
	// Request to end SCP transfer
	Eot bool `protobuf:"varint,3,opt,name=eot,proto3,oneof" firestore:"eot"`
}

type SCPService_File 

type SCPService_File struct {
	// Request to create a file
	File *SCPService_CreateFile `protobuf:"bytes,2,opt,name=file,proto3,oneof" firestore:"file"`
}

type SSHService 

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

Services on the device that the client connects to

func (*SSHService) Descriptor 

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

Deprecated, Use SSHService.ProtoReflect.Descriptor instead.

func (*SSHService) GotenMessage 

func (*SSHService) GotenMessage()

func (*SSHService) GotenValidate 

func (obj *SSHService) GotenValidate() error

func (*SSHService) Marshal 

func (m *SSHService) Marshal() ([]byte, error)

func (*SSHService) MarshalJSON 

func (m *SSHService) MarshalJSON() ([]byte, error)

func (*SSHService) ProtoMessage 

func (*SSHService) ProtoMessage()

func (*SSHService) ProtoReflect 

func (m *SSHService) ProtoReflect() preflect.Message

func (*SSHService) Reset 

func (m *SSHService) Reset()

func (*SSHService) String 

func (m *SSHService) String() string

func (*SSHService) Unmarshal 

func (m *SSHService) Unmarshal(b []byte) error

func (*SSHService) UnmarshalJSON 

func (m *SSHService) UnmarshalJSON(data []byte) error

type SSHService_ClientIn 

type SSHService_ClientIn struct {

	// Types that are valid to be assigned to Msg:
	//	*SSHService_ClientIn_Data
	Msg isSSHService_ClientIn_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*SSHService_ClientIn) Descriptor 

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

Deprecated, Use SSHService_ClientIn.ProtoReflect.Descriptor instead.

func (*SSHService_ClientIn) GetData 

func (m *SSHService_ClientIn) GetData() []byte

func (*SSHService_ClientIn) GetMsg 

func (m *SSHService_ClientIn) GetMsg() isSSHService_ClientIn_Msg

func (*SSHService_ClientIn) GotenMessage 

func (*SSHService_ClientIn) GotenMessage()

func (*SSHService_ClientIn) GotenValidate 

func (obj *SSHService_ClientIn) GotenValidate() error

func (*SSHService_ClientIn) Marshal 

func (m *SSHService_ClientIn) Marshal() ([]byte, error)

func (*SSHService_ClientIn) MarshalJSON 

func (m *SSHService_ClientIn) MarshalJSON() ([]byte, error)

func (*SSHService_ClientIn) ProtoMessage 

func (*SSHService_ClientIn) ProtoMessage()

func (*SSHService_ClientIn) ProtoReflect 

func (m *SSHService_ClientIn) ProtoReflect() preflect.Message

func (*SSHService_ClientIn) Reset 

func (m *SSHService_ClientIn) Reset()

func (*SSHService_ClientIn) SetData 

func (m *SSHService_ClientIn) SetData(fv []byte)

func (*SSHService_ClientIn) SetMsg 

func (m *SSHService_ClientIn) SetMsg(ofv isSSHService_ClientIn_Msg)

func (*SSHService_ClientIn) String 

func (m *SSHService_ClientIn) String() string

func (*SSHService_ClientIn) Unmarshal 

func (m *SSHService_ClientIn) Unmarshal(b []byte) error

func (*SSHService_ClientIn) UnmarshalJSON 

func (m *SSHService_ClientIn) UnmarshalJSON(data []byte) error

type SSHService_ClientIn_Data 

type SSHService_ClientIn_Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3,oneof" firestore:"data"`
}

type SSHService_ClientOut 

type SSHService_ClientOut struct {

	// Types that are valid to be assigned to Msg:
	//	*SSHService_ClientOut_Data
	//	*SSHService_ClientOut_SshHello
	//	*SSHService_ClientOut_SshResizeTerminal
	Msg isSSHService_ClientOut_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*SSHService_ClientOut) Descriptor 

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

Deprecated, Use SSHService_ClientOut.ProtoReflect.Descriptor instead.

func (*SSHService_ClientOut) GetData 

func (m *SSHService_ClientOut) GetData() []byte

func (*SSHService_ClientOut) GetMsg 

func (m *SSHService_ClientOut) GetMsg() isSSHService_ClientOut_Msg

func (*SSHService_ClientOut) GetSshHello 

func (m *SSHService_ClientOut) GetSshHello() *SSHService_Hello

func (*SSHService_ClientOut) GetSshResizeTerminal 

func (m *SSHService_ClientOut) GetSshResizeTerminal() *SSHService_TerminalSize

func (*SSHService_ClientOut) GotenMessage 

func (*SSHService_ClientOut) GotenMessage()

func (*SSHService_ClientOut) GotenValidate 

func (obj *SSHService_ClientOut) GotenValidate() error

func (*SSHService_ClientOut) Marshal 

func (m *SSHService_ClientOut) Marshal() ([]byte, error)

func (*SSHService_ClientOut) MarshalJSON 

func (m *SSHService_ClientOut) MarshalJSON() ([]byte, error)

func (*SSHService_ClientOut) ProtoMessage 

func (*SSHService_ClientOut) ProtoMessage()

func (*SSHService_ClientOut) ProtoReflect 

func (m *SSHService_ClientOut) ProtoReflect() preflect.Message

func (*SSHService_ClientOut) Reset 

func (m *SSHService_ClientOut) Reset()

func (*SSHService_ClientOut) SetData 

func (m *SSHService_ClientOut) SetData(fv []byte)

func (*SSHService_ClientOut) SetMsg 

func (m *SSHService_ClientOut) SetMsg(ofv isSSHService_ClientOut_Msg)

func (*SSHService_ClientOut) SetSshHello 

func (m *SSHService_ClientOut) SetSshHello(fv *SSHService_Hello)

func (*SSHService_ClientOut) SetSshResizeTerminal 

func (m *SSHService_ClientOut) SetSshResizeTerminal(fv *SSHService_TerminalSize)

func (*SSHService_ClientOut) String 

func (m *SSHService_ClientOut) String() string

func (*SSHService_ClientOut) Unmarshal 

func (m *SSHService_ClientOut) Unmarshal(b []byte) error

func (*SSHService_ClientOut) UnmarshalJSON 

func (m *SSHService_ClientOut) UnmarshalJSON(data []byte) error

type SSHService_ClientOut_Data 

type SSHService_ClientOut_Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3,oneof" firestore:"data"`
}

type SSHService_ClientOut_SshHello 

type SSHService_ClientOut_SshHello struct {
	SshHello *SSHService_Hello `protobuf:"bytes,2,opt,name=ssh_hello,json=sshHello,proto3,oneof" firestore:"sshHello"`
}

type SSHService_ClientOut_SshResizeTerminal 

type SSHService_ClientOut_SshResizeTerminal struct {
	SshResizeTerminal *SSHService_TerminalSize `protobuf:"bytes,3,opt,name=ssh_resize_terminal,json=sshResizeTerminal,proto3,oneof" firestore:"sshResizeTerminal"`
}

type SSHService_Hello 

type SSHService_Hello struct {
	User    string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty" firestore:"user"`
	Command []string `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty" firestore:"command"`
	// Environment (optional)
	Env map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SSHService_Hello) Descriptor 

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

Deprecated, Use SSHService_Hello.ProtoReflect.Descriptor instead.

func (*SSHService_Hello) GetCommand 

func (m *SSHService_Hello) GetCommand() []string

func (*SSHService_Hello) GetEnv 

func (m *SSHService_Hello) GetEnv() map[string]string

func (*SSHService_Hello) GetUser 

func (m *SSHService_Hello) GetUser() string

func (*SSHService_Hello) GotenMessage 

func (*SSHService_Hello) GotenMessage()

func (*SSHService_Hello) GotenValidate 

func (obj *SSHService_Hello) GotenValidate() error

func (*SSHService_Hello) Marshal 

func (m *SSHService_Hello) Marshal() ([]byte, error)

func (*SSHService_Hello) MarshalJSON 

func (m *SSHService_Hello) MarshalJSON() ([]byte, error)

func (*SSHService_Hello) ProtoMessage 

func (*SSHService_Hello) ProtoMessage()

func (*SSHService_Hello) ProtoReflect 

func (m *SSHService_Hello) ProtoReflect() preflect.Message

func (*SSHService_Hello) Reset 

func (m *SSHService_Hello) Reset()

func (*SSHService_Hello) SetCommand 

func (m *SSHService_Hello) SetCommand(fv []string)

func (*SSHService_Hello) SetEnv 

func (m *SSHService_Hello) SetEnv(fv map[string]string)

func (*SSHService_Hello) SetUser 

func (m *SSHService_Hello) SetUser(fv string)

func (*SSHService_Hello) String 

func (m *SSHService_Hello) String() string

func (*SSHService_Hello) Unmarshal 

func (m *SSHService_Hello) Unmarshal(b []byte) error

func (*SSHService_Hello) UnmarshalJSON 

func (m *SSHService_Hello) UnmarshalJSON(data []byte) error

type SSHService_TerminalSize 

type SSHService_TerminalSize struct {
	Width  uint32 `protobuf:"varint,1,opt,name=width,proto3" json:"width,omitempty" firestore:"width"`
	Height uint32 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty" firestore:"height"`
	// contains filtered or unexported fields
}

func (*SSHService_TerminalSize) Descriptor 

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

Deprecated, Use SSHService_TerminalSize.ProtoReflect.Descriptor instead.

func (*SSHService_TerminalSize) GetHeight 

func (m *SSHService_TerminalSize) GetHeight() uint32

func (*SSHService_TerminalSize) GetWidth 

func (m *SSHService_TerminalSize) GetWidth() uint32

func (*SSHService_TerminalSize) GotenMessage 

func (*SSHService_TerminalSize) GotenMessage()

func (*SSHService_TerminalSize) GotenValidate 

func (obj *SSHService_TerminalSize) GotenValidate() error

func (*SSHService_TerminalSize) Marshal 

func (m *SSHService_TerminalSize) Marshal() ([]byte, error)

func (*SSHService_TerminalSize) MarshalJSON 

func (m *SSHService_TerminalSize) MarshalJSON() ([]byte, error)

func (*SSHService_TerminalSize) ProtoMessage 

func (*SSHService_TerminalSize) ProtoMessage()

func (*SSHService_TerminalSize) ProtoReflect 

func (m *SSHService_TerminalSize) ProtoReflect() preflect.Message

func (*SSHService_TerminalSize) Reset 

func (m *SSHService_TerminalSize) Reset()

func (*SSHService_TerminalSize) SetHeight 

func (m *SSHService_TerminalSize) SetHeight(fv uint32)

func (*SSHService_TerminalSize) SetWidth 

func (m *SSHService_TerminalSize) SetWidth(fv uint32)

func (*SSHService_TerminalSize) String 

func (m *SSHService_TerminalSize) String() string

func (*SSHService_TerminalSize) Unmarshal 

func (m *SSHService_TerminalSize) Unmarshal(b []byte) error

func (*SSHService_TerminalSize) UnmarshalJSON 

func (m *SSHService_TerminalSize) UnmarshalJSON(data []byte) error

type SystemStateService 

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

func (*SystemStateService) Descriptor 

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

Deprecated, Use SystemStateService.ProtoReflect.Descriptor instead.

func (*SystemStateService) GotenMessage 

func (*SystemStateService) GotenMessage()

func (*SystemStateService) GotenValidate 

func (obj *SystemStateService) GotenValidate() error

func (*SystemStateService) Marshal 

func (m *SystemStateService) Marshal() ([]byte, error)

func (*SystemStateService) MarshalJSON 

func (m *SystemStateService) MarshalJSON() ([]byte, error)

func (*SystemStateService) ProtoMessage 

func (*SystemStateService) ProtoMessage()

func (*SystemStateService) ProtoReflect 

func (m *SystemStateService) ProtoReflect() preflect.Message

func (*SystemStateService) Reset 

func (m *SystemStateService) Reset()

func (*SystemStateService) String 

func (m *SystemStateService) String() string

func (*SystemStateService) Unmarshal 

func (m *SystemStateService) Unmarshal(b []byte) error

func (*SystemStateService) UnmarshalJSON 

func (m *SystemStateService) UnmarshalJSON(data []byte) error

type SystemStateService_SystemState 

type SystemStateService_SystemState int32

Commands for system state management 

const (
	// Unspecified system state
	SystemStateService_UNSPECIFIED SystemStateService_SystemState = 0
	// Shutdown the system
	SystemStateService_SHUTDOWN SystemStateService_SystemState = 1
	// Reboot the system
	SystemStateService_REBOOT SystemStateService_SystemState = 2
)

func (SystemStateService_SystemState) Descriptor 

func (SystemStateService_SystemState) Descriptor() preflect.EnumDescriptor

func (SystemStateService_SystemState) Enum 

func (x SystemStateService_SystemState) Enum() *SystemStateService_SystemState

func (SystemStateService_SystemState) EnumDescriptor 

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

Deprecated, Use SystemStateService_SystemState.ProtoReflect.Descriptor instead.

func (SystemStateService_SystemState) Number 

func (x SystemStateService_SystemState) Number() preflect.EnumNumber

func (SystemStateService_SystemState) String 

func (x SystemStateService_SystemState) String() string

func (SystemStateService_SystemState) Type 

func (SystemStateService_SystemState) Type() preflect.EnumType

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.