broker_client

package
v1.2.12 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 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.

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc grpc.ClientConnInterface) BrokerServiceClient

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) 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 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 (h *ConnectToDeviceDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21 

func (h *ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21 

func (h *ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30 

func (h *ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30 

func (h *ConnectToDeviceDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type ConnectToDeviceDescriptorServerMsgHandle added in v0.4.28 

type ConnectToDeviceDescriptorServerMsgHandle struct{}

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30 

func (h *ConnectToDeviceDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21 

func (h *ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21 

func (h *ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30 

func (h *ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30 

func (h *ConnectToDeviceDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

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 (m *ConnectToDeviceRequest) GetKeepAlive() *ConnectToDeviceRequest_KeepAlive

func (*ConnectToDeviceRequest) GetMsg 

func (m *ConnectToDeviceRequest) GetMsg() isConnectToDeviceRequest_Msg

func (*ConnectToDeviceRequest) GetOpenRequest 

func (m *ConnectToDeviceRequest) GetOpenRequest() *ConnectToDeviceRequest_OpenRequest

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 (m *ConnectToDeviceRequest) SetKeepAlive(fv *ConnectToDeviceRequest_KeepAlive)

func (*ConnectToDeviceRequest) SetMsg 

func (m *ConnectToDeviceRequest) SetMsg(ofv isConnectToDeviceRequest_Msg)

func (*ConnectToDeviceRequest) SetOpenRequest 

func (m *ConnectToDeviceRequest) SetOpenRequest(fv *ConnectToDeviceRequest_OpenRequest)

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 (m *ConnectToDeviceRequest_KeepAlive) ProtoReflect() preflect.Message

func (*ConnectToDeviceRequest_KeepAlive) Reset 

func (m *ConnectToDeviceRequest_KeepAlive) Reset()

func (*ConnectToDeviceRequest_KeepAlive) String 

func (m *ConnectToDeviceRequest_KeepAlive) String() 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 (m *ConnectToDeviceRequest_OpenRequest) GetArg() string

func (*ConnectToDeviceRequest_OpenRequest) GetDevice 

func (m *ConnectToDeviceRequest_OpenRequest) GetDevice() *device.Name

func (*ConnectToDeviceRequest_OpenRequest) GetService 

func (m *ConnectToDeviceRequest_OpenRequest) GetService() BrokerServiceType

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 (m *ConnectToDeviceRequest_OpenRequest) ProtoReflect() preflect.Message

func (*ConnectToDeviceRequest_OpenRequest) Reset 

func (m *ConnectToDeviceRequest_OpenRequest) Reset()

func (*ConnectToDeviceRequest_OpenRequest) SetArg 

func (m *ConnectToDeviceRequest_OpenRequest) SetArg(fv string)

func (*ConnectToDeviceRequest_OpenRequest) SetDevice 

func (m *ConnectToDeviceRequest_OpenRequest) SetDevice(fv *device.Name)

func (*ConnectToDeviceRequest_OpenRequest) SetService 

func (m *ConnectToDeviceRequest_OpenRequest) SetService(fv BrokerServiceType)

func (*ConnectToDeviceRequest_OpenRequest) String 

func (m *ConnectToDeviceRequest_OpenRequest) String() 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 (m *ConnectToDeviceResponse) GetOpenResponse() *ConnectToDeviceResponse_OpenResponse

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 (m *ConnectToDeviceResponse) SetOpenResponse(fv *ConnectToDeviceResponse_OpenResponse)

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 (m *ConnectToDeviceResponse_OpenResponse) Marshal() ([]byte, error)

func (*ConnectToDeviceResponse_OpenResponse) MarshalJSON 

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

func (*ConnectToDeviceResponse_OpenResponse) ProtoMessage 

func (*ConnectToDeviceResponse_OpenResponse) ProtoMessage()

func (*ConnectToDeviceResponse_OpenResponse) ProtoReflect 

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

func (*ConnectToDeviceResponse_OpenResponse) Reset 

func (m *ConnectToDeviceResponse_OpenResponse) Reset()

func (*ConnectToDeviceResponse_OpenResponse) String 

func (m *ConnectToDeviceResponse_OpenResponse) String() string

func (*ConnectToDeviceResponse_OpenResponse) Unmarshal 

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

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 (d *ListenForConnectionsDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

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 (d *ListenForConnectionsDescriptor) GetVerb() string

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 (h *ListenForConnectionsDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21 

func (h *ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21 

func (h *ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30 

func (h *ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30 

func (h *ListenForConnectionsDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type ListenForConnectionsDescriptorServerMsgHandle added in v0.4.28 

type ListenForConnectionsDescriptorServerMsgHandle struct{}

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30 

func (h *ListenForConnectionsDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21 

func (h *ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21 

func (h *ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30 

func (h *ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30 

func (h *ListenForConnectionsDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

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 (m *ListenForConnectionsRequest) GetChannelOpenError() *ListenForConnectionsRequest_ChannelOpenError

func (*ListenForConnectionsRequest) GetKeepAlive 

func (m *ListenForConnectionsRequest) GetKeepAlive() *ListenForConnectionsRequest_KeepAlive

func (*ListenForConnectionsRequest) GetMsg 

func (m *ListenForConnectionsRequest) GetMsg() isListenForConnectionsRequest_Msg

func (*ListenForConnectionsRequest) GetRegisterListener 

func (m *ListenForConnectionsRequest) GetRegisterListener() *ListenForConnectionsRequest_RegisterListener

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 (m *ListenForConnectionsRequest) SetChannelOpenError(fv *ListenForConnectionsRequest_ChannelOpenError)

func (*ListenForConnectionsRequest) SetKeepAlive 

func (m *ListenForConnectionsRequest) SetKeepAlive(fv *ListenForConnectionsRequest_KeepAlive)

func (*ListenForConnectionsRequest) SetMsg 

func (m *ListenForConnectionsRequest) SetMsg(ofv isListenForConnectionsRequest_Msg)

func (*ListenForConnectionsRequest) SetRegisterListener 

func (m *ListenForConnectionsRequest) SetRegisterListener(fv *ListenForConnectionsRequest_RegisterListener)

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 

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

Deprecated, Use ListenForConnectionsRequest_ChannelOpenError.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsRequest_ChannelOpenError) GetChannel 

func (m *ListenForConnectionsRequest_ChannelOpenError) GetChannel() string

func (*ListenForConnectionsRequest_ChannelOpenError) GetMessage 

func (m *ListenForConnectionsRequest_ChannelOpenError) GetMessage() string

func (*ListenForConnectionsRequest_ChannelOpenError) GotenMessage 

func (*ListenForConnectionsRequest_ChannelOpenError) GotenMessage()

func (*ListenForConnectionsRequest_ChannelOpenError) GotenValidate 

func (obj *ListenForConnectionsRequest_ChannelOpenError) GotenValidate() error

func (*ListenForConnectionsRequest_ChannelOpenError) Marshal 

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

func (*ListenForConnectionsRequest_ChannelOpenError) MarshalJSON 

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

func (*ListenForConnectionsRequest_ChannelOpenError) ProtoMessage 

func (*ListenForConnectionsRequest_ChannelOpenError) ProtoMessage()

func (*ListenForConnectionsRequest_ChannelOpenError) ProtoReflect 

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

func (*ListenForConnectionsRequest_ChannelOpenError) Reset 

func (m *ListenForConnectionsRequest_ChannelOpenError) Reset()

func (*ListenForConnectionsRequest_ChannelOpenError) SetChannel 

func (m *ListenForConnectionsRequest_ChannelOpenError) SetChannel(fv string)

func (*ListenForConnectionsRequest_ChannelOpenError) SetMessage 

func (m *ListenForConnectionsRequest_ChannelOpenError) SetMessage(fv string)

func (*ListenForConnectionsRequest_ChannelOpenError) String 

func (m *ListenForConnectionsRequest_ChannelOpenError) String() string

func (*ListenForConnectionsRequest_ChannelOpenError) Unmarshal 

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

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 (m *ListenForConnectionsRequest_KeepAlive) Marshal() ([]byte, error)

func (*ListenForConnectionsRequest_KeepAlive) MarshalJSON 

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

func (*ListenForConnectionsRequest_KeepAlive) ProtoMessage 

func (*ListenForConnectionsRequest_KeepAlive) ProtoMessage()

func (*ListenForConnectionsRequest_KeepAlive) ProtoReflect 

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

func (*ListenForConnectionsRequest_KeepAlive) Reset 

func (m *ListenForConnectionsRequest_KeepAlive) Reset()

func (*ListenForConnectionsRequest_KeepAlive) String 

func (m *ListenForConnectionsRequest_KeepAlive) String() string

func (*ListenForConnectionsRequest_KeepAlive) Unmarshal 

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

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 

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

Deprecated, Use ListenForConnectionsRequest_RegisterListener.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsRequest_RegisterListener) GetDevice 

func (m *ListenForConnectionsRequest_RegisterListener) GetDevice() *device.Name

func (*ListenForConnectionsRequest_RegisterListener) GotenMessage 

func (*ListenForConnectionsRequest_RegisterListener) GotenMessage()

func (*ListenForConnectionsRequest_RegisterListener) GotenValidate 

func (obj *ListenForConnectionsRequest_RegisterListener) GotenValidate() error

func (*ListenForConnectionsRequest_RegisterListener) Marshal 

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

func (*ListenForConnectionsRequest_RegisterListener) MarshalJSON 

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

func (*ListenForConnectionsRequest_RegisterListener) ProtoMessage 

func (*ListenForConnectionsRequest_RegisterListener) ProtoMessage()

func (*ListenForConnectionsRequest_RegisterListener) ProtoReflect 

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

func (*ListenForConnectionsRequest_RegisterListener) Reset 

func (m *ListenForConnectionsRequest_RegisterListener) Reset()

func (*ListenForConnectionsRequest_RegisterListener) SetDevice 

func (m *ListenForConnectionsRequest_RegisterListener) SetDevice(fv *device.Name)

func (*ListenForConnectionsRequest_RegisterListener) String 

func (m *ListenForConnectionsRequest_RegisterListener) String() string

func (*ListenForConnectionsRequest_RegisterListener) Unmarshal 

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

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 (m *ListenForConnectionsResponse) GetChannelRequested() *ListenForConnectionsResponse_ChannelRequested

func (*ListenForConnectionsResponse) GetKeepAlive added in v0.12.69 

func (m *ListenForConnectionsResponse) GetKeepAlive() *ListenForConnectionsResponse_KeepAlive

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 (m *ListenForConnectionsResponse) SetChannelRequested(fv *ListenForConnectionsResponse_ChannelRequested)

func (*ListenForConnectionsResponse) SetKeepAlive added in v0.12.69 

func (m *ListenForConnectionsResponse) SetKeepAlive(fv *ListenForConnectionsResponse_KeepAlive)

func (*ListenForConnectionsResponse) SetMsg 

func (m *ListenForConnectionsResponse) SetMsg(ofv isListenForConnectionsResponse_Msg)

func (*ListenForConnectionsResponse) String 

func (m *ListenForConnectionsResponse) String() 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 

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

Deprecated, Use ListenForConnectionsResponse_ChannelRequested.ProtoReflect.Descriptor instead.

func (*ListenForConnectionsResponse_ChannelRequested) GetArg 

func (m *ListenForConnectionsResponse_ChannelRequested) GetArg() string

func (*ListenForConnectionsResponse_ChannelRequested) GetChannel 

func (m *ListenForConnectionsResponse_ChannelRequested) GetChannel() string

func (*ListenForConnectionsResponse_ChannelRequested) GetService 

func (m *ListenForConnectionsResponse_ChannelRequested) GetService() BrokerServiceType

func (*ListenForConnectionsResponse_ChannelRequested) GotenMessage 

func (*ListenForConnectionsResponse_ChannelRequested) GotenMessage()

func (*ListenForConnectionsResponse_ChannelRequested) GotenValidate 

func (obj *ListenForConnectionsResponse_ChannelRequested) GotenValidate() error

func (*ListenForConnectionsResponse_ChannelRequested) Marshal 

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

func (*ListenForConnectionsResponse_ChannelRequested) MarshalJSON 

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

func (*ListenForConnectionsResponse_ChannelRequested) ProtoMessage 

func (*ListenForConnectionsResponse_ChannelRequested) ProtoMessage()

func (*ListenForConnectionsResponse_ChannelRequested) ProtoReflect 

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

func (*ListenForConnectionsResponse_ChannelRequested) Reset 

func (m *ListenForConnectionsResponse_ChannelRequested) Reset()

func (*ListenForConnectionsResponse_ChannelRequested) SetArg 

func (m *ListenForConnectionsResponse_ChannelRequested) SetArg(fv string)

func (*ListenForConnectionsResponse_ChannelRequested) SetChannel 

func (m *ListenForConnectionsResponse_ChannelRequested) SetChannel(fv string)

func (*ListenForConnectionsResponse_ChannelRequested) SetService 

func (m *ListenForConnectionsResponse_ChannelRequested) SetService(fv BrokerServiceType)

func (*ListenForConnectionsResponse_ChannelRequested) String 

func (m *ListenForConnectionsResponse_ChannelRequested) String() string

func (*ListenForConnectionsResponse_ChannelRequested) Unmarshal 

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

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) GotenMessage()

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 (m *ListenForConnectionsResponse_KeepAlive) Marshal() ([]byte, error)

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) ProtoMessage()

func (*ListenForConnectionsResponse_KeepAlive) ProtoReflect added in v0.12.69 

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

func (*ListenForConnectionsResponse_KeepAlive) Reset added in v0.12.69 

func (m *ListenForConnectionsResponse_KeepAlive) Reset()

func (*ListenForConnectionsResponse_KeepAlive) String added in v0.12.69 

func (m *ListenForConnectionsResponse_KeepAlive) String() string

func (*ListenForConnectionsResponse_KeepAlive) Unmarshal added in v0.12.69 

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

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 (d *OpenConnectionChannelSocketDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*OpenConnectionChannelSocketDescriptor) GetApiName added in v0.4.28 

func (d *OpenConnectionChannelSocketDescriptor) GetApiName() string

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 (d *OpenConnectionChannelSocketDescriptor) GetResourceDescriptor() gotenresource.Descriptor

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 (d *OpenConnectionChannelSocketDescriptor) GetVerb() string

func (*OpenConnectionChannelSocketDescriptor) HasResource added in v0.4.30 

func (d *OpenConnectionChannelSocketDescriptor) HasResource() bool

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 (d *OpenConnectionChannelSocketDescriptor) IsPlural() bool

func (*OpenConnectionChannelSocketDescriptor) IsServerStream added in v0.4.28 

func (d *OpenConnectionChannelSocketDescriptor) IsServerStream() bool

func (*OpenConnectionChannelSocketDescriptor) IsUnary added in v0.4.28 

func (d *OpenConnectionChannelSocketDescriptor) IsUnary() bool

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 (h *OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21 

func (h *OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21 

func (h *OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30 

func (h *OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30 

func (h *OpenConnectionChannelSocketDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type OpenConnectionChannelSocketDescriptorServerMsgHandle added in v0.4.28 

type OpenConnectionChannelSocketDescriptorServerMsgHandle struct{}

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30 

func (h *OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21 

func (h *OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21 

func (h *OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30 

func (h *OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30 

func (h *OpenConnectionChannelSocketDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

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 (m *OpenConnectionChannelSocketRequest) GetAck() *Ack

func (*OpenConnectionChannelSocketRequest) GetData 

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

func (*OpenConnectionChannelSocketRequest) GetError 

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

func (*OpenConnectionChannelSocketRequest) GetMsg 

func (m *OpenConnectionChannelSocketRequest) GetMsg() isOpenConnectionChannelSocketRequest_Msg

func (*OpenConnectionChannelSocketRequest) GetRegisterSocket 

func (m *OpenConnectionChannelSocketRequest) GetRegisterSocket() *OpenConnectionChannelSocketRequest_RegisterSocket

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 (m *OpenConnectionChannelSocketRequest) ProtoReflect() preflect.Message

func (*OpenConnectionChannelSocketRequest) Reset 

func (m *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 (m *OpenConnectionChannelSocketRequest) SetRegisterSocket(fv *OpenConnectionChannelSocketRequest_RegisterSocket)

func (*OpenConnectionChannelSocketRequest) String 

func (m *OpenConnectionChannelSocketRequest) String() 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 

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

Deprecated, Use OpenConnectionChannelSocketRequest_RegisterSocket.ProtoReflect.Descriptor instead.

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GetChannel 

func (m *OpenConnectionChannelSocketRequest_RegisterSocket) GetChannel() string

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GetDevice 

func (m *OpenConnectionChannelSocketRequest_RegisterSocket) GetDevice() *device.Name

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GotenMessage 

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GotenMessage()

func (*OpenConnectionChannelSocketRequest_RegisterSocket) GotenValidate 

func (obj *OpenConnectionChannelSocketRequest_RegisterSocket) GotenValidate() error

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Marshal 

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

func (*OpenConnectionChannelSocketRequest_RegisterSocket) MarshalJSON 

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

func (*OpenConnectionChannelSocketRequest_RegisterSocket) ProtoMessage 

func (*OpenConnectionChannelSocketRequest_RegisterSocket) ProtoMessage()

func (*OpenConnectionChannelSocketRequest_RegisterSocket) ProtoReflect 

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

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Reset 

func (m *OpenConnectionChannelSocketRequest_RegisterSocket) Reset()

func (*OpenConnectionChannelSocketRequest_RegisterSocket) SetChannel 

func (m *OpenConnectionChannelSocketRequest_RegisterSocket) SetChannel(fv string)

func (*OpenConnectionChannelSocketRequest_RegisterSocket) SetDevice 

func (m *OpenConnectionChannelSocketRequest_RegisterSocket) SetDevice(fv *device.Name)

func (*OpenConnectionChannelSocketRequest_RegisterSocket) String 

func (m *OpenConnectionChannelSocketRequest_RegisterSocket) String() string

func (*OpenConnectionChannelSocketRequest_RegisterSocket) Unmarshal 

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

func (*OpenConnectionChannelSocketRequest_RegisterSocket) UnmarshalJSON 

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

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 (m *OpenConnectionChannelSocketResponse) GetAck() *Ack

func (*OpenConnectionChannelSocketResponse) GetData 

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

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 (m *OpenConnectionChannelSocketResponse) Marshal() ([]byte, error)

func (*OpenConnectionChannelSocketResponse) MarshalJSON 

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

func (*OpenConnectionChannelSocketResponse) ProtoMessage 

func (*OpenConnectionChannelSocketResponse) ProtoMessage()

func (*OpenConnectionChannelSocketResponse) ProtoReflect 

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

func (*OpenConnectionChannelSocketResponse) Reset 

func (m *OpenConnectionChannelSocketResponse) Reset()

func (*OpenConnectionChannelSocketResponse) SetAck 

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

func (*OpenConnectionChannelSocketResponse) SetData 

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

func (*OpenConnectionChannelSocketResponse) SetMsg 

func (m *OpenConnectionChannelSocketResponse) SetMsg(ofv isOpenConnectionChannelSocketResponse_Msg)

func (*OpenConnectionChannelSocketResponse) String 

func (m *OpenConnectionChannelSocketResponse) String() string

func (*OpenConnectionChannelSocketResponse) Unmarshal 

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

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 (m *PodManagementService) GetCommand() PodManagementService_PodState

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 (m *PodManagementService) SetCommand(fv PodManagementService_PodState)

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