broker_client

package
v1.2.16 Latest Latest
Warning

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

Go to latest
Published: Jul 23, 2024 License: Apache-2.0 Imports: 22 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 Ack

type Ack struct {
	Processed uint64 `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty" firestore:"processed"`
	// contains filtered or unexported fields
}

Ack message that contains how much data should have been processed

func (*Ack) Descriptor

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

Deprecated, Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetProcessed

func (m *Ack) GetProcessed() uint64

func (*Ack) GotenMessage

func (*Ack) GotenMessage()

func (*Ack) GotenValidate

func (obj *Ack) GotenValidate() error

func (*Ack) Marshal

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

func (*Ack) MarshalJSON

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

func (*Ack) ProtoMessage

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect

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

func (*Ack) Reset

func (m *Ack) Reset()

func (*Ack) SetProcessed

func (m *Ack) SetProcessed(fv uint64)

func (*Ack) String

func (m *Ack) String() string

func (*Ack) Unmarshal

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

func (*Ack) UnmarshalJSON

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

type BrokerServiceClient

type BrokerServiceClient interface {
	ListenForConnections(ctx context.Context, opts ...grpc.CallOption) (ListenForConnectionsClientStream, error)
	OpenConnectionChannelSocket(ctx context.Context, opts ...grpc.CallOption) (OpenConnectionChannelSocketClientStream, error)
	ConnectToDevice(ctx context.Context, opts ...grpc.CallOption) (ConnectToDeviceClientStream, error)
}

BrokerServiceClient is the client API for BrokerService.

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

type BrokerServiceDescriptor added in v0.4.28

type BrokerServiceDescriptor struct{}

func GetBrokerServiceDescriptor added in v0.4.28

func GetBrokerServiceDescriptor() *BrokerServiceDescriptor

func (*BrokerServiceDescriptor) AllMethodDescriptors added in v0.4.28

func (d *BrokerServiceDescriptor) AllMethodDescriptors() []gotenclient.MethodDescriptor

func (*BrokerServiceDescriptor) GetApiName added in v0.4.28

func (d *BrokerServiceDescriptor) GetApiName() string

func (*BrokerServiceDescriptor) GetFullAPIName added in v0.4.28

func (d *BrokerServiceDescriptor) GetFullAPIName() string

func (*BrokerServiceDescriptor) GetProtoPkgName added in v0.4.28

func (d *BrokerServiceDescriptor) GetProtoPkgName() string

func (*BrokerServiceDescriptor) GetServiceDomain added in v0.4.28

func (d *BrokerServiceDescriptor) GetServiceDomain() string

func (*BrokerServiceDescriptor) GetServiceVersion added in v0.4.28

func (d *BrokerServiceDescriptor) GetServiceVersion() string

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) Enum

func (BrokerServiceType) EnumDescriptor

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

Deprecated, Use BrokerServiceType.ProtoReflect.Descriptor instead.

func (BrokerServiceType) Number

func (BrokerServiceType) String

func (x BrokerServiceType) String() string

func (BrokerServiceType) Type

type ConnectToDeviceClientStream

type ConnectToDeviceClientStream interface {
	Send(*ConnectToDeviceRequest) error
	Recv() (*ConnectToDeviceResponse, error)
	grpc.ClientStream
}

type ConnectToDeviceDescriptor added in v0.4.28

type ConnectToDeviceDescriptor struct{}

func GetConnectToDeviceDescriptor added in v0.4.28

func GetConnectToDeviceDescriptor() *ConnectToDeviceDescriptor

func (*ConnectToDeviceDescriptor) GetApiDescriptor added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*ConnectToDeviceDescriptor) GetApiName added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetApiName() string

func (*ConnectToDeviceDescriptor) GetClientMsgReflectHandle added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ConnectToDeviceDescriptor) GetFullMethodName added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetFullMethodName() string

func (*ConnectToDeviceDescriptor) GetMethodName added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetMethodName() string

func (*ConnectToDeviceDescriptor) GetProtoPkgName added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetProtoPkgName() string

func (*ConnectToDeviceDescriptor) GetResourceDescriptor added in v0.4.30

func (d *ConnectToDeviceDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*ConnectToDeviceDescriptor) GetServerMsgReflectHandle added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ConnectToDeviceDescriptor) GetServiceDomain added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetServiceDomain() string

func (*ConnectToDeviceDescriptor) GetServiceVersion added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetServiceVersion() string

func (*ConnectToDeviceDescriptor) GetVerb added in v0.4.28

func (d *ConnectToDeviceDescriptor) GetVerb() string

func (*ConnectToDeviceDescriptor) HasResource added in v0.4.30

func (d *ConnectToDeviceDescriptor) HasResource() bool

func (*ConnectToDeviceDescriptor) IsClientStream added in v0.4.28

func (d *ConnectToDeviceDescriptor) IsClientStream() bool

func (*ConnectToDeviceDescriptor) IsCollection added in v0.4.30

func (d *ConnectToDeviceDescriptor) IsCollection() bool

func (*ConnectToDeviceDescriptor) IsPlural added in v0.4.30

func (d *ConnectToDeviceDescriptor) IsPlural() bool

func (*ConnectToDeviceDescriptor) IsServerStream added in v0.4.28

func (d *ConnectToDeviceDescriptor) IsServerStream() bool

func (*ConnectToDeviceDescriptor) IsUnary added in v0.4.28

func (d *ConnectToDeviceDescriptor) IsUnary() bool

func (*ConnectToDeviceDescriptor) NewEmptyClientMsg added in v0.4.28

func (d *ConnectToDeviceDescriptor) NewEmptyClientMsg() proto.Message

func (*ConnectToDeviceDescriptor) NewEmptyServerMsg added in v0.4.28

func (d *ConnectToDeviceDescriptor) NewEmptyServerMsg() proto.Message

func (*ConnectToDeviceDescriptor) RequestHasResourceBody added in v0.4.28

func (d *ConnectToDeviceDescriptor) RequestHasResourceBody() bool

type ConnectToDeviceDescriptorClientMsgHandle added in v0.4.28

type ConnectToDeviceDescriptorClientMsgHandle struct{}

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type ConnectToDeviceDescriptorServerMsgHandle added in v0.4.28

type ConnectToDeviceDescriptorServerMsgHandle struct{}

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type ConnectToDeviceRequest

type ConnectToDeviceRequest struct {

	// Types that are valid to be assigned to Msg:
	//	*ConnectToDeviceRequest_OpenRequest_
	//	*ConnectToDeviceRequest_Data
	//	*ConnectToDeviceRequest_Ack
	//	*ConnectToDeviceRequest_KeepAlive_
	Msg isConnectToDeviceRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

Request message for method [ConnectToDevice][ntt.devices.v1alpha2.ConnectToDevice] ConnectToDevice connects a local service provided by a Device.

func (*ConnectToDeviceRequest) Descriptor

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

Deprecated, Use ConnectToDeviceRequest.ProtoReflect.Descriptor instead.

func (*ConnectToDeviceRequest) GetAck

func (m *ConnectToDeviceRequest) GetAck() *Ack

func (*ConnectToDeviceRequest) GetData

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

func (*ConnectToDeviceRequest) GetKeepAlive

func (*ConnectToDeviceRequest) GetMsg

func (m *ConnectToDeviceRequest) GetMsg() isConnectToDeviceRequest_Msg

func (*ConnectToDeviceRequest) GetOpenRequest

func (*ConnectToDeviceRequest) GotenMessage

func (*ConnectToDeviceRequest) GotenMessage()

func (*ConnectToDeviceRequest) GotenValidate

func (obj *ConnectToDeviceRequest) GotenValidate() error

func (*ConnectToDeviceRequest) Marshal

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

func (*ConnectToDeviceRequest) MarshalJSON

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

func (*ConnectToDeviceRequest) ProtoMessage

func (*ConnectToDeviceRequest) ProtoMessage()

func (*ConnectToDeviceRequest) ProtoReflect

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

func (*ConnectToDeviceRequest) Reset

func (m *ConnectToDeviceRequest) Reset()

func (*ConnectToDeviceRequest) SetAck

func (m *ConnectToDeviceRequest) SetAck(fv *Ack)

func (*ConnectToDeviceRequest) SetData

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

func (*ConnectToDeviceRequest) SetKeepAlive

func (*ConnectToDeviceRequest) SetMsg

func (m *ConnectToDeviceRequest) SetMsg(ofv isConnectToDeviceRequest_Msg)

func (*ConnectToDeviceRequest) SetOpenRequest

func (*ConnectToDeviceRequest) String

func (m *ConnectToDeviceRequest) String() string

func (*ConnectToDeviceRequest) Unmarshal

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

func (*ConnectToDeviceRequest) UnmarshalJSON

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

type ConnectToDeviceRequest_Ack

type ConnectToDeviceRequest_Ack struct {
	// Ack from the user to the endpoint (device)
	Ack *Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type ConnectToDeviceRequest_Data

type ConnectToDeviceRequest_Data struct {
	// Any data sent to the device through the endpoint.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" firestore:"data"`
}

type ConnectToDeviceRequest_KeepAlive

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

func (*ConnectToDeviceRequest_KeepAlive) Descriptor

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

Deprecated, Use ConnectToDeviceRequest_KeepAlive.ProtoReflect.Descriptor instead.

func (*ConnectToDeviceRequest_KeepAlive) GotenMessage

func (*ConnectToDeviceRequest_KeepAlive) GotenMessage()

func (*ConnectToDeviceRequest_KeepAlive) GotenValidate

func (obj *ConnectToDeviceRequest_KeepAlive) GotenValidate() error

func (*ConnectToDeviceRequest_KeepAlive) Marshal

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

func (*ConnectToDeviceRequest_KeepAlive) MarshalJSON

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

func (*ConnectToDeviceRequest_KeepAlive) ProtoMessage

func (*ConnectToDeviceRequest_KeepAlive) ProtoMessage()

func (*ConnectToDeviceRequest_KeepAlive) ProtoReflect

func (*ConnectToDeviceRequest_KeepAlive) Reset

func (*ConnectToDeviceRequest_KeepAlive) String

func (*ConnectToDeviceRequest_KeepAlive) Unmarshal

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

func (*ConnectToDeviceRequest_KeepAlive) UnmarshalJSON

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

type ConnectToDeviceRequest_KeepAlive_

type ConnectToDeviceRequest_KeepAlive_ struct {
	KeepAlive *ConnectToDeviceRequest_KeepAlive `protobuf:"bytes,5,opt,name=keep_alive,json=keepAlive,proto3,oneof" firestore:"keepAlive"`
}

type ConnectToDeviceRequest_OpenRequest

type ConnectToDeviceRequest_OpenRequest struct {

	// Device name to connect.
	Device *device.Name `protobuf:"bytes,1,opt,customtype=Name,name=device,proto3" json:"device,omitempty" firestore:"device"`
	// Device service
	Service BrokerServiceType `` /* 132-byte string literal not displayed */
	// Initial argument (optional)
	Arg string `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty" firestore:"arg"`
	// contains filtered or unexported fields
}

func (*ConnectToDeviceRequest_OpenRequest) Descriptor

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

Deprecated, Use ConnectToDeviceRequest_OpenRequest.ProtoReflect.Descriptor instead.

func (*ConnectToDeviceRequest_OpenRequest) GetArg

func (*ConnectToDeviceRequest_OpenRequest) GetDevice

func (*ConnectToDeviceRequest_OpenRequest) GetService

func (*ConnectToDeviceRequest_OpenRequest) GotenMessage

func (*ConnectToDeviceRequest_OpenRequest) GotenMessage()

func (*ConnectToDeviceRequest_OpenRequest) GotenValidate

func (obj *ConnectToDeviceRequest_OpenRequest) GotenValidate() error

func (*ConnectToDeviceRequest_OpenRequest) Marshal

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

func (*ConnectToDeviceRequest_OpenRequest) MarshalJSON

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

func (*ConnectToDeviceRequest_OpenRequest) ProtoMessage

func (*ConnectToDeviceRequest_OpenRequest) ProtoMessage()

func (*ConnectToDeviceRequest_OpenRequest) ProtoReflect

func (*ConnectToDeviceRequest_OpenRequest) Reset

func (*ConnectToDeviceRequest_OpenRequest) SetArg

func (*ConnectToDeviceRequest_OpenRequest) SetDevice

func (*ConnectToDeviceRequest_OpenRequest) SetService

func (*ConnectToDeviceRequest_OpenRequest) String

func (*ConnectToDeviceRequest_OpenRequest) Unmarshal

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

func (*ConnectToDeviceRequest_OpenRequest) UnmarshalJSON

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

type ConnectToDeviceRequest_OpenRequest_

type ConnectToDeviceRequest_OpenRequest_ struct {
	// The initiation message to open a channel to a device.
	OpenRequest *ConnectToDeviceRequest_OpenRequest `protobuf:"bytes,1,opt,name=open_request,json=openRequest,proto3,oneof" firestore:"openRequest"`
}

type ConnectToDeviceResponse

type ConnectToDeviceResponse struct {

	// Types that are valid to be assigned to Msg:
	//	*ConnectToDeviceResponse_OpenResponse_
	//	*ConnectToDeviceResponse_Data
	//	*ConnectToDeviceResponse_Error
	//	*ConnectToDeviceResponse_Ack
	Msg isConnectToDeviceResponse_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

Response message for method [ConnectToDevice][ntt.devices.v1alpha2.ConnectToDevice]

func (*ConnectToDeviceResponse) Descriptor

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

Deprecated, Use ConnectToDeviceResponse.ProtoReflect.Descriptor instead.

func (*ConnectToDeviceResponse) GetAck

func (m *ConnectToDeviceResponse) GetAck() *Ack

func (*ConnectToDeviceResponse) GetData

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

func (*ConnectToDeviceResponse) GetError

func (m *ConnectToDeviceResponse) GetError() []byte

func (*ConnectToDeviceResponse) GetMsg

func (m *ConnectToDeviceResponse) GetMsg() isConnectToDeviceResponse_Msg

func (*ConnectToDeviceResponse) GetOpenResponse

func (*ConnectToDeviceResponse) GotenMessage

func (*ConnectToDeviceResponse) GotenMessage()

func (*ConnectToDeviceResponse) GotenValidate

func (obj *ConnectToDeviceResponse) GotenValidate() error

func (*ConnectToDeviceResponse) Marshal

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

func (*ConnectToDeviceResponse) MarshalJSON

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

func (*ConnectToDeviceResponse) ProtoMessage

func (*ConnectToDeviceResponse) ProtoMessage()

func (*ConnectToDeviceResponse) ProtoReflect

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

func (*ConnectToDeviceResponse) Reset

func (m *ConnectToDeviceResponse) Reset()

func (*ConnectToDeviceResponse) SetAck

func (m *ConnectToDeviceResponse) SetAck(fv *Ack)

func (*ConnectToDeviceResponse) SetData

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

func (*ConnectToDeviceResponse) SetError

func (m *ConnectToDeviceResponse) SetError(fv []byte)

func (*ConnectToDeviceResponse) SetMsg

func (m *ConnectToDeviceResponse) SetMsg(ofv isConnectToDeviceResponse_Msg)

func (*ConnectToDeviceResponse) SetOpenResponse

func (*ConnectToDeviceResponse) String

func (m *ConnectToDeviceResponse) String() string

func (*ConnectToDeviceResponse) Unmarshal

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

func (*ConnectToDeviceResponse) UnmarshalJSON

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

type ConnectToDeviceResponse_Ack

type ConnectToDeviceResponse_Ack struct {
	// Ack from the device to the endpoint (client)
	Ack *Ack `protobuf:"bytes,5,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type ConnectToDeviceResponse_Data

type ConnectToDeviceResponse_Data struct {
	// Any data from the device (endpoint) to the client.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" firestore:"data"`
}

type ConnectToDeviceResponse_Error

type ConnectToDeviceResponse_Error struct {
	// Any error from the device (endpoint) to the client.
	Error []byte `protobuf:"bytes,4,opt,name=error,proto3,oneof" firestore:"error"`
}

type ConnectToDeviceResponse_OpenResponse

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

func (*ConnectToDeviceResponse_OpenResponse) Descriptor

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

Deprecated, Use ConnectToDeviceResponse_OpenResponse.ProtoReflect.Descriptor instead.

func (*ConnectToDeviceResponse_OpenResponse) GotenMessage

func (*ConnectToDeviceResponse_OpenResponse) GotenMessage()

func (*ConnectToDeviceResponse_OpenResponse) GotenValidate

func (obj *ConnectToDeviceResponse_OpenResponse) GotenValidate() error

func (*ConnectToDeviceResponse_OpenResponse) Marshal

func (*ConnectToDeviceResponse_OpenResponse) MarshalJSON

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

func (*ConnectToDeviceResponse_OpenResponse) ProtoMessage

func (*ConnectToDeviceResponse_OpenResponse) ProtoMessage()

func (*ConnectToDeviceResponse_OpenResponse) ProtoReflect

func (*ConnectToDeviceResponse_OpenResponse) Reset

func (*ConnectToDeviceResponse_OpenResponse) String

func (*ConnectToDeviceResponse_OpenResponse) Unmarshal

func (*ConnectToDeviceResponse_OpenResponse) UnmarshalJSON

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

type ConnectToDeviceResponse_OpenResponse_

type ConnectToDeviceResponse_OpenResponse_ struct {
	// Notification from the agent (endpoint) to the channel has been opened.
	OpenResponse *ConnectToDeviceResponse_OpenResponse `protobuf:"bytes,1,opt,name=open_response,json=openResponse,proto3,oneof" firestore:"openResponse"`
}

type ListenForConnectionsClientStream

type ListenForConnectionsClientStream interface {
	Send(*ListenForConnectionsRequest) error
	Recv() (*ListenForConnectionsResponse, error)
	grpc.ClientStream
}

type ListenForConnectionsDescriptor added in v0.4.28

type ListenForConnectionsDescriptor struct{}

func GetListenForConnectionsDescriptor added in v0.4.28

func GetListenForConnectionsDescriptor() *ListenForConnectionsDescriptor

func (*ListenForConnectionsDescriptor) GetApiDescriptor added in v0.4.28

func (*ListenForConnectionsDescriptor) GetApiName added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetApiName() string

func (*ListenForConnectionsDescriptor) GetClientMsgReflectHandle added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ListenForConnectionsDescriptor) GetFullMethodName added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetFullMethodName() string

func (*ListenForConnectionsDescriptor) GetMethodName added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetMethodName() string

func (*ListenForConnectionsDescriptor) GetProtoPkgName added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetProtoPkgName() string

func (*ListenForConnectionsDescriptor) GetResourceDescriptor added in v0.4.30

func (d *ListenForConnectionsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*ListenForConnectionsDescriptor) GetServerMsgReflectHandle added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ListenForConnectionsDescriptor) GetServiceDomain added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetServiceDomain() string

func (*ListenForConnectionsDescriptor) GetServiceVersion added in v0.4.28

func (d *ListenForConnectionsDescriptor) GetServiceVersion() string

func (*ListenForConnectionsDescriptor) GetVerb added in v0.4.28

func (*ListenForConnectionsDescriptor) HasResource added in v0.4.30

func (d *ListenForConnectionsDescriptor) HasResource() bool

func (*ListenForConnectionsDescriptor) IsClientStream added in v0.4.28

func (d *ListenForConnectionsDescriptor) IsClientStream() bool

func (*ListenForConnectionsDescriptor) IsCollection added in v0.4.30

func (d *ListenForConnectionsDescriptor) IsCollection() bool

func (*ListenForConnectionsDescriptor) IsPlural added in v0.4.30

func (d *ListenForConnectionsDescriptor) IsPlural() bool

func (*ListenForConnectionsDescriptor) IsServerStream added in v0.4.28

func (d *ListenForConnectionsDescriptor) IsServerStream() bool

func (*ListenForConnectionsDescriptor) IsUnary added in v0.4.28

func (d *ListenForConnectionsDescriptor) IsUnary() bool

func (*ListenForConnectionsDescriptor) NewEmptyClientMsg added in v0.4.28

func (d *ListenForConnectionsDescriptor) NewEmptyClientMsg() proto.Message

func (*ListenForConnectionsDescriptor) NewEmptyServerMsg added in v0.4.28

func (d *ListenForConnectionsDescriptor) NewEmptyServerMsg() proto.Message

func (*ListenForConnectionsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *ListenForConnectionsDescriptor) RequestHasResourceBody() bool

type ListenForConnectionsDescriptorClientMsgHandle added in v0.4.28

type ListenForConnectionsDescriptorClientMsgHandle struct{}

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type ListenForConnectionsDescriptorServerMsgHandle added in v0.4.28

type ListenForConnectionsDescriptorServerMsgHandle struct{}

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type ListenForConnectionsRequest

type ListenForConnectionsRequest struct {

	// Types that are valid to be assigned to Msg:
	//	*ListenForConnectionsRequest_RegisterListener_
	//	*ListenForConnectionsRequest_ChannelOpenError_
	//	*ListenForConnectionsRequest_KeepAlive_
	Msg isListenForConnectionsRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

Request message for method [ListenForConnections][ntt.devices.v1alpha2.ListenForConnections] Registers a new session listener (agent) to the endpoint. This method is used by agents on the device and not meant for use of users.

func (*ListenForConnectionsRequest) Descriptor

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

Deprecated, Use ListenForConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsRequest) GetChannelOpenError

func (*ListenForConnectionsRequest) GetKeepAlive

func (*ListenForConnectionsRequest) GetMsg

func (m *ListenForConnectionsRequest) GetMsg() isListenForConnectionsRequest_Msg

func (*ListenForConnectionsRequest) GetRegisterListener

func (*ListenForConnectionsRequest) GotenMessage

func (*ListenForConnectionsRequest) GotenMessage()

func (*ListenForConnectionsRequest) GotenValidate

func (obj *ListenForConnectionsRequest) GotenValidate() error

func (*ListenForConnectionsRequest) Marshal

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

func (*ListenForConnectionsRequest) MarshalJSON

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

func (*ListenForConnectionsRequest) ProtoMessage

func (*ListenForConnectionsRequest) ProtoMessage()

func (*ListenForConnectionsRequest) ProtoReflect

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

func (*ListenForConnectionsRequest) Reset

func (m *ListenForConnectionsRequest) Reset()

func (*ListenForConnectionsRequest) SetChannelOpenError

func (*ListenForConnectionsRequest) SetKeepAlive

func (*ListenForConnectionsRequest) SetMsg

func (m *ListenForConnectionsRequest) SetMsg(ofv isListenForConnectionsRequest_Msg)

func (*ListenForConnectionsRequest) SetRegisterListener

func (*ListenForConnectionsRequest) String

func (m *ListenForConnectionsRequest) String() string

func (*ListenForConnectionsRequest) Unmarshal

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

func (*ListenForConnectionsRequest) UnmarshalJSON

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

type ListenForConnectionsRequest_ChannelOpenError

type ListenForConnectionsRequest_ChannelOpenError struct {

	// ID of the channel failed to open.
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty" firestore:"channel"`
	// Error message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" firestore:"message"`
	// contains filtered or unexported fields
}

func (*ListenForConnectionsRequest_ChannelOpenError) Descriptor

Deprecated, Use ListenForConnectionsRequest_ChannelOpenError.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsRequest_ChannelOpenError) GetChannel

func (*ListenForConnectionsRequest_ChannelOpenError) GetMessage

func (*ListenForConnectionsRequest_ChannelOpenError) GotenMessage

func (*ListenForConnectionsRequest_ChannelOpenError) GotenValidate

func (*ListenForConnectionsRequest_ChannelOpenError) Marshal

func (*ListenForConnectionsRequest_ChannelOpenError) MarshalJSON

func (*ListenForConnectionsRequest_ChannelOpenError) ProtoMessage

func (*ListenForConnectionsRequest_ChannelOpenError) ProtoReflect

func (*ListenForConnectionsRequest_ChannelOpenError) Reset

func (*ListenForConnectionsRequest_ChannelOpenError) SetChannel

func (*ListenForConnectionsRequest_ChannelOpenError) SetMessage

func (*ListenForConnectionsRequest_ChannelOpenError) String

func (*ListenForConnectionsRequest_ChannelOpenError) Unmarshal

func (*ListenForConnectionsRequest_ChannelOpenError) UnmarshalJSON

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

type ListenForConnectionsRequest_ChannelOpenError_

type ListenForConnectionsRequest_ChannelOpenError_ struct {
	// When the agent failed to open a requested channel, this message will be
	// sent from the agent to the endpoint.
	ChannelOpenError *ListenForConnectionsRequest_ChannelOpenError `protobuf:"bytes,2,opt,name=channel_open_error,json=channelOpenError,proto3,oneof" firestore:"channelOpenError"`
}

type ListenForConnectionsRequest_KeepAlive

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

func (*ListenForConnectionsRequest_KeepAlive) Descriptor

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

Deprecated, Use ListenForConnectionsRequest_KeepAlive.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsRequest_KeepAlive) GotenMessage

func (*ListenForConnectionsRequest_KeepAlive) GotenMessage()

func (*ListenForConnectionsRequest_KeepAlive) GotenValidate

func (obj *ListenForConnectionsRequest_KeepAlive) GotenValidate() error

func (*ListenForConnectionsRequest_KeepAlive) Marshal

func (*ListenForConnectionsRequest_KeepAlive) MarshalJSON

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

func (*ListenForConnectionsRequest_KeepAlive) ProtoMessage

func (*ListenForConnectionsRequest_KeepAlive) ProtoMessage()

func (*ListenForConnectionsRequest_KeepAlive) ProtoReflect

func (*ListenForConnectionsRequest_KeepAlive) Reset

func (*ListenForConnectionsRequest_KeepAlive) String

func (*ListenForConnectionsRequest_KeepAlive) Unmarshal

func (*ListenForConnectionsRequest_KeepAlive) UnmarshalJSON

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

type ListenForConnectionsRequest_KeepAlive_

type ListenForConnectionsRequest_KeepAlive_ struct {
	// KeepAlive.
	KeepAlive *ListenForConnectionsRequest_KeepAlive `protobuf:"bytes,3,opt,name=keep_alive,json=keepAlive,proto3,oneof" firestore:"keepAlive"`
}

type ListenForConnectionsRequest_RegisterListener

type ListenForConnectionsRequest_RegisterListener struct {

	// The self-declared device name, used for authentication/authorization.
	Device *device.Name `protobuf:"bytes,1,opt,customtype=Name,name=device,proto3" json:"device,omitempty" firestore:"device"`
	// contains filtered or unexported fields
}

func (*ListenForConnectionsRequest_RegisterListener) Descriptor

Deprecated, Use ListenForConnectionsRequest_RegisterListener.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsRequest_RegisterListener) GetDevice

func (*ListenForConnectionsRequest_RegisterListener) GotenMessage

func (*ListenForConnectionsRequest_RegisterListener) GotenValidate

func (*ListenForConnectionsRequest_RegisterListener) Marshal

func (*ListenForConnectionsRequest_RegisterListener) MarshalJSON

func (*ListenForConnectionsRequest_RegisterListener) ProtoMessage

func (*ListenForConnectionsRequest_RegisterListener) ProtoReflect

func (*ListenForConnectionsRequest_RegisterListener) Reset

func (*ListenForConnectionsRequest_RegisterListener) SetDevice

func (*ListenForConnectionsRequest_RegisterListener) String

func (*ListenForConnectionsRequest_RegisterListener) Unmarshal

func (*ListenForConnectionsRequest_RegisterListener) UnmarshalJSON

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

type ListenForConnectionsRequest_RegisterListener_

type ListenForConnectionsRequest_RegisterListener_ struct {
	// This is a hello message from the agent with its name.
	RegisterListener *ListenForConnectionsRequest_RegisterListener `protobuf:"bytes,1,opt,name=register_listener,json=registerListener,proto3,oneof" firestore:"registerListener"`
}

type ListenForConnectionsResponse

type ListenForConnectionsResponse struct {

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

Response message for method [ListenForConnections][ntt.devices.v1alpha2.ListenForConnections] Responses from the endpoint to session agents.

func (*ListenForConnectionsResponse) Descriptor

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

Deprecated, Use ListenForConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsResponse) GetChannelRequested

func (*ListenForConnectionsResponse) GetKeepAlive added in v0.12.69

func (*ListenForConnectionsResponse) GetMsg

func (m *ListenForConnectionsResponse) GetMsg() isListenForConnectionsResponse_Msg

func (*ListenForConnectionsResponse) GotenMessage

func (*ListenForConnectionsResponse) GotenMessage()

func (*ListenForConnectionsResponse) GotenValidate

func (obj *ListenForConnectionsResponse) GotenValidate() error

func (*ListenForConnectionsResponse) Marshal

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

func (*ListenForConnectionsResponse) MarshalJSON

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

func (*ListenForConnectionsResponse) ProtoMessage

func (*ListenForConnectionsResponse) ProtoMessage()

func (*ListenForConnectionsResponse) ProtoReflect

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

func (*ListenForConnectionsResponse) Reset

func (m *ListenForConnectionsResponse) Reset()

func (*ListenForConnectionsResponse) SetChannelRequested

func (*ListenForConnectionsResponse) SetKeepAlive added in v0.12.69

func (*ListenForConnectionsResponse) SetMsg

func (m *ListenForConnectionsResponse) SetMsg(ofv isListenForConnectionsResponse_Msg)

func (*ListenForConnectionsResponse) String

func (*ListenForConnectionsResponse) Unmarshal

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

func (*ListenForConnectionsResponse) UnmarshalJSON

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

type ListenForConnectionsResponse_ChannelRequested

type ListenForConnectionsResponse_ChannelRequested struct {

	// Channel ID
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty" firestore:"channel"`
	// Device service;
	Service BrokerServiceType `` /* 132-byte string literal not displayed */
	// Initial argument (optional)
	Arg string `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty" firestore:"arg"`
	// contains filtered or unexported fields
}

func (*ListenForConnectionsResponse_ChannelRequested) Descriptor

Deprecated, Use ListenForConnectionsResponse_ChannelRequested.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsResponse_ChannelRequested) GetArg

func (*ListenForConnectionsResponse_ChannelRequested) GetChannel

func (*ListenForConnectionsResponse_ChannelRequested) GetService

func (*ListenForConnectionsResponse_ChannelRequested) GotenMessage

func (*ListenForConnectionsResponse_ChannelRequested) GotenValidate

func (*ListenForConnectionsResponse_ChannelRequested) Marshal

func (*ListenForConnectionsResponse_ChannelRequested) MarshalJSON

func (*ListenForConnectionsResponse_ChannelRequested) ProtoMessage

func (*ListenForConnectionsResponse_ChannelRequested) ProtoReflect

func (*ListenForConnectionsResponse_ChannelRequested) Reset

func (*ListenForConnectionsResponse_ChannelRequested) SetArg

func (*ListenForConnectionsResponse_ChannelRequested) SetChannel

func (*ListenForConnectionsResponse_ChannelRequested) SetService

func (*ListenForConnectionsResponse_ChannelRequested) String

func (*ListenForConnectionsResponse_ChannelRequested) Unmarshal

func (*ListenForConnectionsResponse_ChannelRequested) UnmarshalJSON

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

type ListenForConnectionsResponse_ChannelRequested_

type ListenForConnectionsResponse_ChannelRequested_ struct {
	// Notifies a new channel has been requested by a client.
	ChannelRequested *ListenForConnectionsResponse_ChannelRequested `protobuf:"bytes,1,opt,name=channel_requested,json=channelRequested,proto3,oneof" firestore:"channelRequested"`
}

type ListenForConnectionsResponse_KeepAlive added in v0.12.69

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

func (*ListenForConnectionsResponse_KeepAlive) Descriptor added in v0.12.69

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

Deprecated, Use ListenForConnectionsResponse_KeepAlive.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsResponse_KeepAlive) GotenMessage added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) GotenValidate added in v0.12.69

func (obj *ListenForConnectionsResponse_KeepAlive) GotenValidate() error

func (*ListenForConnectionsResponse_KeepAlive) Marshal added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) MarshalJSON added in v0.12.69

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

func (*ListenForConnectionsResponse_KeepAlive) ProtoMessage added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) ProtoReflect added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) Reset added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) String added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) Unmarshal added in v0.12.69

func (*ListenForConnectionsResponse_KeepAlive) UnmarshalJSON added in v0.12.69

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

type ListenForConnectionsResponse_KeepAlive_ added in v0.12.69

type ListenForConnectionsResponse_KeepAlive_ struct {
	// Keepalive
	KeepAlive *ListenForConnectionsResponse_KeepAlive `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3,oneof" firestore:"keepAlive"`
}

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 OpenConnectionChannelSocketClientStream

type OpenConnectionChannelSocketClientStream interface {
	Send(*OpenConnectionChannelSocketRequest) error
	Recv() (*OpenConnectionChannelSocketResponse, error)
	grpc.ClientStream
}

type OpenConnectionChannelSocketDescriptor added in v0.4.28

type OpenConnectionChannelSocketDescriptor struct{}

func GetOpenConnectionChannelSocketDescriptor added in v0.4.28

func GetOpenConnectionChannelSocketDescriptor() *OpenConnectionChannelSocketDescriptor

func (*OpenConnectionChannelSocketDescriptor) GetApiDescriptor added in v0.4.28

func (*OpenConnectionChannelSocketDescriptor) GetApiName added in v0.4.28

func (*OpenConnectionChannelSocketDescriptor) GetClientMsgReflectHandle added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*OpenConnectionChannelSocketDescriptor) GetFullMethodName added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetFullMethodName() string

func (*OpenConnectionChannelSocketDescriptor) GetMethodName added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetMethodName() string

func (*OpenConnectionChannelSocketDescriptor) GetProtoPkgName added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetProtoPkgName() string

func (*OpenConnectionChannelSocketDescriptor) GetResourceDescriptor added in v0.4.30

func (*OpenConnectionChannelSocketDescriptor) GetServerMsgReflectHandle added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*OpenConnectionChannelSocketDescriptor) GetServiceDomain added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetServiceDomain() string

func (*OpenConnectionChannelSocketDescriptor) GetServiceVersion added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) GetServiceVersion() string

func (*OpenConnectionChannelSocketDescriptor) GetVerb added in v0.4.28

func (*OpenConnectionChannelSocketDescriptor) HasResource added in v0.4.30

func (*OpenConnectionChannelSocketDescriptor) IsClientStream added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) IsClientStream() bool

func (*OpenConnectionChannelSocketDescriptor) IsCollection added in v0.4.30

func (d *OpenConnectionChannelSocketDescriptor) IsCollection() bool

func (*OpenConnectionChannelSocketDescriptor) IsPlural added in v0.4.30

func (*OpenConnectionChannelSocketDescriptor) IsServerStream added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) IsServerStream() bool

func (*OpenConnectionChannelSocketDescriptor) IsUnary added in v0.4.28

func (*OpenConnectionChannelSocketDescriptor) NewEmptyClientMsg added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) NewEmptyClientMsg() proto.Message

func (*OpenConnectionChannelSocketDescriptor) NewEmptyServerMsg added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) NewEmptyServerMsg() proto.Message

func (*OpenConnectionChannelSocketDescriptor) RequestHasResourceBody added in v0.4.28

func (d *OpenConnectionChannelSocketDescriptor) RequestHasResourceBody() bool

type OpenConnectionChannelSocketDescriptorClientMsgHandle added in v0.4.28

type OpenConnectionChannelSocketDescriptorClientMsgHandle struct{}

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type OpenConnectionChannelSocketDescriptorServerMsgHandle added in v0.4.28

type OpenConnectionChannelSocketDescriptorServerMsgHandle struct{}

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type OpenConnectionChannelSocketRequest

type OpenConnectionChannelSocketRequest struct {

	// Types that are valid to be assigned to Msg:
	//	*OpenConnectionChannelSocketRequest_RegisterSocket_
	//	*OpenConnectionChannelSocketRequest_Data
	//	*OpenConnectionChannelSocketRequest_Error
	//	*OpenConnectionChannelSocketRequest_Ack
	Msg isOpenConnectionChannelSocketRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

Request message for method [OpenConnectionChannelSocket][ntt.devices.v1alpha2.OpenConnectionChannelSocket] Opens a new socket for a session by agent at an endpoint. This session is usually initiated by the agent who received a `ChannelRequested` message on a ListenForConnection session. The session is used for data plane to transfer data for a channel between the endpoint and the agent.

func (*OpenConnectionChannelSocketRequest) Descriptor

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

Deprecated, Use OpenConnectionChannelSocketRequest.ProtoReflect.Descriptor instead.

func (*OpenConnectionChannelSocketRequest) GetAck

func (*OpenConnectionChannelSocketRequest) GetData

func (*OpenConnectionChannelSocketRequest) GetError

func (m *OpenConnectionChannelSocketRequest) GetError() []byte

func (*OpenConnectionChannelSocketRequest) GetMsg

func (m *OpenConnectionChannelSocketRequest) GetMsg() isOpenConnectionChannelSocketRequest_Msg

func (*OpenConnectionChannelSocketRequest) GetRegisterSocket

func (*OpenConnectionChannelSocketRequest) GotenMessage

func (*OpenConnectionChannelSocketRequest) GotenMessage()

func (*OpenConnectionChannelSocketRequest) GotenValidate

func (obj *OpenConnectionChannelSocketRequest) GotenValidate() error

func (*OpenConnectionChannelSocketRequest) Marshal

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

func (*OpenConnectionChannelSocketRequest) MarshalJSON

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

func (*OpenConnectionChannelSocketRequest) ProtoMessage

func (*OpenConnectionChannelSocketRequest) ProtoMessage()

func (*OpenConnectionChannelSocketRequest) ProtoReflect

func (*OpenConnectionChannelSocketRequest) Reset

func (*OpenConnectionChannelSocketRequest) SetAck

func (m *OpenConnectionChannelSocketRequest) SetAck(fv *Ack)

func (*OpenConnectionChannelSocketRequest) SetData

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

func (*OpenConnectionChannelSocketRequest) SetError

func (m *OpenConnectionChannelSocketRequest) SetError(fv []byte)

func (*OpenConnectionChannelSocketRequest) SetMsg

func (m *OpenConnectionChannelSocketRequest) SetMsg(ofv isOpenConnectionChannelSocketRequest_Msg)

func (*OpenConnectionChannelSocketRequest) SetRegisterSocket

func (*OpenConnectionChannelSocketRequest) String

func (*OpenConnectionChannelSocketRequest) Unmarshal

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

func (*OpenConnectionChannelSocketRequest) UnmarshalJSON

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

type OpenConnectionChannelSocketRequest_Ack

type OpenConnectionChannelSocketRequest_Ack struct {
	// Ack from the agent to the endpoint (client)
	Ack *Ack `protobuf:"bytes,5,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type OpenConnectionChannelSocketRequest_Data

type OpenConnectionChannelSocketRequest_Data struct {
	// Data from the agent to the endpoint (client).
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" firestore:"data"`
}

type OpenConnectionChannelSocketRequest_Error

type OpenConnectionChannelSocketRequest_Error struct {
	// Error from the agent to the endpoint (client).
	Error []byte `protobuf:"bytes,4,opt,name=error,proto3,oneof" firestore:"error"`
}

type OpenConnectionChannelSocketRequest_RegisterSocket

type OpenConnectionChannelSocketRequest_RegisterSocket struct {

	// Device name, to be authenticated/authorized.
	Device *device.Name `protobuf:"bytes,1,opt,customtype=Name,name=device,proto3" json:"device,omitempty" firestore:"device"`
	// Channel ID, requested by the endpoint in the ChannelRequested message.
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty" firestore:"channel"`
	// contains filtered or unexported fields
}

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Descriptor

Deprecated, Use OpenConnectionChannelSocketRequest_RegisterSocket.ProtoReflect.Descriptor instead.

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GetChannel

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GetDevice

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GotenMessage

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GotenValidate

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Marshal

func (*OpenConnectionChannelSocketRequest_RegisterSocket) MarshalJSON

func (*OpenConnectionChannelSocketRequest_RegisterSocket) ProtoMessage

func (*OpenConnectionChannelSocketRequest_RegisterSocket) ProtoReflect

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Reset

func (*OpenConnectionChannelSocketRequest_RegisterSocket) SetChannel

func (*OpenConnectionChannelSocketRequest_RegisterSocket) SetDevice

func (*OpenConnectionChannelSocketRequest_RegisterSocket) String

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Unmarshal

func (*OpenConnectionChannelSocketRequest_RegisterSocket) UnmarshalJSON

type OpenConnectionChannelSocketRequest_RegisterSocket_

type OpenConnectionChannelSocketRequest_RegisterSocket_ struct {
	// Registers a new socket on the endpoint.
	RegisterSocket *OpenConnectionChannelSocketRequest_RegisterSocket `protobuf:"bytes,1,opt,name=register_socket,json=registerSocket,proto3,oneof" firestore:"registerSocket"`
}

type OpenConnectionChannelSocketResponse

type OpenConnectionChannelSocketResponse struct {

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

Response message for method [OpenConnectionChannelSocket][ntt.devices.v1alpha2.OpenConnectionChannelSocket]

func (*OpenConnectionChannelSocketResponse) Descriptor

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

Deprecated, Use OpenConnectionChannelSocketResponse.ProtoReflect.Descriptor instead.

func (*OpenConnectionChannelSocketResponse) GetAck

func (*OpenConnectionChannelSocketResponse) GetData

func (*OpenConnectionChannelSocketResponse) GetMsg

func (m *OpenConnectionChannelSocketResponse) GetMsg() isOpenConnectionChannelSocketResponse_Msg

func (*OpenConnectionChannelSocketResponse) GotenMessage

func (*OpenConnectionChannelSocketResponse) GotenMessage()

func (*OpenConnectionChannelSocketResponse) GotenValidate

func (obj *OpenConnectionChannelSocketResponse) GotenValidate() error

func (*OpenConnectionChannelSocketResponse) Marshal

func (*OpenConnectionChannelSocketResponse) MarshalJSON

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

func (*OpenConnectionChannelSocketResponse) ProtoMessage

func (*OpenConnectionChannelSocketResponse) ProtoMessage()

func (*OpenConnectionChannelSocketResponse) ProtoReflect

func (*OpenConnectionChannelSocketResponse) Reset

func (*OpenConnectionChannelSocketResponse) SetAck

func (*OpenConnectionChannelSocketResponse) SetData

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

func (*OpenConnectionChannelSocketResponse) SetMsg

func (m *OpenConnectionChannelSocketResponse) SetMsg(ofv isOpenConnectionChannelSocketResponse_Msg)

func (*OpenConnectionChannelSocketResponse) String

func (*OpenConnectionChannelSocketResponse) Unmarshal

func (*OpenConnectionChannelSocketResponse) UnmarshalJSON

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

type OpenConnectionChannelSocketResponse_Ack

type OpenConnectionChannelSocketResponse_Ack struct {
	// Ack from the client to the endpoint (device)
	Ack *Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type OpenConnectionChannelSocketResponse_Data

type OpenConnectionChannelSocketResponse_Data struct {
	// Data from the endpoint (client) to the agent.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3,oneof" firestore:"data"`
}

type PodManagementService

type PodManagementService struct {

	// Pod state command
	Command PodManagementService_PodState `` /* 144-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 (*PodManagementService) GetPod

func (m *PodManagementService) GetPod() string

func (*PodManagementService) GetService added in v0.10.6

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 (*PodManagementService) SetPod

func (m *PodManagementService) SetPod(fv string)

func (*PodManagementService) SetService added in v0.10.6

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) Enum

func (PodManagementService_PodState) EnumDescriptor

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

Deprecated, Use PodManagementService_PodState.ProtoReflect.Descriptor instead.

func (PodManagementService_PodState) Number

func (PodManagementService_PodState) String

func (PodManagementService_PodState) Type

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 (*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 `` /* 151-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 (*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 (*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) Enum

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 (SCPService_Configure_Direction) String

func (SCPService_Configure_Direction) Type

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 (*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 (*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 (*SCPService_CreateFile_Initialize) GetPath

func (*SCPService_CreateFile_Initialize) GetSize

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 (*SCPService_CreateFile_Initialize) Reset

func (*SCPService_CreateFile_Initialize) SetMode

func (*SCPService_CreateFile_Initialize) SetPath

func (*SCPService_CreateFile_Initialize) SetSize

func (*SCPService_CreateFile_Initialize) 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) Enum

func (SystemStateService_SystemState) EnumDescriptor

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

Deprecated, Use SystemStateService_SystemState.ProtoReflect.Descriptor instead.

func (SystemStateService_SystemState) Number

func (SystemStateService_SystemState) String

func (SystemStateService_SystemState) Type

Jump to

Keyboard shortcuts

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