broker_client

package
v1.5.12 Latest Latest
Warning

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

Go to latest
Published: Oct 8, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AcceptClientStream

type AcceptClientStream interface {
	Send(*AcceptRequest) error
	Recv() (*AcceptResponse, error)
	grpc.ClientStream
}

type AcceptDescriptor

type AcceptDescriptor struct{}

func GetAcceptDescriptor

func GetAcceptDescriptor() *AcceptDescriptor

func (*AcceptDescriptor) GetApiDescriptor

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

func (*AcceptDescriptor) GetApiName

func (d *AcceptDescriptor) GetApiName() string

func (*AcceptDescriptor) GetClientMsgReflectHandle

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

func (*AcceptDescriptor) GetFullMethodName

func (d *AcceptDescriptor) GetFullMethodName() string

func (*AcceptDescriptor) GetMethodName

func (d *AcceptDescriptor) GetMethodName() string

func (*AcceptDescriptor) GetProtoPkgName

func (d *AcceptDescriptor) GetProtoPkgName() string

func (*AcceptDescriptor) GetResourceDescriptor

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

func (*AcceptDescriptor) GetServerMsgReflectHandle

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

func (*AcceptDescriptor) GetServiceDomain

func (d *AcceptDescriptor) GetServiceDomain() string

func (*AcceptDescriptor) GetServiceVersion

func (d *AcceptDescriptor) GetServiceVersion() string

func (*AcceptDescriptor) GetVerb

func (d *AcceptDescriptor) GetVerb() string

func (*AcceptDescriptor) HasResource

func (d *AcceptDescriptor) HasResource() bool

func (*AcceptDescriptor) IsClientStream

func (d *AcceptDescriptor) IsClientStream() bool

func (*AcceptDescriptor) IsCollection

func (d *AcceptDescriptor) IsCollection() bool

func (*AcceptDescriptor) IsPlural

func (d *AcceptDescriptor) IsPlural() bool

func (*AcceptDescriptor) IsServerStream

func (d *AcceptDescriptor) IsServerStream() bool

func (*AcceptDescriptor) IsUnary

func (d *AcceptDescriptor) IsUnary() bool

func (*AcceptDescriptor) NewEmptyClientMsg

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

func (*AcceptDescriptor) NewEmptyServerMsg

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

func (*AcceptDescriptor) RequestHasResourceBody

func (d *AcceptDescriptor) RequestHasResourceBody() bool

type AcceptDescriptorClientMsgHandle

type AcceptDescriptorClientMsgHandle struct{}

func (*AcceptDescriptorClientMsgHandle) ExtractCollectionName

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

func (*AcceptDescriptorClientMsgHandle) ExtractResourceBodies

func (*AcceptDescriptorClientMsgHandle) ExtractResourceBody

func (*AcceptDescriptorClientMsgHandle) ExtractResourceName

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

func (*AcceptDescriptorClientMsgHandle) ExtractResourceNames

type AcceptDescriptorServerMsgHandle

type AcceptDescriptorServerMsgHandle struct{}

func (*AcceptDescriptorServerMsgHandle) ExtractCollectionName

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

func (*AcceptDescriptorServerMsgHandle) ExtractResourceBodies

func (*AcceptDescriptorServerMsgHandle) ExtractResourceBody

func (*AcceptDescriptorServerMsgHandle) ExtractResourceName

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

func (*AcceptDescriptorServerMsgHandle) ExtractResourceNames

type AcceptRequest

type AcceptRequest struct {

	// Types that are valid to be assigned to Message:
	//	*AcceptRequest_OpenRequest_
	//	*AcceptRequest_ResumeRequest_
	//	*AcceptRequest_Data
	//	*AcceptRequest_Ack
	//	*AcceptRequest_Close
	//	*AcceptRequest_Error
	//	*AcceptRequest_Ping
	Message isAcceptRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Request message for method [Accept][ntt.proxies.v1.Accept]

func (*AcceptRequest) Descriptor

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

Deprecated, Use AcceptRequest.ProtoReflect.Descriptor instead.

func (*AcceptRequest) GetAck

func (m *AcceptRequest) GetAck() *Ack

func (*AcceptRequest) GetClose

func (m *AcceptRequest) GetClose() *Close

func (*AcceptRequest) GetData

func (m *AcceptRequest) GetData() *Data

func (*AcceptRequest) GetError

func (m *AcceptRequest) GetError() *Error

func (*AcceptRequest) GetMessage

func (m *AcceptRequest) GetMessage() isAcceptRequest_Message

func (*AcceptRequest) GetOpenRequest

func (m *AcceptRequest) GetOpenRequest() *AcceptRequest_OpenRequest

func (*AcceptRequest) GetPing

func (m *AcceptRequest) GetPing() *Ping

func (*AcceptRequest) GetResumeRequest

func (m *AcceptRequest) GetResumeRequest() *AcceptRequest_ResumeRequest

func (*AcceptRequest) GotenMessage

func (*AcceptRequest) GotenMessage()

func (*AcceptRequest) GotenValidate

func (obj *AcceptRequest) GotenValidate() error

func (*AcceptRequest) Marshal

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

func (*AcceptRequest) MarshalJSON

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

func (*AcceptRequest) ProtoMessage

func (*AcceptRequest) ProtoMessage()

func (*AcceptRequest) ProtoReflect

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

func (*AcceptRequest) Reset

func (m *AcceptRequest) Reset()

func (*AcceptRequest) SetAck

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

func (*AcceptRequest) SetClose

func (m *AcceptRequest) SetClose(fv *Close)

func (*AcceptRequest) SetData

func (m *AcceptRequest) SetData(fv *Data)

func (*AcceptRequest) SetError

func (m *AcceptRequest) SetError(fv *Error)

func (*AcceptRequest) SetMessage

func (m *AcceptRequest) SetMessage(ofv isAcceptRequest_Message)

func (*AcceptRequest) SetOpenRequest

func (m *AcceptRequest) SetOpenRequest(fv *AcceptRequest_OpenRequest)

func (*AcceptRequest) SetPing

func (m *AcceptRequest) SetPing(fv *Ping)

func (*AcceptRequest) SetResumeRequest

func (m *AcceptRequest) SetResumeRequest(fv *AcceptRequest_ResumeRequest)

func (*AcceptRequest) String

func (m *AcceptRequest) String() string

func (*AcceptRequest) Unmarshal

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

func (*AcceptRequest) UnmarshalJSON

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

type AcceptRequest_Ack

type AcceptRequest_Ack struct {
	// ACK message
	Ack *Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type AcceptRequest_Close

type AcceptRequest_Close struct {
	Close *Close `protobuf:"bytes,5,opt,name=close,proto3,oneof" firestore:"close"`
}

type AcceptRequest_Data

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

type AcceptRequest_Error

type AcceptRequest_Error struct {
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof" firestore:"error"`
}

type AcceptRequest_OpenRequest

type AcceptRequest_OpenRequest struct {
	Project  *project.Name `protobuf:"bytes,1,opt,customtype=Name,name=project,proto3" json:"project,omitempty" firestore:"project"`
	RegionId string        `protobuf:"bytes,5,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// Service domain (for example devices.edgelq.com) for this provider.
	ServiceDomain string `` /* 126-byte string literal not displayed */
	// Name, to be authenticated/authorized.
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" firestore:"name"`
	SessionId uint64 `protobuf:"varint,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	// Channel ID, requested by the endpoint in the ChannelRequested message.
	ChannelId uint64 `protobuf:"varint,4,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	// contains filtered or unexported fields
}

func (*AcceptRequest_OpenRequest) Descriptor

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

Deprecated, Use AcceptRequest_OpenRequest.ProtoReflect.Descriptor instead.

func (*AcceptRequest_OpenRequest) GetChannelId

func (m *AcceptRequest_OpenRequest) GetChannelId() uint64

func (*AcceptRequest_OpenRequest) GetName

func (m *AcceptRequest_OpenRequest) GetName() string

func (*AcceptRequest_OpenRequest) GetProject

func (m *AcceptRequest_OpenRequest) GetProject() *project.Name

func (*AcceptRequest_OpenRequest) GetRegionId

func (m *AcceptRequest_OpenRequest) GetRegionId() string

func (*AcceptRequest_OpenRequest) GetServiceDomain

func (m *AcceptRequest_OpenRequest) GetServiceDomain() string

func (*AcceptRequest_OpenRequest) GetSessionId

func (m *AcceptRequest_OpenRequest) GetSessionId() uint64

func (*AcceptRequest_OpenRequest) GotenMessage

func (*AcceptRequest_OpenRequest) GotenMessage()

func (*AcceptRequest_OpenRequest) GotenValidate

func (obj *AcceptRequest_OpenRequest) GotenValidate() error

func (*AcceptRequest_OpenRequest) Marshal

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

func (*AcceptRequest_OpenRequest) MarshalJSON

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

func (*AcceptRequest_OpenRequest) ProtoMessage

func (*AcceptRequest_OpenRequest) ProtoMessage()

func (*AcceptRequest_OpenRequest) ProtoReflect

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

func (*AcceptRequest_OpenRequest) Reset

func (m *AcceptRequest_OpenRequest) Reset()

func (*AcceptRequest_OpenRequest) SetChannelId

func (m *AcceptRequest_OpenRequest) SetChannelId(fv uint64)

func (*AcceptRequest_OpenRequest) SetName

func (m *AcceptRequest_OpenRequest) SetName(fv string)

func (*AcceptRequest_OpenRequest) SetProject

func (m *AcceptRequest_OpenRequest) SetProject(fv *project.Name)

func (*AcceptRequest_OpenRequest) SetRegionId

func (m *AcceptRequest_OpenRequest) SetRegionId(fv string)

func (*AcceptRequest_OpenRequest) SetServiceDomain

func (m *AcceptRequest_OpenRequest) SetServiceDomain(fv string)

func (*AcceptRequest_OpenRequest) SetSessionId

func (m *AcceptRequest_OpenRequest) SetSessionId(fv uint64)

func (*AcceptRequest_OpenRequest) String

func (m *AcceptRequest_OpenRequest) String() string

func (*AcceptRequest_OpenRequest) Unmarshal

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

func (*AcceptRequest_OpenRequest) UnmarshalJSON

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

type AcceptRequest_OpenRequest_

type AcceptRequest_OpenRequest_ struct {
	// Registers a new socket on the endpoint.
	OpenRequest *AcceptRequest_OpenRequest `protobuf:"bytes,1,opt,name=open_request,json=openRequest,proto3,oneof" firestore:"openRequest"`
}

type AcceptRequest_Ping

type AcceptRequest_Ping struct {
	Ping *Ping `protobuf:"bytes,7,opt,name=ping,proto3,oneof" firestore:"ping"`
}

type AcceptRequest_ResumeRequest

type AcceptRequest_ResumeRequest struct {
	Project  *project.Name `protobuf:"bytes,1,opt,customtype=Name,name=project,proto3" json:"project,omitempty" firestore:"project"`
	RegionId string        `protobuf:"bytes,6,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// Service domain (for example devices.edgelq.com) for this provider.
	ServiceDomain string `` /* 126-byte string literal not displayed */
	// Name, to be authenticated/authorized.
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" firestore:"name"`
	SessionId uint64 `protobuf:"varint,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	// Channel ID, requested by the endpoint in the ChannelRequested message.
	ChannelId     uint64 `protobuf:"varint,4,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	LastMessageId uint64 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AcceptRequest_ResumeRequest) Descriptor

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

Deprecated, Use AcceptRequest_ResumeRequest.ProtoReflect.Descriptor instead.

func (*AcceptRequest_ResumeRequest) GetChannelId

func (m *AcceptRequest_ResumeRequest) GetChannelId() uint64

func (*AcceptRequest_ResumeRequest) GetLastMessageId

func (m *AcceptRequest_ResumeRequest) GetLastMessageId() uint64

func (*AcceptRequest_ResumeRequest) GetName

func (m *AcceptRequest_ResumeRequest) GetName() string

func (*AcceptRequest_ResumeRequest) GetProject

func (m *AcceptRequest_ResumeRequest) GetProject() *project.Name

func (*AcceptRequest_ResumeRequest) GetRegionId

func (m *AcceptRequest_ResumeRequest) GetRegionId() string

func (*AcceptRequest_ResumeRequest) GetServiceDomain

func (m *AcceptRequest_ResumeRequest) GetServiceDomain() string

func (*AcceptRequest_ResumeRequest) GetSessionId

func (m *AcceptRequest_ResumeRequest) GetSessionId() uint64

func (*AcceptRequest_ResumeRequest) GotenMessage

func (*AcceptRequest_ResumeRequest) GotenMessage()

func (*AcceptRequest_ResumeRequest) GotenValidate

func (obj *AcceptRequest_ResumeRequest) GotenValidate() error

func (*AcceptRequest_ResumeRequest) Marshal

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

func (*AcceptRequest_ResumeRequest) MarshalJSON

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

func (*AcceptRequest_ResumeRequest) ProtoMessage

func (*AcceptRequest_ResumeRequest) ProtoMessage()

func (*AcceptRequest_ResumeRequest) ProtoReflect

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

func (*AcceptRequest_ResumeRequest) Reset

func (m *AcceptRequest_ResumeRequest) Reset()

func (*AcceptRequest_ResumeRequest) SetChannelId

func (m *AcceptRequest_ResumeRequest) SetChannelId(fv uint64)

func (*AcceptRequest_ResumeRequest) SetLastMessageId

func (m *AcceptRequest_ResumeRequest) SetLastMessageId(fv uint64)

func (*AcceptRequest_ResumeRequest) SetName

func (m *AcceptRequest_ResumeRequest) SetName(fv string)

func (*AcceptRequest_ResumeRequest) SetProject

func (m *AcceptRequest_ResumeRequest) SetProject(fv *project.Name)

func (*AcceptRequest_ResumeRequest) SetRegionId

func (m *AcceptRequest_ResumeRequest) SetRegionId(fv string)

func (*AcceptRequest_ResumeRequest) SetServiceDomain

func (m *AcceptRequest_ResumeRequest) SetServiceDomain(fv string)

func (*AcceptRequest_ResumeRequest) SetSessionId

func (m *AcceptRequest_ResumeRequest) SetSessionId(fv uint64)

func (*AcceptRequest_ResumeRequest) String

func (m *AcceptRequest_ResumeRequest) String() string

func (*AcceptRequest_ResumeRequest) Unmarshal

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

func (*AcceptRequest_ResumeRequest) UnmarshalJSON

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

type AcceptRequest_ResumeRequest_

type AcceptRequest_ResumeRequest_ struct {
	ResumeRequest *AcceptRequest_ResumeRequest `protobuf:"bytes,2,opt,name=resume_request,json=resumeRequest,proto3,oneof" firestore:"resumeRequest"`
}

type AcceptResponse

type AcceptResponse struct {

	// Types that are valid to be assigned to Message:
	//	*AcceptResponse_Data
	//	*AcceptResponse_Ack
	//	*AcceptResponse_Close
	//	*AcceptResponse_Error
	//	*AcceptResponse_Pong
	Message isAcceptResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Response message for method [Accept][ntt.proxies.v1.Accept]

func (*AcceptResponse) Descriptor

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

Deprecated, Use AcceptResponse.ProtoReflect.Descriptor instead.

func (*AcceptResponse) GetAck

func (m *AcceptResponse) GetAck() *Ack

func (*AcceptResponse) GetClose

func (m *AcceptResponse) GetClose() *Close

func (*AcceptResponse) GetData

func (m *AcceptResponse) GetData() *Data

func (*AcceptResponse) GetError

func (m *AcceptResponse) GetError() *Error

func (*AcceptResponse) GetMessage

func (m *AcceptResponse) GetMessage() isAcceptResponse_Message

func (*AcceptResponse) GetPong

func (m *AcceptResponse) GetPong() *Pong

func (*AcceptResponse) GotenMessage

func (*AcceptResponse) GotenMessage()

func (*AcceptResponse) GotenValidate

func (obj *AcceptResponse) GotenValidate() error

func (*AcceptResponse) Marshal

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

func (*AcceptResponse) MarshalJSON

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

func (*AcceptResponse) ProtoMessage

func (*AcceptResponse) ProtoMessage()

func (*AcceptResponse) ProtoReflect

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

func (*AcceptResponse) Reset

func (m *AcceptResponse) Reset()

func (*AcceptResponse) SetAck

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

func (*AcceptResponse) SetClose

func (m *AcceptResponse) SetClose(fv *Close)

func (*AcceptResponse) SetData

func (m *AcceptResponse) SetData(fv *Data)

func (*AcceptResponse) SetError

func (m *AcceptResponse) SetError(fv *Error)

func (*AcceptResponse) SetMessage

func (m *AcceptResponse) SetMessage(ofv isAcceptResponse_Message)

func (*AcceptResponse) SetPong

func (m *AcceptResponse) SetPong(fv *Pong)

func (*AcceptResponse) String

func (m *AcceptResponse) String() string

func (*AcceptResponse) Unmarshal

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

func (*AcceptResponse) UnmarshalJSON

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

type AcceptResponse_Ack

type AcceptResponse_Ack struct {
	// ACK message
	Ack *Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type AcceptResponse_Close

type AcceptResponse_Close struct {
	Close *Close `protobuf:"bytes,3,opt,name=close,proto3,oneof" firestore:"close"`
}

type AcceptResponse_Data

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

type AcceptResponse_Error

type AcceptResponse_Error struct {
	Error *Error `protobuf:"bytes,4,opt,name=error,proto3,oneof" firestore:"error"`
}

type AcceptResponse_Pong

type AcceptResponse_Pong struct {
	Pong *Pong `protobuf:"bytes,5,opt,name=pong,proto3,oneof" firestore:"pong"`
}

type Ack

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

func (*Ack) Descriptor

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

Deprecated, Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetId

func (m *Ack) GetId() 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) SetId

func (m *Ack) SetId(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 {
	Connect(ctx context.Context, opts ...grpc.CallOption) (ConnectClientStream, error)
	Listen(ctx context.Context, opts ...grpc.CallOption) (ListenClientStream, error)
	Accept(ctx context.Context, opts ...grpc.CallOption) (AcceptClientStream, error)
}

BrokerServiceClient is the client API for BrokerService.

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

type BrokerServiceDescriptor

type BrokerServiceDescriptor struct{}

func GetBrokerServiceDescriptor

func GetBrokerServiceDescriptor() *BrokerServiceDescriptor

func (*BrokerServiceDescriptor) AllMethodDescriptors

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

func (*BrokerServiceDescriptor) GetApiName

func (d *BrokerServiceDescriptor) GetApiName() string

func (*BrokerServiceDescriptor) GetFullAPIName

func (d *BrokerServiceDescriptor) GetFullAPIName() string

func (*BrokerServiceDescriptor) GetProtoPkgName

func (d *BrokerServiceDescriptor) GetProtoPkgName() string

func (*BrokerServiceDescriptor) GetServiceDomain

func (d *BrokerServiceDescriptor) GetServiceDomain() string

func (*BrokerServiceDescriptor) GetServiceVersion

func (d *BrokerServiceDescriptor) GetServiceVersion() string

type Close

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

func (*Close) Descriptor

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

Deprecated, Use Close.ProtoReflect.Descriptor instead.

func (*Close) GetId

func (m *Close) GetId() uint64

func (*Close) GotenMessage

func (*Close) GotenMessage()

func (*Close) GotenValidate

func (obj *Close) GotenValidate() error

func (*Close) Marshal

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

func (*Close) MarshalJSON

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

func (*Close) ProtoMessage

func (*Close) ProtoMessage()

func (*Close) ProtoReflect

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

func (*Close) Reset

func (m *Close) Reset()

func (*Close) SetId

func (m *Close) SetId(fv uint64)

func (*Close) String

func (m *Close) String() string

func (*Close) Unmarshal

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

func (*Close) UnmarshalJSON

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

type ConnectClientStream

type ConnectClientStream interface {
	Send(*ConnectRequest) error
	Recv() (*ConnectResponse, error)
	grpc.ClientStream
}

type ConnectDescriptor

type ConnectDescriptor struct{}

func GetConnectDescriptor

func GetConnectDescriptor() *ConnectDescriptor

func (*ConnectDescriptor) GetApiDescriptor

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

func (*ConnectDescriptor) GetApiName

func (d *ConnectDescriptor) GetApiName() string

func (*ConnectDescriptor) GetClientMsgReflectHandle

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

func (*ConnectDescriptor) GetFullMethodName

func (d *ConnectDescriptor) GetFullMethodName() string

func (*ConnectDescriptor) GetMethodName

func (d *ConnectDescriptor) GetMethodName() string

func (*ConnectDescriptor) GetProtoPkgName

func (d *ConnectDescriptor) GetProtoPkgName() string

func (*ConnectDescriptor) GetResourceDescriptor

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

func (*ConnectDescriptor) GetServerMsgReflectHandle

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

func (*ConnectDescriptor) GetServiceDomain

func (d *ConnectDescriptor) GetServiceDomain() string

func (*ConnectDescriptor) GetServiceVersion

func (d *ConnectDescriptor) GetServiceVersion() string

func (*ConnectDescriptor) GetVerb

func (d *ConnectDescriptor) GetVerb() string

func (*ConnectDescriptor) HasResource

func (d *ConnectDescriptor) HasResource() bool

func (*ConnectDescriptor) IsClientStream

func (d *ConnectDescriptor) IsClientStream() bool

func (*ConnectDescriptor) IsCollection

func (d *ConnectDescriptor) IsCollection() bool

func (*ConnectDescriptor) IsPlural

func (d *ConnectDescriptor) IsPlural() bool

func (*ConnectDescriptor) IsServerStream

func (d *ConnectDescriptor) IsServerStream() bool

func (*ConnectDescriptor) IsUnary

func (d *ConnectDescriptor) IsUnary() bool

func (*ConnectDescriptor) NewEmptyClientMsg

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

func (*ConnectDescriptor) NewEmptyServerMsg

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

func (*ConnectDescriptor) RequestHasResourceBody

func (d *ConnectDescriptor) RequestHasResourceBody() bool

type ConnectDescriptorClientMsgHandle

type ConnectDescriptorClientMsgHandle struct{}

func (*ConnectDescriptorClientMsgHandle) ExtractCollectionName

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

func (*ConnectDescriptorClientMsgHandle) ExtractResourceBodies

func (*ConnectDescriptorClientMsgHandle) ExtractResourceBody

func (*ConnectDescriptorClientMsgHandle) ExtractResourceName

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

func (*ConnectDescriptorClientMsgHandle) ExtractResourceNames

type ConnectDescriptorServerMsgHandle

type ConnectDescriptorServerMsgHandle struct{}

func (*ConnectDescriptorServerMsgHandle) ExtractCollectionName

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

func (*ConnectDescriptorServerMsgHandle) ExtractResourceBodies

func (*ConnectDescriptorServerMsgHandle) ExtractResourceBody

func (*ConnectDescriptorServerMsgHandle) ExtractResourceName

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

func (*ConnectDescriptorServerMsgHandle) ExtractResourceNames

type ConnectRequest

type ConnectRequest struct {

	// Types that are valid to be assigned to Message:
	//	*ConnectRequest_OpenRequest_
	//	*ConnectRequest_ResumeRequest_
	//	*ConnectRequest_Ack
	//	*ConnectRequest_Data
	//	*ConnectRequest_Close
	//	*ConnectRequest_Error
	//	*ConnectRequest_Ping
	Message isConnectRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Request message for method [Connect][ntt.proxies.v1.Connect]

func (*ConnectRequest) Descriptor

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

Deprecated, Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetAck

func (m *ConnectRequest) GetAck() *Ack

func (*ConnectRequest) GetClose

func (m *ConnectRequest) GetClose() *Close

func (*ConnectRequest) GetData

func (m *ConnectRequest) GetData() *Data

func (*ConnectRequest) GetError

func (m *ConnectRequest) GetError() *Error

func (*ConnectRequest) GetMessage

func (m *ConnectRequest) GetMessage() isConnectRequest_Message

func (*ConnectRequest) GetOpenRequest

func (m *ConnectRequest) GetOpenRequest() *ConnectRequest_OpenRequest

func (*ConnectRequest) GetPing

func (m *ConnectRequest) GetPing() *Ping

func (*ConnectRequest) GetResumeRequest

func (m *ConnectRequest) GetResumeRequest() *ConnectRequest_ResumeRequest

func (*ConnectRequest) GotenMessage

func (*ConnectRequest) GotenMessage()

func (*ConnectRequest) GotenValidate

func (obj *ConnectRequest) GotenValidate() error

func (*ConnectRequest) Marshal

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

func (*ConnectRequest) MarshalJSON

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

func (*ConnectRequest) ProtoMessage

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect

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

func (*ConnectRequest) Reset

func (m *ConnectRequest) Reset()

func (*ConnectRequest) SetAck

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

func (*ConnectRequest) SetClose

func (m *ConnectRequest) SetClose(fv *Close)

func (*ConnectRequest) SetData

func (m *ConnectRequest) SetData(fv *Data)

func (*ConnectRequest) SetError

func (m *ConnectRequest) SetError(fv *Error)

func (*ConnectRequest) SetMessage

func (m *ConnectRequest) SetMessage(ofv isConnectRequest_Message)

func (*ConnectRequest) SetOpenRequest

func (m *ConnectRequest) SetOpenRequest(fv *ConnectRequest_OpenRequest)

func (*ConnectRequest) SetPing

func (m *ConnectRequest) SetPing(fv *Ping)

func (*ConnectRequest) SetResumeRequest

func (m *ConnectRequest) SetResumeRequest(fv *ConnectRequest_ResumeRequest)

func (*ConnectRequest) String

func (m *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal

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

func (*ConnectRequest) UnmarshalJSON

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

type ConnectRequest_Ack

type ConnectRequest_Ack struct {
	// ACK message
	Ack *Ack `protobuf:"bytes,3,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type ConnectRequest_Close

type ConnectRequest_Close struct {
	Close *Close `protobuf:"bytes,5,opt,name=close,proto3,oneof" firestore:"close"`
}

type ConnectRequest_Data

type ConnectRequest_Data struct {
	// Any data sent to the device through the endpoint.
	Data *Data `protobuf:"bytes,4,opt,name=data,proto3,oneof" firestore:"data"`
}

type ConnectRequest_Error

type ConnectRequest_Error struct {
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof" firestore:"error"`
}

type ConnectRequest_OpenRequest

type ConnectRequest_OpenRequest struct {
	Project *project.Name `protobuf:"bytes,1,opt,customtype=Name,name=project,proto3" json:"project,omitempty" firestore:"project"`
	// Region ID to connect to
	RegionId string `protobuf:"bytes,6,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// Service domain (for example devices.edgelq.com) for this provider.
	ServiceDomain string `` /* 126-byte string literal not displayed */
	// name to connect to - must match to name value passed in ListenRequest
	ProviderName string `protobuf:"bytes,3,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty" firestore:"providerName"`
	// Name of the connecting client
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" firestore:"name"`
	// Service to connect
	Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty" firestore:"service"`
	// Initial argument (optional)
	Arg []byte `protobuf:"bytes,5,opt,name=arg,proto3" json:"arg,omitempty" firestore:"arg"`
	// contains filtered or unexported fields
}

func (*ConnectRequest_OpenRequest) Descriptor

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

Deprecated, Use ConnectRequest_OpenRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest_OpenRequest) GetArg

func (m *ConnectRequest_OpenRequest) GetArg() []byte

func (*ConnectRequest_OpenRequest) GetName

func (m *ConnectRequest_OpenRequest) GetName() string

func (*ConnectRequest_OpenRequest) GetProject

func (m *ConnectRequest_OpenRequest) GetProject() *project.Name

func (*ConnectRequest_OpenRequest) GetProviderName

func (m *ConnectRequest_OpenRequest) GetProviderName() string

func (*ConnectRequest_OpenRequest) GetRegionId

func (m *ConnectRequest_OpenRequest) GetRegionId() string

func (*ConnectRequest_OpenRequest) GetService

func (m *ConnectRequest_OpenRequest) GetService() string

func (*ConnectRequest_OpenRequest) GetServiceDomain

func (m *ConnectRequest_OpenRequest) GetServiceDomain() string

func (*ConnectRequest_OpenRequest) GotenMessage

func (*ConnectRequest_OpenRequest) GotenMessage()

func (*ConnectRequest_OpenRequest) GotenValidate

func (obj *ConnectRequest_OpenRequest) GotenValidate() error

func (*ConnectRequest_OpenRequest) Marshal

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

func (*ConnectRequest_OpenRequest) MarshalJSON

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

func (*ConnectRequest_OpenRequest) ProtoMessage

func (*ConnectRequest_OpenRequest) ProtoMessage()

func (*ConnectRequest_OpenRequest) ProtoReflect

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

func (*ConnectRequest_OpenRequest) Reset

func (m *ConnectRequest_OpenRequest) Reset()

func (*ConnectRequest_OpenRequest) SetArg

func (m *ConnectRequest_OpenRequest) SetArg(fv []byte)

func (*ConnectRequest_OpenRequest) SetName

func (m *ConnectRequest_OpenRequest) SetName(fv string)

func (*ConnectRequest_OpenRequest) SetProject

func (m *ConnectRequest_OpenRequest) SetProject(fv *project.Name)

func (*ConnectRequest_OpenRequest) SetProviderName

func (m *ConnectRequest_OpenRequest) SetProviderName(fv string)

func (*ConnectRequest_OpenRequest) SetRegionId

func (m *ConnectRequest_OpenRequest) SetRegionId(fv string)

func (*ConnectRequest_OpenRequest) SetService

func (m *ConnectRequest_OpenRequest) SetService(fv string)

func (*ConnectRequest_OpenRequest) SetServiceDomain

func (m *ConnectRequest_OpenRequest) SetServiceDomain(fv string)

func (*ConnectRequest_OpenRequest) String

func (m *ConnectRequest_OpenRequest) String() string

func (*ConnectRequest_OpenRequest) Unmarshal

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

func (*ConnectRequest_OpenRequest) UnmarshalJSON

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

type ConnectRequest_OpenRequest_

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

type ConnectRequest_Ping

type ConnectRequest_Ping struct {
	Ping *Ping `protobuf:"bytes,7,opt,name=ping,proto3,oneof" firestore:"ping"`
}

type ConnectRequest_ResumeRequest

type ConnectRequest_ResumeRequest struct {
	Project *project.Name `protobuf:"bytes,1,opt,customtype=Name,name=project,proto3" json:"project,omitempty" firestore:"project"`
	// Region ID to connect to
	RegionId string `protobuf:"bytes,7,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// Service domain (for example devices.edgelq.com) for this provider.
	ServiceDomain string `` /* 126-byte string literal not displayed */
	// name to connect to - must match to name value passed in ListenRequest
	ProviderName string `protobuf:"bytes,3,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty" firestore:"providerName"`
	// Name of the connecting client
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" firestore:"name"`
	SessionId     uint64 `protobuf:"varint,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	ChannelId     uint64 `protobuf:"varint,5,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	LastMessageId uint64 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectRequest_ResumeRequest) Descriptor

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

Deprecated, Use ConnectRequest_ResumeRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest_ResumeRequest) GetChannelId

func (m *ConnectRequest_ResumeRequest) GetChannelId() uint64

func (*ConnectRequest_ResumeRequest) GetLastMessageId

func (m *ConnectRequest_ResumeRequest) GetLastMessageId() uint64

func (*ConnectRequest_ResumeRequest) GetName

func (m *ConnectRequest_ResumeRequest) GetName() string

func (*ConnectRequest_ResumeRequest) GetProject

func (m *ConnectRequest_ResumeRequest) GetProject() *project.Name

func (*ConnectRequest_ResumeRequest) GetProviderName

func (m *ConnectRequest_ResumeRequest) GetProviderName() string

func (*ConnectRequest_ResumeRequest) GetRegionId

func (m *ConnectRequest_ResumeRequest) GetRegionId() string

func (*ConnectRequest_ResumeRequest) GetServiceDomain

func (m *ConnectRequest_ResumeRequest) GetServiceDomain() string

func (*ConnectRequest_ResumeRequest) GetSessionId

func (m *ConnectRequest_ResumeRequest) GetSessionId() uint64

func (*ConnectRequest_ResumeRequest) GotenMessage

func (*ConnectRequest_ResumeRequest) GotenMessage()

func (*ConnectRequest_ResumeRequest) GotenValidate

func (obj *ConnectRequest_ResumeRequest) GotenValidate() error

func (*ConnectRequest_ResumeRequest) Marshal

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

func (*ConnectRequest_ResumeRequest) MarshalJSON

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

func (*ConnectRequest_ResumeRequest) ProtoMessage

func (*ConnectRequest_ResumeRequest) ProtoMessage()

func (*ConnectRequest_ResumeRequest) ProtoReflect

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

func (*ConnectRequest_ResumeRequest) Reset

func (m *ConnectRequest_ResumeRequest) Reset()

func (*ConnectRequest_ResumeRequest) SetChannelId

func (m *ConnectRequest_ResumeRequest) SetChannelId(fv uint64)

func (*ConnectRequest_ResumeRequest) SetLastMessageId

func (m *ConnectRequest_ResumeRequest) SetLastMessageId(fv uint64)

func (*ConnectRequest_ResumeRequest) SetName

func (m *ConnectRequest_ResumeRequest) SetName(fv string)

func (*ConnectRequest_ResumeRequest) SetProject

func (m *ConnectRequest_ResumeRequest) SetProject(fv *project.Name)

func (*ConnectRequest_ResumeRequest) SetProviderName

func (m *ConnectRequest_ResumeRequest) SetProviderName(fv string)

func (*ConnectRequest_ResumeRequest) SetRegionId

func (m *ConnectRequest_ResumeRequest) SetRegionId(fv string)

func (*ConnectRequest_ResumeRequest) SetServiceDomain

func (m *ConnectRequest_ResumeRequest) SetServiceDomain(fv string)

func (*ConnectRequest_ResumeRequest) SetSessionId

func (m *ConnectRequest_ResumeRequest) SetSessionId(fv uint64)

func (*ConnectRequest_ResumeRequest) String

func (*ConnectRequest_ResumeRequest) Unmarshal

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

func (*ConnectRequest_ResumeRequest) UnmarshalJSON

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

type ConnectRequest_ResumeRequest_

type ConnectRequest_ResumeRequest_ struct {
	// Attempt to resume stream of data
	ResumeRequest *ConnectRequest_ResumeRequest `protobuf:"bytes,2,opt,name=resume_request,json=resumeRequest,proto3,oneof" firestore:"resumeRequest"`
}

type ConnectResponse

type ConnectResponse struct {

	// Types that are valid to be assigned to Message:
	//	*ConnectResponse_OpenResponse_
	//	*ConnectResponse_ResumeResponse_
	//	*ConnectResponse_ChannelOpenError_
	//	*ConnectResponse_Ack
	//	*ConnectResponse_Data
	//	*ConnectResponse_Close
	//	*ConnectResponse_Error
	//	*ConnectResponse_Pong
	Message isConnectResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Response message for method [Connect][ntt.proxies.v1.Connect]

func (*ConnectResponse) Descriptor

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

Deprecated, Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetAck

func (m *ConnectResponse) GetAck() *Ack

func (*ConnectResponse) GetChannelOpenError

func (m *ConnectResponse) GetChannelOpenError() *ConnectResponse_ChannelOpenError

func (*ConnectResponse) GetClose

func (m *ConnectResponse) GetClose() *Close

func (*ConnectResponse) GetData

func (m *ConnectResponse) GetData() *Data

func (*ConnectResponse) GetError

func (m *ConnectResponse) GetError() *Error

func (*ConnectResponse) GetMessage

func (m *ConnectResponse) GetMessage() isConnectResponse_Message

func (*ConnectResponse) GetOpenResponse

func (m *ConnectResponse) GetOpenResponse() *ConnectResponse_OpenResponse

func (*ConnectResponse) GetPong

func (m *ConnectResponse) GetPong() *Pong

func (*ConnectResponse) GetResumeResponse

func (m *ConnectResponse) GetResumeResponse() *ConnectResponse_ResumeResponse

func (*ConnectResponse) GotenMessage

func (*ConnectResponse) GotenMessage()

func (*ConnectResponse) GotenValidate

func (obj *ConnectResponse) GotenValidate() error

func (*ConnectResponse) Marshal

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

func (*ConnectResponse) MarshalJSON

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

func (*ConnectResponse) ProtoMessage

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect

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

func (*ConnectResponse) Reset

func (m *ConnectResponse) Reset()

func (*ConnectResponse) SetAck

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

func (*ConnectResponse) SetChannelOpenError

func (m *ConnectResponse) SetChannelOpenError(fv *ConnectResponse_ChannelOpenError)

func (*ConnectResponse) SetClose

func (m *ConnectResponse) SetClose(fv *Close)

func (*ConnectResponse) SetData

func (m *ConnectResponse) SetData(fv *Data)

func (*ConnectResponse) SetError

func (m *ConnectResponse) SetError(fv *Error)

func (*ConnectResponse) SetMessage

func (m *ConnectResponse) SetMessage(ofv isConnectResponse_Message)

func (*ConnectResponse) SetOpenResponse

func (m *ConnectResponse) SetOpenResponse(fv *ConnectResponse_OpenResponse)

func (*ConnectResponse) SetPong

func (m *ConnectResponse) SetPong(fv *Pong)

func (*ConnectResponse) SetResumeResponse

func (m *ConnectResponse) SetResumeResponse(fv *ConnectResponse_ResumeResponse)

func (*ConnectResponse) String

func (m *ConnectResponse) String() string

func (*ConnectResponse) Unmarshal

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

func (*ConnectResponse) UnmarshalJSON

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

type ConnectResponse_Ack

type ConnectResponse_Ack struct {
	// ACK message
	Ack *Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof" firestore:"ack"`
}

type ConnectResponse_ChannelOpenError

type ConnectResponse_ChannelOpenError struct {

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

func (*ConnectResponse_ChannelOpenError) Descriptor

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

Deprecated, Use ConnectResponse_ChannelOpenError.ProtoReflect.Descriptor instead.

func (*ConnectResponse_ChannelOpenError) GetChannelId

func (m *ConnectResponse_ChannelOpenError) GetChannelId() uint64

func (*ConnectResponse_ChannelOpenError) GetMessage

func (m *ConnectResponse_ChannelOpenError) GetMessage() string

func (*ConnectResponse_ChannelOpenError) GotenMessage

func (*ConnectResponse_ChannelOpenError) GotenMessage()

func (*ConnectResponse_ChannelOpenError) GotenValidate

func (obj *ConnectResponse_ChannelOpenError) GotenValidate() error

func (*ConnectResponse_ChannelOpenError) Marshal

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

func (*ConnectResponse_ChannelOpenError) MarshalJSON

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

func (*ConnectResponse_ChannelOpenError) ProtoMessage

func (*ConnectResponse_ChannelOpenError) ProtoMessage()

func (*ConnectResponse_ChannelOpenError) ProtoReflect

func (*ConnectResponse_ChannelOpenError) Reset

func (*ConnectResponse_ChannelOpenError) SetChannelId

func (m *ConnectResponse_ChannelOpenError) SetChannelId(fv uint64)

func (*ConnectResponse_ChannelOpenError) SetMessage

func (m *ConnectResponse_ChannelOpenError) SetMessage(fv string)

func (*ConnectResponse_ChannelOpenError) String

func (*ConnectResponse_ChannelOpenError) Unmarshal

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

func (*ConnectResponse_ChannelOpenError) UnmarshalJSON

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

type ConnectResponse_ChannelOpenError_

type ConnectResponse_ChannelOpenError_ struct {
	ChannelOpenError *ConnectResponse_ChannelOpenError `protobuf:"bytes,3,opt,name=channel_open_error,json=channelOpenError,proto3,oneof" firestore:"channelOpenError"`
}

type ConnectResponse_Close

type ConnectResponse_Close struct {
	Close *Close `protobuf:"bytes,6,opt,name=close,proto3,oneof" firestore:"close"`
}

type ConnectResponse_Data

type ConnectResponse_Data struct {
	// Any data from the device (endpoint) to the client.
	Data *Data `protobuf:"bytes,5,opt,name=data,proto3,oneof" firestore:"data"`
}

type ConnectResponse_Error

type ConnectResponse_Error struct {
	Error *Error `protobuf:"bytes,7,opt,name=error,proto3,oneof" firestore:"error"`
}

type ConnectResponse_OpenResponse

type ConnectResponse_OpenResponse struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	ChannelId uint64 `protobuf:"varint,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	// contains filtered or unexported fields
}

func (*ConnectResponse_OpenResponse) Descriptor

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

Deprecated, Use ConnectResponse_OpenResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse_OpenResponse) GetChannelId

func (m *ConnectResponse_OpenResponse) GetChannelId() uint64

func (*ConnectResponse_OpenResponse) GetSessionId

func (m *ConnectResponse_OpenResponse) GetSessionId() uint64

func (*ConnectResponse_OpenResponse) GotenMessage

func (*ConnectResponse_OpenResponse) GotenMessage()

func (*ConnectResponse_OpenResponse) GotenValidate

func (obj *ConnectResponse_OpenResponse) GotenValidate() error

func (*ConnectResponse_OpenResponse) Marshal

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

func (*ConnectResponse_OpenResponse) MarshalJSON

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

func (*ConnectResponse_OpenResponse) ProtoMessage

func (*ConnectResponse_OpenResponse) ProtoMessage()

func (*ConnectResponse_OpenResponse) ProtoReflect

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

func (*ConnectResponse_OpenResponse) Reset

func (m *ConnectResponse_OpenResponse) Reset()

func (*ConnectResponse_OpenResponse) SetChannelId

func (m *ConnectResponse_OpenResponse) SetChannelId(fv uint64)

func (*ConnectResponse_OpenResponse) SetSessionId

func (m *ConnectResponse_OpenResponse) SetSessionId(fv uint64)

func (*ConnectResponse_OpenResponse) String

func (*ConnectResponse_OpenResponse) Unmarshal

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

func (*ConnectResponse_OpenResponse) UnmarshalJSON

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

type ConnectResponse_OpenResponse_

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

type ConnectResponse_Pong

type ConnectResponse_Pong struct {
	Pong *Pong `protobuf:"bytes,8,opt,name=pong,proto3,oneof" firestore:"pong"`
}

type ConnectResponse_ResumeResponse

type ConnectResponse_ResumeResponse struct {
	SessionId     uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	ChannelId     uint64 `protobuf:"varint,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	LastMessageId uint64 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectResponse_ResumeResponse) Descriptor

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

Deprecated, Use ConnectResponse_ResumeResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse_ResumeResponse) GetChannelId

func (m *ConnectResponse_ResumeResponse) GetChannelId() uint64

func (*ConnectResponse_ResumeResponse) GetLastMessageId

func (m *ConnectResponse_ResumeResponse) GetLastMessageId() uint64

func (*ConnectResponse_ResumeResponse) GetSessionId

func (m *ConnectResponse_ResumeResponse) GetSessionId() uint64

func (*ConnectResponse_ResumeResponse) GotenMessage

func (*ConnectResponse_ResumeResponse) GotenMessage()

func (*ConnectResponse_ResumeResponse) GotenValidate

func (obj *ConnectResponse_ResumeResponse) GotenValidate() error

func (*ConnectResponse_ResumeResponse) Marshal

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

func (*ConnectResponse_ResumeResponse) MarshalJSON

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

func (*ConnectResponse_ResumeResponse) ProtoMessage

func (*ConnectResponse_ResumeResponse) ProtoMessage()

func (*ConnectResponse_ResumeResponse) ProtoReflect

func (*ConnectResponse_ResumeResponse) Reset

func (m *ConnectResponse_ResumeResponse) Reset()

func (*ConnectResponse_ResumeResponse) SetChannelId

func (m *ConnectResponse_ResumeResponse) SetChannelId(fv uint64)

func (*ConnectResponse_ResumeResponse) SetLastMessageId

func (m *ConnectResponse_ResumeResponse) SetLastMessageId(fv uint64)

func (*ConnectResponse_ResumeResponse) SetSessionId

func (m *ConnectResponse_ResumeResponse) SetSessionId(fv uint64)

func (*ConnectResponse_ResumeResponse) String

func (*ConnectResponse_ResumeResponse) Unmarshal

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

func (*ConnectResponse_ResumeResponse) UnmarshalJSON

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

type ConnectResponse_ResumeResponse_

type ConnectResponse_ResumeResponse_ struct {
	ResumeResponse *ConnectResponse_ResumeResponse `protobuf:"bytes,2,opt,name=resume_response,json=resumeResponse,proto3,oneof" firestore:"resumeResponse"`
}

type Data

type Data struct {
	Id          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" firestore:"id"`
	Bytes       []byte `protobuf:"bytes,2,opt,name=bytes,proto3" json:"bytes,omitempty" firestore:"bytes"`
	AckRequired bool   `protobuf:"varint,3,opt,name=ack_required,json=ackRequired,proto3" json:"ack_required,omitempty" firestore:"ackRequired"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor

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

Deprecated, Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetAckRequired

func (m *Data) GetAckRequired() bool

func (*Data) GetBytes

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

func (*Data) GetId

func (m *Data) GetId() uint64

func (*Data) GotenMessage

func (*Data) GotenMessage()

func (*Data) GotenValidate

func (obj *Data) GotenValidate() error

func (*Data) Marshal

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

func (*Data) MarshalJSON

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

func (*Data) ProtoMessage

func (*Data) ProtoMessage()

func (*Data) ProtoReflect

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

func (*Data) Reset

func (m *Data) Reset()

func (*Data) SetAckRequired

func (m *Data) SetAckRequired(fv bool)

func (*Data) SetBytes

func (m *Data) SetBytes(fv []byte)

func (*Data) SetId

func (m *Data) SetId(fv uint64)

func (*Data) String

func (m *Data) String() string

func (*Data) Unmarshal

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

func (*Data) UnmarshalJSON

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

type Error

type Error struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" firestore:"id"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" firestore:"message"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor

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

Deprecated, Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetId

func (m *Error) GetId() uint64

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) GotenMessage

func (*Error) GotenMessage()

func (*Error) GotenValidate

func (obj *Error) GotenValidate() error

func (*Error) Marshal

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

func (*Error) MarshalJSON

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

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

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

func (*Error) Reset

func (m *Error) Reset()

func (*Error) SetId

func (m *Error) SetId(fv uint64)

func (*Error) SetMessage

func (m *Error) SetMessage(fv string)

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

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

func (*Error) UnmarshalJSON

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

type ListenClientStream

type ListenClientStream interface {
	Send(*ListenRequest) error
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type ListenDescriptor

type ListenDescriptor struct{}

func GetListenDescriptor

func GetListenDescriptor() *ListenDescriptor

func (*ListenDescriptor) GetApiDescriptor

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

func (*ListenDescriptor) GetApiName

func (d *ListenDescriptor) GetApiName() string

func (*ListenDescriptor) GetClientMsgReflectHandle

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

func (*ListenDescriptor) GetFullMethodName

func (d *ListenDescriptor) GetFullMethodName() string

func (*ListenDescriptor) GetMethodName

func (d *ListenDescriptor) GetMethodName() string

func (*ListenDescriptor) GetProtoPkgName

func (d *ListenDescriptor) GetProtoPkgName() string

func (*ListenDescriptor) GetResourceDescriptor

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

func (*ListenDescriptor) GetServerMsgReflectHandle

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

func (*ListenDescriptor) GetServiceDomain

func (d *ListenDescriptor) GetServiceDomain() string

func (*ListenDescriptor) GetServiceVersion

func (d *ListenDescriptor) GetServiceVersion() string

func (*ListenDescriptor) GetVerb

func (d *ListenDescriptor) GetVerb() string

func (*ListenDescriptor) HasResource

func (d *ListenDescriptor) HasResource() bool

func (*ListenDescriptor) IsClientStream

func (d *ListenDescriptor) IsClientStream() bool

func (*ListenDescriptor) IsCollection

func (d *ListenDescriptor) IsCollection() bool

func (*ListenDescriptor) IsPlural

func (d *ListenDescriptor) IsPlural() bool

func (*ListenDescriptor) IsServerStream

func (d *ListenDescriptor) IsServerStream() bool

func (*ListenDescriptor) IsUnary

func (d *ListenDescriptor) IsUnary() bool

func (*ListenDescriptor) NewEmptyClientMsg

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

func (*ListenDescriptor) NewEmptyServerMsg

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

func (*ListenDescriptor) RequestHasResourceBody

func (d *ListenDescriptor) RequestHasResourceBody() bool

type ListenDescriptorClientMsgHandle

type ListenDescriptorClientMsgHandle struct{}

func (*ListenDescriptorClientMsgHandle) ExtractCollectionName

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

func (*ListenDescriptorClientMsgHandle) ExtractResourceBodies

func (*ListenDescriptorClientMsgHandle) ExtractResourceBody

func (*ListenDescriptorClientMsgHandle) ExtractResourceName

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

func (*ListenDescriptorClientMsgHandle) ExtractResourceNames

type ListenDescriptorServerMsgHandle

type ListenDescriptorServerMsgHandle struct{}

func (*ListenDescriptorServerMsgHandle) ExtractCollectionName

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

func (*ListenDescriptorServerMsgHandle) ExtractResourceBodies

func (*ListenDescriptorServerMsgHandle) ExtractResourceBody

func (*ListenDescriptorServerMsgHandle) ExtractResourceName

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

func (*ListenDescriptorServerMsgHandle) ExtractResourceNames

type ListenRequest

type ListenRequest struct {

	// Types that are valid to be assigned to Message:
	//	*ListenRequest_OpenRequest_
	//	*ListenRequest_ResumeRequest_
	//	*ListenRequest_ChannelOpenError_
	//	*ListenRequest_Ping
	Message isListenRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Request message for method [Listen][ntt.proxies.v1.Listen]

func (*ListenRequest) Descriptor

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

Deprecated, Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetChannelOpenError

func (m *ListenRequest) GetChannelOpenError() *ListenRequest_ChannelOpenError

func (*ListenRequest) GetMessage

func (m *ListenRequest) GetMessage() isListenRequest_Message

func (*ListenRequest) GetOpenRequest

func (m *ListenRequest) GetOpenRequest() *ListenRequest_OpenRequest

func (*ListenRequest) GetPing

func (m *ListenRequest) GetPing() *Ping

func (*ListenRequest) GetResumeRequest

func (m *ListenRequest) GetResumeRequest() *ListenRequest_ResumeRequest

func (*ListenRequest) GotenMessage

func (*ListenRequest) GotenMessage()

func (*ListenRequest) GotenValidate

func (obj *ListenRequest) GotenValidate() error

func (*ListenRequest) Marshal

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

func (*ListenRequest) MarshalJSON

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

func (*ListenRequest) ProtoMessage

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect

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

func (*ListenRequest) Reset

func (m *ListenRequest) Reset()

func (*ListenRequest) SetChannelOpenError

func (m *ListenRequest) SetChannelOpenError(fv *ListenRequest_ChannelOpenError)

func (*ListenRequest) SetMessage

func (m *ListenRequest) SetMessage(ofv isListenRequest_Message)

func (*ListenRequest) SetOpenRequest

func (m *ListenRequest) SetOpenRequest(fv *ListenRequest_OpenRequest)

func (*ListenRequest) SetPing

func (m *ListenRequest) SetPing(fv *Ping)

func (*ListenRequest) SetResumeRequest

func (m *ListenRequest) SetResumeRequest(fv *ListenRequest_ResumeRequest)

func (*ListenRequest) String

func (m *ListenRequest) String() string

func (*ListenRequest) Unmarshal

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

func (*ListenRequest) UnmarshalJSON

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

type ListenRequest_ChannelOpenError

type ListenRequest_ChannelOpenError struct {

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

func (*ListenRequest_ChannelOpenError) Descriptor

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

Deprecated, Use ListenRequest_ChannelOpenError.ProtoReflect.Descriptor instead.

func (*ListenRequest_ChannelOpenError) GetChannelId

func (m *ListenRequest_ChannelOpenError) GetChannelId() uint64

func (*ListenRequest_ChannelOpenError) GetMessage

func (m *ListenRequest_ChannelOpenError) GetMessage() string

func (*ListenRequest_ChannelOpenError) GotenMessage

func (*ListenRequest_ChannelOpenError) GotenMessage()

func (*ListenRequest_ChannelOpenError) GotenValidate

func (obj *ListenRequest_ChannelOpenError) GotenValidate() error

func (*ListenRequest_ChannelOpenError) Marshal

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

func (*ListenRequest_ChannelOpenError) MarshalJSON

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

func (*ListenRequest_ChannelOpenError) ProtoMessage

func (*ListenRequest_ChannelOpenError) ProtoMessage()

func (*ListenRequest_ChannelOpenError) ProtoReflect

func (*ListenRequest_ChannelOpenError) Reset

func (m *ListenRequest_ChannelOpenError) Reset()

func (*ListenRequest_ChannelOpenError) SetChannelId

func (m *ListenRequest_ChannelOpenError) SetChannelId(fv uint64)

func (*ListenRequest_ChannelOpenError) SetMessage

func (m *ListenRequest_ChannelOpenError) SetMessage(fv string)

func (*ListenRequest_ChannelOpenError) String

func (*ListenRequest_ChannelOpenError) Unmarshal

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

func (*ListenRequest_ChannelOpenError) UnmarshalJSON

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

type ListenRequest_ChannelOpenError_

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

type ListenRequest_OpenRequest

type ListenRequest_OpenRequest struct {
	Project  *project.Name `protobuf:"bytes,1,opt,customtype=Name,name=project,proto3" json:"project,omitempty" firestore:"project"`
	RegionId string        `protobuf:"bytes,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// Service domain (for example devices.edgelq.com) for this provider.
	ServiceDomain string `` /* 126-byte string literal not displayed */
	// The self-declared device name, used for authentication/authorization.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" firestore:"name"`
	// contains filtered or unexported fields
}

func (*ListenRequest_OpenRequest) Descriptor

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

Deprecated, Use ListenRequest_OpenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest_OpenRequest) GetName

func (m *ListenRequest_OpenRequest) GetName() string

func (*ListenRequest_OpenRequest) GetProject

func (m *ListenRequest_OpenRequest) GetProject() *project.Name

func (*ListenRequest_OpenRequest) GetRegionId

func (m *ListenRequest_OpenRequest) GetRegionId() string

func (*ListenRequest_OpenRequest) GetServiceDomain

func (m *ListenRequest_OpenRequest) GetServiceDomain() string

func (*ListenRequest_OpenRequest) GotenMessage

func (*ListenRequest_OpenRequest) GotenMessage()

func (*ListenRequest_OpenRequest) GotenValidate

func (obj *ListenRequest_OpenRequest) GotenValidate() error

func (*ListenRequest_OpenRequest) Marshal

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

func (*ListenRequest_OpenRequest) MarshalJSON

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

func (*ListenRequest_OpenRequest) ProtoMessage

func (*ListenRequest_OpenRequest) ProtoMessage()

func (*ListenRequest_OpenRequest) ProtoReflect

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

func (*ListenRequest_OpenRequest) Reset

func (m *ListenRequest_OpenRequest) Reset()

func (*ListenRequest_OpenRequest) SetName

func (m *ListenRequest_OpenRequest) SetName(fv string)

func (*ListenRequest_OpenRequest) SetProject

func (m *ListenRequest_OpenRequest) SetProject(fv *project.Name)

func (*ListenRequest_OpenRequest) SetRegionId

func (m *ListenRequest_OpenRequest) SetRegionId(fv string)

func (*ListenRequest_OpenRequest) SetServiceDomain

func (m *ListenRequest_OpenRequest) SetServiceDomain(fv string)

func (*ListenRequest_OpenRequest) String

func (m *ListenRequest_OpenRequest) String() string

func (*ListenRequest_OpenRequest) Unmarshal

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

func (*ListenRequest_OpenRequest) UnmarshalJSON

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

type ListenRequest_OpenRequest_

type ListenRequest_OpenRequest_ struct {
	// This is a hello message from the agent with its name.
	OpenRequest *ListenRequest_OpenRequest `protobuf:"bytes,1,opt,name=open_request,json=openRequest,proto3,oneof" firestore:"openRequest"`
}

type ListenRequest_Ping

type ListenRequest_Ping struct {
	Ping *Ping `protobuf:"bytes,4,opt,name=ping,proto3,oneof" firestore:"ping"`
}

type ListenRequest_ResumeRequest

type ListenRequest_ResumeRequest struct {
	Project  *project.Name `protobuf:"bytes,1,opt,customtype=Name,name=project,proto3" json:"project,omitempty" firestore:"project"`
	RegionId string        `protobuf:"bytes,4,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// Service domain (for example devices.edgelq.com) for this provider.
	ServiceDomain string `` /* 126-byte string literal not displayed */
	// The self-declared device name, used for authentication/authorization.
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" firestore:"name"`
	SessionId uint64 `protobuf:"varint,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	// contains filtered or unexported fields
}

func (*ListenRequest_ResumeRequest) Descriptor

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

Deprecated, Use ListenRequest_ResumeRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest_ResumeRequest) GetName

func (m *ListenRequest_ResumeRequest) GetName() string

func (*ListenRequest_ResumeRequest) GetProject

func (m *ListenRequest_ResumeRequest) GetProject() *project.Name

func (*ListenRequest_ResumeRequest) GetRegionId

func (m *ListenRequest_ResumeRequest) GetRegionId() string

func (*ListenRequest_ResumeRequest) GetServiceDomain

func (m *ListenRequest_ResumeRequest) GetServiceDomain() string

func (*ListenRequest_ResumeRequest) GetSessionId

func (m *ListenRequest_ResumeRequest) GetSessionId() uint64

func (*ListenRequest_ResumeRequest) GotenMessage

func (*ListenRequest_ResumeRequest) GotenMessage()

func (*ListenRequest_ResumeRequest) GotenValidate

func (obj *ListenRequest_ResumeRequest) GotenValidate() error

func (*ListenRequest_ResumeRequest) Marshal

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

func (*ListenRequest_ResumeRequest) MarshalJSON

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

func (*ListenRequest_ResumeRequest) ProtoMessage

func (*ListenRequest_ResumeRequest) ProtoMessage()

func (*ListenRequest_ResumeRequest) ProtoReflect

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

func (*ListenRequest_ResumeRequest) Reset

func (m *ListenRequest_ResumeRequest) Reset()

func (*ListenRequest_ResumeRequest) SetName

func (m *ListenRequest_ResumeRequest) SetName(fv string)

func (*ListenRequest_ResumeRequest) SetProject

func (m *ListenRequest_ResumeRequest) SetProject(fv *project.Name)

func (*ListenRequest_ResumeRequest) SetRegionId

func (m *ListenRequest_ResumeRequest) SetRegionId(fv string)

func (*ListenRequest_ResumeRequest) SetServiceDomain

func (m *ListenRequest_ResumeRequest) SetServiceDomain(fv string)

func (*ListenRequest_ResumeRequest) SetSessionId

func (m *ListenRequest_ResumeRequest) SetSessionId(fv uint64)

func (*ListenRequest_ResumeRequest) String

func (m *ListenRequest_ResumeRequest) String() string

func (*ListenRequest_ResumeRequest) Unmarshal

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

func (*ListenRequest_ResumeRequest) UnmarshalJSON

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

type ListenRequest_ResumeRequest_

type ListenRequest_ResumeRequest_ struct {
	ResumeRequest *ListenRequest_ResumeRequest `protobuf:"bytes,2,opt,name=resume_request,json=resumeRequest,proto3,oneof" firestore:"resumeRequest"`
}

type ListenResponse

type ListenResponse struct {

	// Types that are valid to be assigned to Message:
	//	*ListenResponse_Listening_
	//	*ListenResponse_OpenChannelResponse_
	//	*ListenResponse_ResumeChannelResponse_
	//	*ListenResponse_Pong
	Message isListenResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Response message for method [Listen][ntt.proxies.v1.Listen]

func (*ListenResponse) Descriptor

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

Deprecated, Use ListenResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse) GetListening

func (m *ListenResponse) GetListening() *ListenResponse_Listening

func (*ListenResponse) GetMessage

func (m *ListenResponse) GetMessage() isListenResponse_Message

func (*ListenResponse) GetOpenChannelResponse

func (m *ListenResponse) GetOpenChannelResponse() *ListenResponse_OpenChannelResponse

func (*ListenResponse) GetPong

func (m *ListenResponse) GetPong() *Pong

func (*ListenResponse) GetResumeChannelResponse

func (m *ListenResponse) GetResumeChannelResponse() *ListenResponse_ResumeChannelResponse

func (*ListenResponse) GotenMessage

func (*ListenResponse) GotenMessage()

func (*ListenResponse) GotenValidate

func (obj *ListenResponse) GotenValidate() error

func (*ListenResponse) Marshal

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

func (*ListenResponse) MarshalJSON

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

func (*ListenResponse) ProtoMessage

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) ProtoReflect

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

func (*ListenResponse) Reset

func (m *ListenResponse) Reset()

func (*ListenResponse) SetListening

func (m *ListenResponse) SetListening(fv *ListenResponse_Listening)

func (*ListenResponse) SetMessage

func (m *ListenResponse) SetMessage(ofv isListenResponse_Message)

func (*ListenResponse) SetOpenChannelResponse

func (m *ListenResponse) SetOpenChannelResponse(fv *ListenResponse_OpenChannelResponse)

func (*ListenResponse) SetPong

func (m *ListenResponse) SetPong(fv *Pong)

func (*ListenResponse) SetResumeChannelResponse

func (m *ListenResponse) SetResumeChannelResponse(fv *ListenResponse_ResumeChannelResponse)

func (*ListenResponse) String

func (m *ListenResponse) String() string

func (*ListenResponse) Unmarshal

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

func (*ListenResponse) UnmarshalJSON

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

type ListenResponse_Listening

type ListenResponse_Listening struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" firestore:"sessionId"`
	// contains filtered or unexported fields
}

func (*ListenResponse_Listening) Descriptor

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

Deprecated, Use ListenResponse_Listening.ProtoReflect.Descriptor instead.

func (*ListenResponse_Listening) GetSessionId

func (m *ListenResponse_Listening) GetSessionId() uint64

func (*ListenResponse_Listening) GotenMessage

func (*ListenResponse_Listening) GotenMessage()

func (*ListenResponse_Listening) GotenValidate

func (obj *ListenResponse_Listening) GotenValidate() error

func (*ListenResponse_Listening) Marshal

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

func (*ListenResponse_Listening) MarshalJSON

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

func (*ListenResponse_Listening) ProtoMessage

func (*ListenResponse_Listening) ProtoMessage()

func (*ListenResponse_Listening) ProtoReflect

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

func (*ListenResponse_Listening) Reset

func (m *ListenResponse_Listening) Reset()

func (*ListenResponse_Listening) SetSessionId

func (m *ListenResponse_Listening) SetSessionId(fv uint64)

func (*ListenResponse_Listening) String

func (m *ListenResponse_Listening) String() string

func (*ListenResponse_Listening) Unmarshal

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

func (*ListenResponse_Listening) UnmarshalJSON

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

type ListenResponse_Listening_

type ListenResponse_Listening_ struct {
	Listening *ListenResponse_Listening `protobuf:"bytes,1,opt,name=listening,proto3,oneof" firestore:"listening"`
}

type ListenResponse_OpenChannelResponse

type ListenResponse_OpenChannelResponse struct {

	// Channel ID
	ChannelId uint64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	// Device service;
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty" firestore:"service"`
	// Initial argument (optional)
	Arg []byte `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty" firestore:"arg"`
	// contains filtered or unexported fields
}

func (*ListenResponse_OpenChannelResponse) Descriptor

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

Deprecated, Use ListenResponse_OpenChannelResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse_OpenChannelResponse) GetArg

func (*ListenResponse_OpenChannelResponse) GetChannelId

func (m *ListenResponse_OpenChannelResponse) GetChannelId() uint64

func (*ListenResponse_OpenChannelResponse) GetService

func (*ListenResponse_OpenChannelResponse) GotenMessage

func (*ListenResponse_OpenChannelResponse) GotenMessage()

func (*ListenResponse_OpenChannelResponse) GotenValidate

func (obj *ListenResponse_OpenChannelResponse) GotenValidate() error

func (*ListenResponse_OpenChannelResponse) Marshal

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

func (*ListenResponse_OpenChannelResponse) MarshalJSON

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

func (*ListenResponse_OpenChannelResponse) ProtoMessage

func (*ListenResponse_OpenChannelResponse) ProtoMessage()

func (*ListenResponse_OpenChannelResponse) ProtoReflect

func (*ListenResponse_OpenChannelResponse) Reset

func (*ListenResponse_OpenChannelResponse) SetArg

func (m *ListenResponse_OpenChannelResponse) SetArg(fv []byte)

func (*ListenResponse_OpenChannelResponse) SetChannelId

func (m *ListenResponse_OpenChannelResponse) SetChannelId(fv uint64)

func (*ListenResponse_OpenChannelResponse) SetService

func (m *ListenResponse_OpenChannelResponse) SetService(fv string)

func (*ListenResponse_OpenChannelResponse) String

func (*ListenResponse_OpenChannelResponse) Unmarshal

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

func (*ListenResponse_OpenChannelResponse) UnmarshalJSON

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

type ListenResponse_OpenChannelResponse_

type ListenResponse_OpenChannelResponse_ struct {
	// Notifies a new channel has been requested by a client.
	OpenChannelResponse *ListenResponse_OpenChannelResponse `protobuf:"bytes,2,opt,name=open_channel_response,json=openChannelResponse,proto3,oneof" firestore:"openChannelResponse"`
}

type ListenResponse_Pong

type ListenResponse_Pong struct {
	Pong *Pong `protobuf:"bytes,4,opt,name=pong,proto3,oneof" firestore:"pong"`
}

type ListenResponse_ResumeChannelResponse

type ListenResponse_ResumeChannelResponse struct {

	// Channel ID
	ChannelId uint64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" firestore:"channelId"`
	// Device service;
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty" firestore:"service"`
	// Initial argument (optional)
	Arg           []byte `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty" firestore:"arg"`
	LastMessageId uint64 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListenResponse_ResumeChannelResponse) Descriptor

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

Deprecated, Use ListenResponse_ResumeChannelResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse_ResumeChannelResponse) GetArg

func (*ListenResponse_ResumeChannelResponse) GetChannelId

func (m *ListenResponse_ResumeChannelResponse) GetChannelId() uint64

func (*ListenResponse_ResumeChannelResponse) GetLastMessageId

func (m *ListenResponse_ResumeChannelResponse) GetLastMessageId() uint64

func (*ListenResponse_ResumeChannelResponse) GetService

func (*ListenResponse_ResumeChannelResponse) GotenMessage

func (*ListenResponse_ResumeChannelResponse) GotenMessage()

func (*ListenResponse_ResumeChannelResponse) GotenValidate

func (obj *ListenResponse_ResumeChannelResponse) GotenValidate() error

func (*ListenResponse_ResumeChannelResponse) Marshal

func (*ListenResponse_ResumeChannelResponse) MarshalJSON

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

func (*ListenResponse_ResumeChannelResponse) ProtoMessage

func (*ListenResponse_ResumeChannelResponse) ProtoMessage()

func (*ListenResponse_ResumeChannelResponse) ProtoReflect

func (*ListenResponse_ResumeChannelResponse) Reset

func (*ListenResponse_ResumeChannelResponse) SetArg

func (*ListenResponse_ResumeChannelResponse) SetChannelId

func (m *ListenResponse_ResumeChannelResponse) SetChannelId(fv uint64)

func (*ListenResponse_ResumeChannelResponse) SetLastMessageId

func (m *ListenResponse_ResumeChannelResponse) SetLastMessageId(fv uint64)

func (*ListenResponse_ResumeChannelResponse) SetService

func (m *ListenResponse_ResumeChannelResponse) SetService(fv string)

func (*ListenResponse_ResumeChannelResponse) String

func (*ListenResponse_ResumeChannelResponse) Unmarshal

func (*ListenResponse_ResumeChannelResponse) UnmarshalJSON

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

type ListenResponse_ResumeChannelResponse_

type ListenResponse_ResumeChannelResponse_ struct {
	// Notifies a channel was asked to be resumed by a client
	ResumeChannelResponse *ListenResponse_ResumeChannelResponse `protobuf:"bytes,3,opt,name=resume_channel_response,json=resumeChannelResponse,proto3,oneof" firestore:"resumeChannelResponse"`
}

type Ping

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

func (*Ping) Descriptor

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

Deprecated, Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GotenMessage

func (*Ping) GotenMessage()

func (*Ping) GotenValidate

func (obj *Ping) GotenValidate() error

func (*Ping) Marshal

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

func (*Ping) MarshalJSON

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

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect

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

func (*Ping) Reset

func (m *Ping) Reset()

func (*Ping) String

func (m *Ping) String() string

func (*Ping) Unmarshal

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

func (*Ping) UnmarshalJSON

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

type Pong

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

func (*Pong) Descriptor

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

Deprecated, Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GotenMessage

func (*Pong) GotenMessage()

func (*Pong) GotenValidate

func (obj *Pong) GotenValidate() error

func (*Pong) Marshal

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

func (*Pong) MarshalJSON

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

func (*Pong) ProtoMessage

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect

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

func (*Pong) Reset

func (m *Pong) Reset()

func (*Pong) String

func (m *Pong) String() string

func (*Pong) Unmarshal

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

func (*Pong) UnmarshalJSON

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

Jump to

Keyboard shortcuts

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