Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterServerSideApiHTTPServer(s *http.Server, srv ServerSideApiHTTPServer)
- func RegisterServerSideApiServer(s grpc.ServiceRegistrar, srv ServerSideApiServer)
- type DisconnectReply
- type DisconnectRequest
- func (*DisconnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectRequest) GetClient() string
- func (x *DisconnectRequest) GetCode() int32
- func (x *DisconnectRequest) GetReason() string
- func (*DisconnectRequest) ProtoMessage()
- func (x *DisconnectRequest) ProtoReflect() protoreflect.Message
- func (x *DisconnectRequest) Reset()
- func (x *DisconnectRequest) String() string
- type PublishReply
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishRequest) GetContentType() string
- func (x *PublishRequest) GetPayloadBytes() []byte
- func (x *PublishRequest) GetPayloadText() string
- func (x *PublishRequest) GetQos() int32
- func (x *PublishRequest) GetRetain() bool
- func (x *PublishRequest) GetRoute() string
- func (x *PublishRequest) GetTopic() string
- func (*PublishRequest) ProtoMessage()
- func (x *PublishRequest) ProtoReflect() protoreflect.Message
- func (x *PublishRequest) Reset()
- func (x *PublishRequest) String() string
- type ServerSideApiClient
- type ServerSideApiHTTPClient
- type ServerSideApiHTTPClientImpl
- func (c *ServerSideApiHTTPClientImpl) Disconnect(ctx context.Context, in *DisconnectRequest, opts ...http.CallOption) (*DisconnectReply, error)
- func (c *ServerSideApiHTTPClientImpl) Publish(ctx context.Context, in *PublishRequest, opts ...http.CallOption) (*PublishReply, error)
- func (c *ServerSideApiHTTPClientImpl) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...http.CallOption) (*SubscribeReply, error)
- func (c *ServerSideApiHTTPClientImpl) Survey(ctx context.Context, in *SurveyRequest, opts ...http.CallOption) (*SurveyReply, error)
- func (c *ServerSideApiHTTPClientImpl) Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...http.CallOption) (*UnsubscribeReply, error)
- type ServerSideApiHTTPServer
- type ServerSideApiServer
- type SubscribeReply
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeRequest) GetBroker() string
- func (x *SubscribeRequest) GetClient() string
- func (x *SubscribeRequest) GetFilter() string
- func (x *SubscribeRequest) GetQos() int32
- func (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (x *SubscribeRequest) String() string
- type SurveyReply
- func (*SurveyReply) Descriptor() ([]byte, []int)deprecated
- func (x *SurveyReply) GetError() *shared.Error
- func (x *SurveyReply) GetId() string
- func (x *SurveyReply) GetResults() []*SurveyReply_Result
- func (x *SurveyReply) GetRoute() string
- func (*SurveyReply) ProtoMessage()
- func (x *SurveyReply) ProtoReflect() protoreflect.Message
- func (x *SurveyReply) Reset()
- func (x *SurveyReply) String() string
- type SurveyReply_Result
- func (*SurveyReply_Result) Descriptor() ([]byte, []int)deprecated
- func (x *SurveyReply_Result) GetContentType() string
- func (x *SurveyReply_Result) GetError() *shared.Error
- func (x *SurveyReply_Result) GetMetadata() *shared.Metadata
- func (x *SurveyReply_Result) GetPayloadBytes() []byte
- func (x *SurveyReply_Result) GetPayloadText() string
- func (*SurveyReply_Result) ProtoMessage()
- func (x *SurveyReply_Result) ProtoReflect() protoreflect.Message
- func (x *SurveyReply_Result) Reset()
- func (x *SurveyReply_Result) String() string
- type SurveyRequest
- func (*SurveyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SurveyRequest) GetContentType() string
- func (x *SurveyRequest) GetId() string
- func (x *SurveyRequest) GetPayloadBytes() []byte
- func (x *SurveyRequest) GetPayloadText() string
- func (x *SurveyRequest) GetRoute() string
- func (x *SurveyRequest) GetTimeout() uint32
- func (x *SurveyRequest) GetTopic() string
- func (x *SurveyRequest) GetWaitReplies() uint32
- func (*SurveyRequest) ProtoMessage()
- func (x *SurveyRequest) ProtoReflect() protoreflect.Message
- func (x *SurveyRequest) Reset()
- func (x *SurveyRequest) String() string
- type UnimplementedServerSideApiServer
- func (UnimplementedServerSideApiServer) Disconnect(context.Context, *DisconnectRequest) (*DisconnectReply, error)
- func (UnimplementedServerSideApiServer) Publish(context.Context, *PublishRequest) (*PublishReply, error)
- func (UnimplementedServerSideApiServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeReply, error)
- func (UnimplementedServerSideApiServer) Survey(context.Context, *SurveyRequest) (*SurveyReply, error)
- func (UnimplementedServerSideApiServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeReply, error)
- type UnsafeServerSideApiServer
- type UnsubscribeReply
- type UnsubscribeRequest
- func (*UnsubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeRequest) GetBroker() string
- func (x *UnsubscribeRequest) GetClient() string
- func (x *UnsubscribeRequest) GetFilter() string
- func (*UnsubscribeRequest) ProtoMessage()
- func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeRequest) Reset()
- func (x *UnsubscribeRequest) String() string
Constants ¶
const ( ServerSideApi_Publish_FullMethodName = "/edgehub.protocol.ssapi.v1.ServerSideApi/Publish" ServerSideApi_Survey_FullMethodName = "/edgehub.protocol.ssapi.v1.ServerSideApi/Survey" ServerSideApi_Subscribe_FullMethodName = "/edgehub.protocol.ssapi.v1.ServerSideApi/Subscribe" ServerSideApi_Unsubscribe_FullMethodName = "/edgehub.protocol.ssapi.v1.ServerSideApi/Unsubscribe" ServerSideApi_Disconnect_FullMethodName = "/edgehub.protocol.ssapi.v1.ServerSideApi/Disconnect" )
const OperationServerSideApiDisconnect = "/edgehub.protocol.ssapi.v1.ServerSideApi/Disconnect"
const OperationServerSideApiPublish = "/edgehub.protocol.ssapi.v1.ServerSideApi/Publish"
const OperationServerSideApiSubscribe = "/edgehub.protocol.ssapi.v1.ServerSideApi/Subscribe"
const OperationServerSideApiSurvey = "/edgehub.protocol.ssapi.v1.ServerSideApi/Survey"
const OperationServerSideApiUnsubscribe = "/edgehub.protocol.ssapi.v1.ServerSideApi/Unsubscribe"
Variables ¶
var File_ssapi_v1_api_proto protoreflect.FileDescriptor
var ServerSideApi_ServiceDesc = grpc.ServiceDesc{ ServiceName: "edgehub.protocol.ssapi.v1.ServerSideApi", HandlerType: (*ServerSideApiServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Publish", Handler: _ServerSideApi_Publish_Handler, }, { MethodName: "Survey", Handler: _ServerSideApi_Survey_Handler, }, { MethodName: "Subscribe", Handler: _ServerSideApi_Subscribe_Handler, }, { MethodName: "Unsubscribe", Handler: _ServerSideApi_Unsubscribe_Handler, }, { MethodName: "Disconnect", Handler: _ServerSideApi_Disconnect_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ssapi/v1/api.proto", }
ServerSideApi_ServiceDesc is the grpc.ServiceDesc for ServerSideApi service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServerSideApiHTTPServer ¶
func RegisterServerSideApiHTTPServer(s *http.Server, srv ServerSideApiHTTPServer)
func RegisterServerSideApiServer ¶
func RegisterServerSideApiServer(s grpc.ServiceRegistrar, srv ServerSideApiServer)
Types ¶
type DisconnectReply ¶
type DisconnectReply struct { Error *shared.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*DisconnectReply) Descriptor
deprecated
func (*DisconnectReply) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectReply.ProtoReflect.Descriptor instead.
func (*DisconnectReply) GetError ¶
func (x *DisconnectReply) GetError() *shared.Error
func (*DisconnectReply) ProtoMessage ¶
func (*DisconnectReply) ProtoMessage()
func (*DisconnectReply) ProtoReflect ¶
func (x *DisconnectReply) ProtoReflect() protoreflect.Message
func (*DisconnectReply) Reset ¶
func (x *DisconnectReply) Reset()
func (*DisconnectReply) String ¶
func (x *DisconnectReply) String() string
type DisconnectRequest ¶
type DisconnectRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Code int32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*DisconnectRequest) Descriptor
deprecated
func (*DisconnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectRequest.ProtoReflect.Descriptor instead.
func (*DisconnectRequest) GetClient ¶
func (x *DisconnectRequest) GetClient() string
func (*DisconnectRequest) GetCode ¶
func (x *DisconnectRequest) GetCode() int32
func (*DisconnectRequest) GetReason ¶
func (x *DisconnectRequest) GetReason() string
func (*DisconnectRequest) ProtoMessage ¶
func (*DisconnectRequest) ProtoMessage()
func (*DisconnectRequest) ProtoReflect ¶
func (x *DisconnectRequest) ProtoReflect() protoreflect.Message
func (*DisconnectRequest) Reset ¶
func (x *DisconnectRequest) Reset()
func (*DisconnectRequest) String ¶
func (x *DisconnectRequest) String() string
type PublishReply ¶
type PublishReply struct { Error *shared.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*PublishReply) Descriptor
deprecated
func (*PublishReply) Descriptor() ([]byte, []int)
Deprecated: Use PublishReply.ProtoReflect.Descriptor instead.
func (*PublishReply) GetError ¶
func (x *PublishReply) GetError() *shared.Error
func (*PublishReply) ProtoMessage ¶
func (*PublishReply) ProtoMessage()
func (*PublishReply) ProtoReflect ¶
func (x *PublishReply) ProtoReflect() protoreflect.Message
func (*PublishReply) Reset ¶
func (x *PublishReply) Reset()
func (*PublishReply) String ¶
func (x *PublishReply) String() string
type PublishRequest ¶
type PublishRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Retain bool `protobuf:"varint,2,opt,name=retain,proto3" json:"retain,omitempty"` Qos int32 `protobuf:"varint,3,opt,name=qos,proto3" json:"qos,omitempty"` Route string `protobuf:"bytes,4,opt,name=route,proto3" json:"route,omitempty"` ContentType string `protobuf:"bytes,5,opt,name=content_type,proto3" json:"content_type,omitempty"` PayloadText string `protobuf:"bytes,6,opt,name=payload_text,proto3" json:"payload_text,omitempty"` PayloadBytes []byte `protobuf:"bytes,7,opt,name=payload_bytes,proto3" json:"payload_bytes,omitempty"` // contains filtered or unexported fields }
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) GetContentType ¶
func (x *PublishRequest) GetContentType() string
func (*PublishRequest) GetPayloadBytes ¶
func (x *PublishRequest) GetPayloadBytes() []byte
func (*PublishRequest) GetPayloadText ¶
func (x *PublishRequest) GetPayloadText() string
func (*PublishRequest) GetQos ¶
func (x *PublishRequest) GetQos() int32
func (*PublishRequest) GetRetain ¶
func (x *PublishRequest) GetRetain() bool
func (*PublishRequest) GetRoute ¶ added in v0.0.6
func (x *PublishRequest) GetRoute() string
func (*PublishRequest) GetTopic ¶
func (x *PublishRequest) GetTopic() string
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) ProtoReflect ¶
func (x *PublishRequest) ProtoReflect() protoreflect.Message
func (*PublishRequest) Reset ¶
func (x *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (x *PublishRequest) String() string
type ServerSideApiClient ¶
type ServerSideApiClient interface { Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error) Survey(ctx context.Context, in *SurveyRequest, opts ...grpc.CallOption) (*SurveyReply, error) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeReply, error) Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeReply, error) Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectReply, error) }
ServerSideApiClient is the client API for ServerSideApi service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewServerSideApiClient ¶
func NewServerSideApiClient(cc grpc.ClientConnInterface) ServerSideApiClient
type ServerSideApiHTTPClient ¶
type ServerSideApiHTTPClient interface { Disconnect(ctx context.Context, req *DisconnectRequest, opts ...http.CallOption) (rsp *DisconnectReply, err error) Publish(ctx context.Context, req *PublishRequest, opts ...http.CallOption) (rsp *PublishReply, err error) Subscribe(ctx context.Context, req *SubscribeRequest, opts ...http.CallOption) (rsp *SubscribeReply, err error) Survey(ctx context.Context, req *SurveyRequest, opts ...http.CallOption) (rsp *SurveyReply, err error) Unsubscribe(ctx context.Context, req *UnsubscribeRequest, opts ...http.CallOption) (rsp *UnsubscribeReply, err error) }
func NewServerSideApiHTTPClient ¶
func NewServerSideApiHTTPClient(client *http.Client) ServerSideApiHTTPClient
type ServerSideApiHTTPClientImpl ¶
type ServerSideApiHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*ServerSideApiHTTPClientImpl) Disconnect ¶
func (c *ServerSideApiHTTPClientImpl) Disconnect(ctx context.Context, in *DisconnectRequest, opts ...http.CallOption) (*DisconnectReply, error)
func (*ServerSideApiHTTPClientImpl) Publish ¶
func (c *ServerSideApiHTTPClientImpl) Publish(ctx context.Context, in *PublishRequest, opts ...http.CallOption) (*PublishReply, error)
func (*ServerSideApiHTTPClientImpl) Subscribe ¶
func (c *ServerSideApiHTTPClientImpl) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...http.CallOption) (*SubscribeReply, error)
func (*ServerSideApiHTTPClientImpl) Survey ¶
func (c *ServerSideApiHTTPClientImpl) Survey(ctx context.Context, in *SurveyRequest, opts ...http.CallOption) (*SurveyReply, error)
func (*ServerSideApiHTTPClientImpl) Unsubscribe ¶
func (c *ServerSideApiHTTPClientImpl) Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...http.CallOption) (*UnsubscribeReply, error)
type ServerSideApiHTTPServer ¶
type ServerSideApiHTTPServer interface { Disconnect(context.Context, *DisconnectRequest) (*DisconnectReply, error) Publish(context.Context, *PublishRequest) (*PublishReply, error) Subscribe(context.Context, *SubscribeRequest) (*SubscribeReply, error) Survey(context.Context, *SurveyRequest) (*SurveyReply, error) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeReply, error) }
type ServerSideApiServer ¶
type ServerSideApiServer interface { Publish(context.Context, *PublishRequest) (*PublishReply, error) Survey(context.Context, *SurveyRequest) (*SurveyReply, error) Subscribe(context.Context, *SubscribeRequest) (*SubscribeReply, error) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeReply, error) Disconnect(context.Context, *DisconnectRequest) (*DisconnectReply, error) // contains filtered or unexported methods }
ServerSideApiServer is the server API for ServerSideApi service. All implementations must embed UnimplementedServerSideApiServer for forward compatibility
type SubscribeReply ¶
type SubscribeReply struct { Error *shared.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*SubscribeReply) Descriptor
deprecated
func (*SubscribeReply) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeReply.ProtoReflect.Descriptor instead.
func (*SubscribeReply) GetError ¶
func (x *SubscribeReply) GetError() *shared.Error
func (*SubscribeReply) ProtoMessage ¶
func (*SubscribeReply) ProtoMessage()
func (*SubscribeReply) ProtoReflect ¶
func (x *SubscribeReply) ProtoReflect() protoreflect.Message
func (*SubscribeReply) Reset ¶
func (x *SubscribeReply) Reset()
func (*SubscribeReply) String ¶
func (x *SubscribeReply) String() string
type SubscribeRequest ¶
type SubscribeRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` Qos int32 `protobuf:"varint,3,opt,name=qos,proto3" json:"qos,omitempty"` Broker string `protobuf:"bytes,4,opt,name=broker,proto3" json:"broker,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetBroker ¶
func (x *SubscribeRequest) GetBroker() string
func (*SubscribeRequest) GetClient ¶
func (x *SubscribeRequest) GetClient() string
func (*SubscribeRequest) GetFilter ¶
func (x *SubscribeRequest) GetFilter() string
func (*SubscribeRequest) GetQos ¶
func (x *SubscribeRequest) GetQos() int32
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SurveyReply ¶
type SurveyReply struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Error *shared.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Route string `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"` Results []*SurveyReply_Result `protobuf:"bytes,4,rep,name=results,proto3" json:"results,omitempty"` // contains filtered or unexported fields }
func (*SurveyReply) Descriptor
deprecated
func (*SurveyReply) Descriptor() ([]byte, []int)
Deprecated: Use SurveyReply.ProtoReflect.Descriptor instead.
func (*SurveyReply) GetError ¶
func (x *SurveyReply) GetError() *shared.Error
func (*SurveyReply) GetId ¶
func (x *SurveyReply) GetId() string
func (*SurveyReply) GetResults ¶
func (x *SurveyReply) GetResults() []*SurveyReply_Result
func (*SurveyReply) GetRoute ¶ added in v0.0.6
func (x *SurveyReply) GetRoute() string
func (*SurveyReply) ProtoMessage ¶
func (*SurveyReply) ProtoMessage()
func (*SurveyReply) ProtoReflect ¶
func (x *SurveyReply) ProtoReflect() protoreflect.Message
func (*SurveyReply) Reset ¶
func (x *SurveyReply) Reset()
func (*SurveyReply) String ¶
func (x *SurveyReply) String() string
type SurveyReply_Result ¶
type SurveyReply_Result struct { Error *shared.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Metadata *shared.Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` ContentType string `protobuf:"bytes,5,opt,name=content_type,proto3" json:"content_type,omitempty"` PayloadText string `protobuf:"bytes,6,opt,name=payload_text,proto3" json:"payload_text,omitempty"` PayloadBytes []byte `protobuf:"bytes,7,opt,name=payload_bytes,proto3" json:"payload_bytes,omitempty"` // contains filtered or unexported fields }
func (*SurveyReply_Result) Descriptor
deprecated
func (*SurveyReply_Result) Descriptor() ([]byte, []int)
Deprecated: Use SurveyReply_Result.ProtoReflect.Descriptor instead.
func (*SurveyReply_Result) GetContentType ¶
func (x *SurveyReply_Result) GetContentType() string
func (*SurveyReply_Result) GetError ¶
func (x *SurveyReply_Result) GetError() *shared.Error
func (*SurveyReply_Result) GetMetadata ¶
func (x *SurveyReply_Result) GetMetadata() *shared.Metadata
func (*SurveyReply_Result) GetPayloadBytes ¶
func (x *SurveyReply_Result) GetPayloadBytes() []byte
func (*SurveyReply_Result) GetPayloadText ¶
func (x *SurveyReply_Result) GetPayloadText() string
func (*SurveyReply_Result) ProtoMessage ¶
func (*SurveyReply_Result) ProtoMessage()
func (*SurveyReply_Result) ProtoReflect ¶
func (x *SurveyReply_Result) ProtoReflect() protoreflect.Message
func (*SurveyReply_Result) Reset ¶
func (x *SurveyReply_Result) Reset()
func (*SurveyReply_Result) String ¶
func (x *SurveyReply_Result) String() string
type SurveyRequest ¶
type SurveyRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` WaitReplies uint32 `protobuf:"varint,2,opt,name=wait_replies,proto3" json:"wait_replies,omitempty"` // first, all Timeout uint32 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"` Topic string `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"` Route string `protobuf:"bytes,5,opt,name=route,proto3" json:"route,omitempty"` ContentType string `protobuf:"bytes,6,opt,name=content_type,proto3" json:"content_type,omitempty"` PayloadText string `protobuf:"bytes,7,opt,name=payload_text,proto3" json:"payload_text,omitempty"` PayloadBytes []byte `protobuf:"bytes,8,opt,name=payload_bytes,proto3" json:"payload_bytes,omitempty"` // contains filtered or unexported fields }
func (*SurveyRequest) Descriptor
deprecated
func (*SurveyRequest) Descriptor() ([]byte, []int)
Deprecated: Use SurveyRequest.ProtoReflect.Descriptor instead.
func (*SurveyRequest) GetContentType ¶
func (x *SurveyRequest) GetContentType() string
func (*SurveyRequest) GetId ¶
func (x *SurveyRequest) GetId() string
func (*SurveyRequest) GetPayloadBytes ¶
func (x *SurveyRequest) GetPayloadBytes() []byte
func (*SurveyRequest) GetPayloadText ¶
func (x *SurveyRequest) GetPayloadText() string
func (*SurveyRequest) GetRoute ¶ added in v0.0.6
func (x *SurveyRequest) GetRoute() string
func (*SurveyRequest) GetTimeout ¶
func (x *SurveyRequest) GetTimeout() uint32
func (*SurveyRequest) GetTopic ¶
func (x *SurveyRequest) GetTopic() string
func (*SurveyRequest) GetWaitReplies ¶ added in v0.0.7
func (x *SurveyRequest) GetWaitReplies() uint32
func (*SurveyRequest) ProtoMessage ¶
func (*SurveyRequest) ProtoMessage()
func (*SurveyRequest) ProtoReflect ¶
func (x *SurveyRequest) ProtoReflect() protoreflect.Message
func (*SurveyRequest) Reset ¶
func (x *SurveyRequest) Reset()
func (*SurveyRequest) String ¶
func (x *SurveyRequest) String() string
type UnimplementedServerSideApiServer ¶
type UnimplementedServerSideApiServer struct { }
UnimplementedServerSideApiServer must be embedded to have forward compatible implementations.
func (UnimplementedServerSideApiServer) Disconnect ¶
func (UnimplementedServerSideApiServer) Disconnect(context.Context, *DisconnectRequest) (*DisconnectReply, error)
func (UnimplementedServerSideApiServer) Publish ¶
func (UnimplementedServerSideApiServer) Publish(context.Context, *PublishRequest) (*PublishReply, error)
func (UnimplementedServerSideApiServer) Subscribe ¶
func (UnimplementedServerSideApiServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeReply, error)
func (UnimplementedServerSideApiServer) Survey ¶
func (UnimplementedServerSideApiServer) Survey(context.Context, *SurveyRequest) (*SurveyReply, error)
func (UnimplementedServerSideApiServer) Unsubscribe ¶
func (UnimplementedServerSideApiServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeReply, error)
type UnsafeServerSideApiServer ¶
type UnsafeServerSideApiServer interface {
// contains filtered or unexported methods
}
UnsafeServerSideApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServerSideApiServer will result in compilation errors.
type UnsubscribeReply ¶
type UnsubscribeReply struct { Error *shared.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeReply) Descriptor
deprecated
func (*UnsubscribeReply) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeReply.ProtoReflect.Descriptor instead.
func (*UnsubscribeReply) GetError ¶
func (x *UnsubscribeReply) GetError() *shared.Error
func (*UnsubscribeReply) ProtoMessage ¶
func (*UnsubscribeReply) ProtoMessage()
func (*UnsubscribeReply) ProtoReflect ¶
func (x *UnsubscribeReply) ProtoReflect() protoreflect.Message
func (*UnsubscribeReply) Reset ¶
func (x *UnsubscribeReply) Reset()
func (*UnsubscribeReply) String ¶
func (x *UnsubscribeReply) String() string
type UnsubscribeRequest ¶
type UnsubscribeRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` Broker string `protobuf:"bytes,3,opt,name=broker,proto3" json:"broker,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeRequest) Descriptor
deprecated
func (*UnsubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.
func (*UnsubscribeRequest) GetBroker ¶
func (x *UnsubscribeRequest) GetBroker() string
func (*UnsubscribeRequest) GetClient ¶
func (x *UnsubscribeRequest) GetClient() string
func (*UnsubscribeRequest) GetFilter ¶
func (x *UnsubscribeRequest) GetFilter() string
func (*UnsubscribeRequest) ProtoMessage ¶
func (*UnsubscribeRequest) ProtoMessage()
func (*UnsubscribeRequest) ProtoReflect ¶
func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
func (*UnsubscribeRequest) Reset ¶
func (x *UnsubscribeRequest) Reset()
func (*UnsubscribeRequest) String ¶
func (x *UnsubscribeRequest) String() string