Versions in this module Expand all Collapse all v0 v0.0.5 Nov 29, 2024 v0.0.1 Nov 26, 2024 Changes in this version + const PushService_Channel_FullMethodName + const PushService_GetClientActiveDevices_FullMethodName + const PushService_SendEventToClientChannel_FullMethodName + const PushService_SendEventToClientDeviceChannel_FullMethodName + const PushService_SendEventToTopic_FullMethodName + const PushService_SendEventToTopics_FullMethodName + var Event_Type_name = map[int32]string + var Event_Type_value = map[string]int32 + var File_push_v1_api_proto protoreflect.FileDescriptor + var PushService_ServiceDesc = grpc.ServiceDesc + func RegisterPushServiceServer(s grpc.ServiceRegistrar, srv PushServiceServer) + type ChannelEvent struct + Event *Event + Topic string + UniqueId string + func (*ChannelEvent) Descriptor() ([]byte, []int) + func (*ChannelEvent) ProtoMessage() + func (x *ChannelEvent) GetEvent() *Event + func (x *ChannelEvent) GetTopic() string + func (x *ChannelEvent) GetUniqueId() string + func (x *ChannelEvent) ProtoReflect() protoreflect.Message + func (x *ChannelEvent) Reset() + func (x *ChannelEvent) String() string + type ChannelEventAck struct + Status *ResponseStatus + UniqueId string + func (*ChannelEventAck) Descriptor() ([]byte, []int) + func (*ChannelEventAck) ProtoMessage() + func (x *ChannelEventAck) GetStatus() *ResponseStatus + func (x *ChannelEventAck) GetUniqueId() string + func (x *ChannelEventAck) ProtoReflect() protoreflect.Message + func (x *ChannelEventAck) Reset() + func (x *ChannelEventAck) String() string + type ChannelRequest struct + Request isChannelRequest_Request + func (*ChannelRequest) Descriptor() ([]byte, []int) + func (*ChannelRequest) ProtoMessage() + func (m *ChannelRequest) GetRequest() isChannelRequest_Request + func (x *ChannelRequest) GetChannelEvent() *ChannelEvent + func (x *ChannelRequest) GetChannelEventAck() *ChannelEventAck + func (x *ChannelRequest) GetTopicSubscriptionRequest() *TopicSubscriptionRequest + func (x *ChannelRequest) GetTopicUnsubscriptionRequest() *TopicUnsubscriptionRequest + func (x *ChannelRequest) ProtoReflect() protoreflect.Message + func (x *ChannelRequest) Reset() + func (x *ChannelRequest) String() string + type ChannelRequest_ChannelEvent struct + ChannelEvent *ChannelEvent + type ChannelRequest_ChannelEventAck struct + ChannelEventAck *ChannelEventAck + type ChannelRequest_TopicSubscriptionRequest struct + TopicSubscriptionRequest *TopicSubscriptionRequest + type ChannelRequest_TopicUnsubscriptionRequest struct + TopicUnsubscriptionRequest *TopicUnsubscriptionRequest + type ChannelResponse struct + Response isChannelResponse_Response + func (*ChannelResponse) Descriptor() ([]byte, []int) + func (*ChannelResponse) ProtoMessage() + func (m *ChannelResponse) GetResponse() isChannelResponse_Response + func (x *ChannelResponse) GetChannelEvent() *ChannelEvent + func (x *ChannelResponse) GetChannelEventAck() *ChannelEventAck + func (x *ChannelResponse) GetConnectAck() *ConnectAck + func (x *ChannelResponse) GetTopicSubscriptionRequestAck() *TopicSubscriptionRequestAck + func (x *ChannelResponse) GetTopicUnsubscriptionRequestAck() *TopicUnsubscriptionRequestAck + func (x *ChannelResponse) ProtoReflect() protoreflect.Message + func (x *ChannelResponse) Reset() + func (x *ChannelResponse) String() string + type ChannelResponse_ChannelEvent struct + ChannelEvent *ChannelEvent + type ChannelResponse_ChannelEventAck struct + ChannelEventAck *ChannelEventAck + type ChannelResponse_ConnectAck struct + ConnectAck *ConnectAck + type ChannelResponse_TopicSubscriptionRequestAck struct + TopicSubscriptionRequestAck *TopicSubscriptionRequestAck + type ChannelResponse_TopicUnsubscriptionRequestAck struct + TopicUnsubscriptionRequestAck *TopicUnsubscriptionRequestAck + type ConnectAck struct + Status *ResponseStatus + func (*ConnectAck) Descriptor() ([]byte, []int) + func (*ConnectAck) ProtoMessage() + func (x *ConnectAck) GetStatus() *ResponseStatus + func (x *ConnectAck) ProtoReflect() protoreflect.Message + func (x *ConnectAck) Reset() + func (x *ConnectAck) String() string + type Device struct + Attributes map[string]string + Id string + LoggedInAt *timestamppb.Timestamp + func (*Device) Descriptor() ([]byte, []int) + func (*Device) ProtoMessage() + func (x *Device) GetAttributes() map[string]string + func (x *Device) GetId() string + func (x *Device) GetLoggedInAt() *timestamppb.Timestamp + func (x *Device) ProtoReflect() protoreflect.Message + func (x *Device) Reset() + func (x *Device) String() string + type Event struct + Data *anypb.Any + FormatType Event_Type + Name string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (x *Event) GetData() *anypb.Any + func (x *Event) GetFormatType() Event_Type + func (x *Event) GetName() string + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type Event_Type int32 + const Event_TYPE_JSON_UNSPECIFIED + const Event_TYPE_PROTO + func (Event_Type) Descriptor() protoreflect.EnumDescriptor + func (Event_Type) EnumDescriptor() ([]byte, []int) + func (Event_Type) Type() protoreflect.EnumType + func (x Event_Type) Enum() *Event_Type + func (x Event_Type) Number() protoreflect.EnumNumber + func (x Event_Type) String() string + type GetClientActiveDevicesRequest struct + ClientId string + func (*GetClientActiveDevicesRequest) Descriptor() ([]byte, []int) + func (*GetClientActiveDevicesRequest) ProtoMessage() + func (x *GetClientActiveDevicesRequest) GetClientId() string + func (x *GetClientActiveDevicesRequest) ProtoReflect() protoreflect.Message + func (x *GetClientActiveDevicesRequest) Reset() + func (x *GetClientActiveDevicesRequest) String() string + type GetClientActiveDevicesResponse struct + Devices []*Device + IsClientOnline bool + Status *ResponseStatus + func (*GetClientActiveDevicesResponse) Descriptor() ([]byte, []int) + func (*GetClientActiveDevicesResponse) ProtoMessage() + func (x *GetClientActiveDevicesResponse) GetDevices() []*Device + func (x *GetClientActiveDevicesResponse) GetIsClientOnline() bool + func (x *GetClientActiveDevicesResponse) GetStatus() *ResponseStatus + func (x *GetClientActiveDevicesResponse) ProtoReflect() protoreflect.Message + func (x *GetClientActiveDevicesResponse) Reset() + func (x *GetClientActiveDevicesResponse) String() string + type PushServiceClient interface + Channel func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ChannelRequest, ChannelResponse], error) + GetClientActiveDevices func(ctx context.Context, in *GetClientActiveDevicesRequest, ...) (*GetClientActiveDevicesResponse, error) + SendEventToClientChannel func(ctx context.Context, in *SendEventToClientChannelRequest, ...) (*SendEventToClientChannelResponse, error) + SendEventToClientDeviceChannel func(ctx context.Context, in *SendEventToClientDeviceChannelRequest, ...) (*SendEventToClientDeviceChannelResponse, error) + SendEventToTopic func(ctx context.Context, in *SendEventToTopicRequest, opts ...grpc.CallOption) (*SendEventToTopicResponse, error) + SendEventToTopics func(ctx context.Context, in *SendEventToTopicsRequest, opts ...grpc.CallOption) (*SendEventToTopicsResponse, error) + func NewPushServiceClient(cc grpc.ClientConnInterface) PushServiceClient + type PushServiceServer interface + Channel func(grpc.BidiStreamingServer[ChannelRequest, ChannelResponse]) error + GetClientActiveDevices func(context.Context, *GetClientActiveDevicesRequest) (*GetClientActiveDevicesResponse, error) + SendEventToClientChannel func(context.Context, *SendEventToClientChannelRequest) (*SendEventToClientChannelResponse, error) + SendEventToClientDeviceChannel func(context.Context, *SendEventToClientDeviceChannelRequest) (*SendEventToClientDeviceChannelResponse, error) + SendEventToTopic func(context.Context, *SendEventToTopicRequest) (*SendEventToTopicResponse, error) + SendEventToTopics func(context.Context, *SendEventToTopicsRequest) (*SendEventToTopicsResponse, error) + type PushService_ChannelClient = grpc.BidiStreamingClient[ChannelRequest, ChannelResponse] + type PushService_ChannelServer = grpc.BidiStreamingServer[ChannelRequest, ChannelResponse] + type ResponseStatus struct + ErrorCode string + ErrorType string + Message map[string]string + Success bool + func (*ResponseStatus) Descriptor() ([]byte, []int) + func (*ResponseStatus) ProtoMessage() + func (x *ResponseStatus) GetErrorCode() string + func (x *ResponseStatus) GetErrorType() string + func (x *ResponseStatus) GetMessage() map[string]string + func (x *ResponseStatus) GetSuccess() bool + func (x *ResponseStatus) ProtoReflect() protoreflect.Message + func (x *ResponseStatus) Reset() + func (x *ResponseStatus) String() string + type SendEventToClientChannelRequest struct + ClientId string + Event *Event + func (*SendEventToClientChannelRequest) Descriptor() ([]byte, []int) + func (*SendEventToClientChannelRequest) ProtoMessage() + func (x *SendEventToClientChannelRequest) GetClientId() string + func (x *SendEventToClientChannelRequest) GetEvent() *Event + func (x *SendEventToClientChannelRequest) ProtoReflect() protoreflect.Message + func (x *SendEventToClientChannelRequest) Reset() + func (x *SendEventToClientChannelRequest) String() string + type SendEventToClientChannelResponse struct + Status *ResponseStatus + func (*SendEventToClientChannelResponse) Descriptor() ([]byte, []int) + func (*SendEventToClientChannelResponse) ProtoMessage() + func (x *SendEventToClientChannelResponse) GetStatus() *ResponseStatus + func (x *SendEventToClientChannelResponse) ProtoReflect() protoreflect.Message + func (x *SendEventToClientChannelResponse) Reset() + func (x *SendEventToClientChannelResponse) String() string + type SendEventToClientDeviceChannelRequest struct + ClientId string + DeviceId string + Event *Event + func (*SendEventToClientDeviceChannelRequest) Descriptor() ([]byte, []int) + func (*SendEventToClientDeviceChannelRequest) ProtoMessage() + func (x *SendEventToClientDeviceChannelRequest) GetClientId() string + func (x *SendEventToClientDeviceChannelRequest) GetDeviceId() string + func (x *SendEventToClientDeviceChannelRequest) GetEvent() *Event + func (x *SendEventToClientDeviceChannelRequest) ProtoReflect() protoreflect.Message + func (x *SendEventToClientDeviceChannelRequest) Reset() + func (x *SendEventToClientDeviceChannelRequest) String() string + type SendEventToClientDeviceChannelResponse struct + Status *ResponseStatus + func (*SendEventToClientDeviceChannelResponse) Descriptor() ([]byte, []int) + func (*SendEventToClientDeviceChannelResponse) ProtoMessage() + func (x *SendEventToClientDeviceChannelResponse) GetStatus() *ResponseStatus + func (x *SendEventToClientDeviceChannelResponse) ProtoReflect() protoreflect.Message + func (x *SendEventToClientDeviceChannelResponse) Reset() + func (x *SendEventToClientDeviceChannelResponse) String() string + type SendEventToTopicRequest struct + Event *Event + Topic string + func (*SendEventToTopicRequest) Descriptor() ([]byte, []int) + func (*SendEventToTopicRequest) ProtoMessage() + func (x *SendEventToTopicRequest) GetEvent() *Event + func (x *SendEventToTopicRequest) GetTopic() string + func (x *SendEventToTopicRequest) ProtoReflect() protoreflect.Message + func (x *SendEventToTopicRequest) Reset() + func (x *SendEventToTopicRequest) String() string + type SendEventToTopicResponse struct + Status *ResponseStatus + func (*SendEventToTopicResponse) Descriptor() ([]byte, []int) + func (*SendEventToTopicResponse) ProtoMessage() + func (x *SendEventToTopicResponse) GetStatus() *ResponseStatus + func (x *SendEventToTopicResponse) ProtoReflect() protoreflect.Message + func (x *SendEventToTopicResponse) Reset() + func (x *SendEventToTopicResponse) String() string + type SendEventToTopicsRequest struct + Requests []*SendEventToTopicRequest + func (*SendEventToTopicsRequest) Descriptor() ([]byte, []int) + func (*SendEventToTopicsRequest) ProtoMessage() + func (x *SendEventToTopicsRequest) GetRequests() []*SendEventToTopicRequest + func (x *SendEventToTopicsRequest) ProtoReflect() protoreflect.Message + func (x *SendEventToTopicsRequest) Reset() + func (x *SendEventToTopicsRequest) String() string + type SendEventToTopicsResponse struct + Status *ResponseStatus + func (*SendEventToTopicsResponse) Descriptor() ([]byte, []int) + func (*SendEventToTopicsResponse) ProtoMessage() + func (x *SendEventToTopicsResponse) GetStatus() *ResponseStatus + func (x *SendEventToTopicsResponse) ProtoReflect() protoreflect.Message + func (x *SendEventToTopicsResponse) Reset() + func (x *SendEventToTopicsResponse) String() string + type TopicSubscriptionRequest struct + Topic string + func (*TopicSubscriptionRequest) Descriptor() ([]byte, []int) + func (*TopicSubscriptionRequest) ProtoMessage() + func (x *TopicSubscriptionRequest) GetTopic() string + func (x *TopicSubscriptionRequest) ProtoReflect() protoreflect.Message + func (x *TopicSubscriptionRequest) Reset() + func (x *TopicSubscriptionRequest) String() string + type TopicSubscriptionRequestAck struct + Status *ResponseStatus + Topic string + func (*TopicSubscriptionRequestAck) Descriptor() ([]byte, []int) + func (*TopicSubscriptionRequestAck) ProtoMessage() + func (x *TopicSubscriptionRequestAck) GetStatus() *ResponseStatus + func (x *TopicSubscriptionRequestAck) GetTopic() string + func (x *TopicSubscriptionRequestAck) ProtoReflect() protoreflect.Message + func (x *TopicSubscriptionRequestAck) Reset() + func (x *TopicSubscriptionRequestAck) String() string + type TopicUnsubscriptionRequest struct + Topic string + func (*TopicUnsubscriptionRequest) Descriptor() ([]byte, []int) + func (*TopicUnsubscriptionRequest) ProtoMessage() + func (x *TopicUnsubscriptionRequest) GetTopic() string + func (x *TopicUnsubscriptionRequest) ProtoReflect() protoreflect.Message + func (x *TopicUnsubscriptionRequest) Reset() + func (x *TopicUnsubscriptionRequest) String() string + type TopicUnsubscriptionRequestAck struct + Status *ResponseStatus + Topic string + func (*TopicUnsubscriptionRequestAck) Descriptor() ([]byte, []int) + func (*TopicUnsubscriptionRequestAck) ProtoMessage() + func (x *TopicUnsubscriptionRequestAck) GetStatus() *ResponseStatus + func (x *TopicUnsubscriptionRequestAck) GetTopic() string + func (x *TopicUnsubscriptionRequestAck) ProtoReflect() protoreflect.Message + func (x *TopicUnsubscriptionRequestAck) Reset() + func (x *TopicUnsubscriptionRequestAck) String() string + type UnimplementedPushServiceServer struct + func (UnimplementedPushServiceServer) Channel(grpc.BidiStreamingServer[ChannelRequest, ChannelResponse]) error + func (UnimplementedPushServiceServer) GetClientActiveDevices(context.Context, *GetClientActiveDevicesRequest) (*GetClientActiveDevicesResponse, error) + func (UnimplementedPushServiceServer) SendEventToClientChannel(context.Context, *SendEventToClientChannelRequest) (*SendEventToClientChannelResponse, error) + func (UnimplementedPushServiceServer) SendEventToClientDeviceChannel(context.Context, *SendEventToClientDeviceChannelRequest) (*SendEventToClientDeviceChannelResponse, error) + func (UnimplementedPushServiceServer) SendEventToTopic(context.Context, *SendEventToTopicRequest) (*SendEventToTopicResponse, error) + func (UnimplementedPushServiceServer) SendEventToTopics(context.Context, *SendEventToTopicsRequest) (*SendEventToTopicsResponse, error) + type UnsafePushServiceServer interface
Go to main page