broker_client

package
v1.9.1 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 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 (h *AcceptDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*AcceptDescriptorClientMsgHandle) ExtractResourceBody 

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

func (*AcceptDescriptorClientMsgHandle) ExtractResourceName 

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

func (*AcceptDescriptorClientMsgHandle) ExtractResourceNames 

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

type AcceptDescriptorServerMsgHandle 

type AcceptDescriptorServerMsgHandle struct{}

func (*AcceptDescriptorServerMsgHandle) ExtractCollectionName 

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

func (*AcceptDescriptorServerMsgHandle) ExtractResourceBodies 

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

func (*AcceptDescriptorServerMsgHandle) ExtractResourceBody 

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

func (*AcceptDescriptorServerMsgHandle) ExtractResourceName 

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

func (*AcceptDescriptorServerMsgHandle) ExtractResourceNames 

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

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.

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc grpc.ClientConnInterface) BrokerServiceClient

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 (h *ConnectDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ConnectDescriptorClientMsgHandle) ExtractResourceBody 

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

func (*ConnectDescriptorClientMsgHandle) ExtractResourceName 

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

func (*ConnectDescriptorClientMsgHandle) ExtractResourceNames 

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

type ConnectDescriptorServerMsgHandle 

type ConnectDescriptorServerMsgHandle struct{}

func (*ConnectDescriptorServerMsgHandle) ExtractCollectionName 

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

func (*ConnectDescriptorServerMsgHandle) ExtractResourceBodies 

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

func (*ConnectDescriptorServerMsgHandle) ExtractResourceBody 

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

func (*ConnectDescriptorServerMsgHandle) ExtractResourceName 

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

func (*ConnectDescriptorServerMsgHandle) ExtractResourceNames 

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

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

func (*ConnectResponse_ChannelOpenError) Reset 

func (m *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 (m *ConnectResponse_ChannelOpenError) String() 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 (m *ConnectResponse_OpenResponse) String() 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 (m *ConnectResponse_ResumeResponse) ProtoReflect() preflect.Message

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 (m *ConnectResponse_ResumeResponse) String() 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 (h *ListenDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ListenDescriptorClientMsgHandle) ExtractResourceBody 

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

func (*ListenDescriptorClientMsgHandle) ExtractResourceName 

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

func (*ListenDescriptorClientMsgHandle) ExtractResourceNames 

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

type ListenDescriptorServerMsgHandle 

type ListenDescriptorServerMsgHandle struct{}

func (*ListenDescriptorServerMsgHandle) ExtractCollectionName 

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

func (*ListenDescriptorServerMsgHandle) ExtractResourceBodies 

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

func (*ListenDescriptorServerMsgHandle) ExtractResourceBody 

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

func (*ListenDescriptorServerMsgHandle) ExtractResourceName 

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

func (*ListenDescriptorServerMsgHandle) ExtractResourceNames 

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

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

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 (m *ListenRequest_ChannelOpenError) String() 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 (m *ListenResponse_OpenChannelResponse) GetArg() []byte

func (*ListenResponse_OpenChannelResponse) GetChannelId 

func (m *ListenResponse_OpenChannelResponse) GetChannelId() uint64

func (*ListenResponse_OpenChannelResponse) GetService 

func (m *ListenResponse_OpenChannelResponse) GetService() string

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

func (*ListenResponse_OpenChannelResponse) Reset 

func (m *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 (m *ListenResponse_OpenChannelResponse) String() 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 (m *ListenResponse_ResumeChannelResponse) GetArg() []byte

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 (m *ListenResponse_ResumeChannelResponse) GetService() string

func (*ListenResponse_ResumeChannelResponse) GotenMessage 

func (*ListenResponse_ResumeChannelResponse) GotenMessage()

func (*ListenResponse_ResumeChannelResponse) GotenValidate 

func (obj *ListenResponse_ResumeChannelResponse) GotenValidate() error

func (*ListenResponse_ResumeChannelResponse) Marshal 

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

func (*ListenResponse_ResumeChannelResponse) MarshalJSON 

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

func (*ListenResponse_ResumeChannelResponse) ProtoMessage 

func (*ListenResponse_ResumeChannelResponse) ProtoMessage()

func (*ListenResponse_ResumeChannelResponse) ProtoReflect 

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

func (*ListenResponse_ResumeChannelResponse) Reset 

func (m *ListenResponse_ResumeChannelResponse) Reset()

func (*ListenResponse_ResumeChannelResponse) SetArg 

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

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 (m *ListenResponse_ResumeChannelResponse) String() string

func (*ListenResponse_ResumeChannelResponse) Unmarshal 

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

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

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.