v1_pushv1

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PushService_Channel_FullMethodName                        = "/push.v1.PushService/Channel"
	PushService_SendEventToClientChannel_FullMethodName       = "/push.v1.PushService/SendEventToClientChannel"
	PushService_SendEventToClientDeviceChannel_FullMethodName = "/push.v1.PushService/SendEventToClientDeviceChannel"
	PushService_SendEventToTopic_FullMethodName               = "/push.v1.PushService/SendEventToTopic"
	PushService_SendEventToTopics_FullMethodName              = "/push.v1.PushService/SendEventToTopics"
	PushService_GetClientActiveDevices_FullMethodName         = "/push.v1.PushService/GetClientActiveDevices"
)

Variables

View Source 
var (
	Event_Type_name = map[int32]string{
		0: "TYPE_JSON_UNSPECIFIED",
		1: "TYPE_PROTO",
	}
	Event_Type_value = map[string]int32{
		"TYPE_JSON_UNSPECIFIED": 0,
		"TYPE_PROTO":            1,
	}
)

Enum value maps for Event_Type.

View Source 
var File_push_v1_api_proto protoreflect.FileDescriptor
View Source 
var PushService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "push.v1.PushService",
	HandlerType: (*PushServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendEventToClientChannel",
			Handler:    _PushService_SendEventToClientChannel_Handler,
		},
		{
			MethodName: "SendEventToClientDeviceChannel",
			Handler:    _PushService_SendEventToClientDeviceChannel_Handler,
		},
		{
			MethodName: "SendEventToTopic",
			Handler:    _PushService_SendEventToTopic_Handler,
		},
		{
			MethodName: "SendEventToTopics",
			Handler:    _PushService_SendEventToTopics_Handler,
		},
		{
			MethodName: "GetClientActiveDevices",
			Handler:    _PushService_GetClientActiveDevices_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Channel",
			Handler:       _PushService_Channel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "push/v1/api.proto",
}

PushService_ServiceDesc is the grpc.ServiceDesc for PushService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPushServiceServer 

func RegisterPushServiceServer(s grpc.ServiceRegistrar, srv PushServiceServer)

Types

type ChannelEvent 

type ChannelEvent struct {

	// unique event id
	UniqueId string `protobuf:"bytes,1,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	// Topic of the event
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// event sent and received
	Event *Event `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

ChannelEvent is the main payload

func (*ChannelEvent) Descriptor deprecated 

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

Deprecated: Use ChannelEvent.ProtoReflect.Descriptor instead.

func (*ChannelEvent) GetEvent 

func (x *ChannelEvent) GetEvent() *Event

func (*ChannelEvent) GetTopic 

func (x *ChannelEvent) GetTopic() string

func (*ChannelEvent) GetUniqueId 

func (x *ChannelEvent) GetUniqueId() string

func (*ChannelEvent) ProtoMessage 

func (*ChannelEvent) ProtoMessage()

func (*ChannelEvent) ProtoReflect 

func (x *ChannelEvent) ProtoReflect() protoreflect.Message

func (*ChannelEvent) Reset 

func (x *ChannelEvent) Reset()

func (*ChannelEvent) String 

func (x *ChannelEvent) String() string

type ChannelEventAck 

type ChannelEventAck struct {

	// unique event id
	UniqueId string `protobuf:"bytes,1,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

ChannelEventAck is the ack of a ChannelEvent

func (*ChannelEventAck) Descriptor deprecated 

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

Deprecated: Use ChannelEventAck.ProtoReflect.Descriptor instead.

func (*ChannelEventAck) GetStatus 

func (x *ChannelEventAck) GetStatus() *ResponseStatus

func (*ChannelEventAck) GetUniqueId 

func (x *ChannelEventAck) GetUniqueId() string

func (*ChannelEventAck) ProtoMessage 

func (*ChannelEventAck) ProtoMessage()

func (*ChannelEventAck) ProtoReflect 

func (x *ChannelEventAck) ProtoReflect() protoreflect.Message

func (*ChannelEventAck) Reset 

func (x *ChannelEventAck) Reset()

func (*ChannelEventAck) String 

func (x *ChannelEventAck) String() string

type ChannelRequest 

type ChannelRequest struct {

	// Types that are assignable to Request:
	//
	//	*ChannelRequest_ChannelEvent
	//	*ChannelRequest_ChannelEventAck
	//	*ChannelRequest_TopicSubscriptionRequest
	//	*ChannelRequest_TopicUnsubscriptionRequest
	Request isChannelRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

ChannelRequest is the channel request holder

func (*ChannelRequest) Descriptor deprecated 

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

Deprecated: Use ChannelRequest.ProtoReflect.Descriptor instead.

func (*ChannelRequest) GetChannelEvent 

func (x *ChannelRequest) GetChannelEvent() *ChannelEvent

func (*ChannelRequest) GetChannelEventAck 

func (x *ChannelRequest) GetChannelEventAck() *ChannelEventAck

func (*ChannelRequest) GetRequest 

func (m *ChannelRequest) GetRequest() isChannelRequest_Request

func (*ChannelRequest) GetTopicSubscriptionRequest 

func (x *ChannelRequest) GetTopicSubscriptionRequest() *TopicSubscriptionRequest

func (*ChannelRequest) GetTopicUnsubscriptionRequest 

func (x *ChannelRequest) GetTopicUnsubscriptionRequest() *TopicUnsubscriptionRequest

func (*ChannelRequest) ProtoMessage 

func (*ChannelRequest) ProtoMessage()

func (*ChannelRequest) ProtoReflect 

func (x *ChannelRequest) ProtoReflect() protoreflect.Message

func (*ChannelRequest) Reset 

func (x *ChannelRequest) Reset()

func (*ChannelRequest) String 

func (x *ChannelRequest) String() string

type ChannelRequest_ChannelEvent 

type ChannelRequest_ChannelEvent struct {
	// channel_event carries main payload
	ChannelEvent *ChannelEvent `protobuf:"bytes,1,opt,name=channel_event,json=channelEvent,proto3,oneof"`
}

type ChannelRequest_ChannelEventAck 

type ChannelRequest_ChannelEventAck struct {
	// channel_event_ack is ack of channel_event
	ChannelEventAck *ChannelEventAck `protobuf:"bytes,2,opt,name=channel_event_ack,json=channelEventAck,proto3,oneof"`
}

type ChannelRequest_TopicSubscriptionRequest 

type ChannelRequest_TopicSubscriptionRequest struct {
	// topic_subscription_request to subscribe to a topic
	TopicSubscriptionRequest *TopicSubscriptionRequest `protobuf:"bytes,3,opt,name=topic_subscription_request,json=topicSubscriptionRequest,proto3,oneof"`
}

type ChannelRequest_TopicUnsubscriptionRequest 

type ChannelRequest_TopicUnsubscriptionRequest struct {
	// topic_unsubscription_request to unsubscribe to a topic
	TopicUnsubscriptionRequest *TopicUnsubscriptionRequest `protobuf:"bytes,4,opt,name=topic_unsubscription_request,json=topicUnsubscriptionRequest,proto3,oneof"`
}

type ChannelResponse 

type ChannelResponse struct {

	// Types that are assignable to Response:
	//
	//	*ChannelResponse_ConnectAck
	//	*ChannelResponse_ChannelEvent
	//	*ChannelResponse_ChannelEventAck
	//	*ChannelResponse_TopicSubscriptionRequestAck
	//	*ChannelResponse_TopicUnsubscriptionRequestAck
	Response isChannelResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

ChannelResponse is the channel response holder

func (*ChannelResponse) Descriptor deprecated 

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

Deprecated: Use ChannelResponse.ProtoReflect.Descriptor instead.

func (*ChannelResponse) GetChannelEvent 

func (x *ChannelResponse) GetChannelEvent() *ChannelEvent

func (*ChannelResponse) GetChannelEventAck 

func (x *ChannelResponse) GetChannelEventAck() *ChannelEventAck

func (*ChannelResponse) GetConnectAck 

func (x *ChannelResponse) GetConnectAck() *ConnectAck

func (*ChannelResponse) GetResponse 

func (m *ChannelResponse) GetResponse() isChannelResponse_Response

func (*ChannelResponse) GetTopicSubscriptionRequestAck 

func (x *ChannelResponse) GetTopicSubscriptionRequestAck() *TopicSubscriptionRequestAck

func (*ChannelResponse) GetTopicUnsubscriptionRequestAck 

func (x *ChannelResponse) GetTopicUnsubscriptionRequestAck() *TopicUnsubscriptionRequestAck

func (*ChannelResponse) ProtoMessage 

func (*ChannelResponse) ProtoMessage()

func (*ChannelResponse) ProtoReflect 

func (x *ChannelResponse) ProtoReflect() protoreflect.Message

func (*ChannelResponse) Reset 

func (x *ChannelResponse) Reset()

func (*ChannelResponse) String 

func (x *ChannelResponse) String() string

type ChannelResponse_ChannelEvent 

type ChannelResponse_ChannelEvent struct {
	// channel_event carries main payload
	ChannelEvent *ChannelEvent `protobuf:"bytes,2,opt,name=channel_event,json=channelEvent,proto3,oneof"`
}

type ChannelResponse_ChannelEventAck 

type ChannelResponse_ChannelEventAck struct {
	// channel_event_ack is ack of channel_event
	ChannelEventAck *ChannelEventAck `protobuf:"bytes,3,opt,name=channel_event_ack,json=channelEventAck,proto3,oneof"`
}

type ChannelResponse_ConnectAck 

type ChannelResponse_ConnectAck struct {
	// connect_ack is the ack for channel connect request
	ConnectAck *ConnectAck `protobuf:"bytes,1,opt,name=connect_ack,json=connectAck,proto3,oneof"`
}

type ChannelResponse_TopicSubscriptionRequestAck 

type ChannelResponse_TopicSubscriptionRequestAck struct {
	// topic_subscription_request_ack is ack of topic_subscription_request
	TopicSubscriptionRequestAck *TopicSubscriptionRequestAck `protobuf:"bytes,4,opt,name=topic_subscription_request_ack,json=topicSubscriptionRequestAck,proto3,oneof"`
}

type ChannelResponse_TopicUnsubscriptionRequestAck 

type ChannelResponse_TopicUnsubscriptionRequestAck struct {
	// topic_unsubscription_request_ack is ack of topic_unsubscription_request
	TopicUnsubscriptionRequestAck *TopicUnsubscriptionRequestAck `protobuf:"bytes,5,opt,name=topic_unsubscription_request_ack,json=topicUnsubscriptionRequestAck,proto3,oneof"`
}

type ConnectAck 

type ConnectAck struct {

	// Represents a generic Response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

ConnectResponse is the response client gets on connecting to channel

func (*ConnectAck) Descriptor deprecated 

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

Deprecated: Use ConnectAck.ProtoReflect.Descriptor instead.

func (*ConnectAck) GetStatus 

func (x *ConnectAck) GetStatus() *ResponseStatus

func (*ConnectAck) ProtoMessage 

func (*ConnectAck) ProtoMessage()

func (*ConnectAck) ProtoReflect 

func (x *ConnectAck) ProtoReflect() protoreflect.Message

func (*ConnectAck) Reset 

func (x *ConnectAck) Reset()

func (*ConnectAck) String 

func (x *ConnectAck) String() string

type Device 

type Device struct {

	// unique device id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// logged in time
	LoggedInAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=logged_in_at,json=loggedInAt,proto3" json:"logged_in_at,omitempty"`
	// device attributes
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Device holds details of a device

func (*Device) Descriptor deprecated 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetAttributes 

func (x *Device) GetAttributes() map[string]string

func (*Device) GetId 

func (x *Device) GetId() string

func (*Device) GetLoggedInAt 

func (x *Device) GetLoggedInAt() *timestamppb.Timestamp

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

func (x *Device) ProtoReflect() protoreflect.Message

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type Event 

type Event struct {

	// name of the event
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// format_type is type of event format
	FormatType Event_Type `protobuf:"varint,2,opt,name=format_type,json=formatType,proto3,enum=push.v1.Event_Type" json:"format_type,omitempty"`
	// data which the event carries
	Data *anypb.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Event holds the event structure

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData 

func (x *Event) GetData() *anypb.Any

func (*Event) GetFormatType 

func (x *Event) GetFormatType() Event_Type

func (*Event) GetName 

func (x *Event) GetName() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_Type 

type Event_Type int32

Types of event formats like JSON 

const (
	// default type is JSON
	Event_TYPE_JSON_UNSPECIFIED Event_Type = 0
	// proto type
	Event_TYPE_PROTO Event_Type = 1
)

func (Event_Type) Descriptor 

func (Event_Type) Descriptor() protoreflect.EnumDescriptor

func (Event_Type) Enum 

func (x Event_Type) Enum() *Event_Type

func (Event_Type) EnumDescriptor deprecated 

func (Event_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Event_Type.Descriptor instead.

func (Event_Type) Number 

func (x Event_Type) Number() protoreflect.EnumNumber

func (Event_Type) String 

func (x Event_Type) String() string

func (Event_Type) Type 

func (Event_Type) Type() protoreflect.EnumType

type GetClientActiveDevicesRequest 

type GetClientActiveDevicesRequest struct {

	// client_id for which devices to fetch devices
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

GetClientActiveDevicesRequest is the request to get active devices of a client

func (*GetClientActiveDevicesRequest) Descriptor deprecated 

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

Deprecated: Use GetClientActiveDevicesRequest.ProtoReflect.Descriptor instead.

func (*GetClientActiveDevicesRequest) GetClientId 

func (x *GetClientActiveDevicesRequest) GetClientId() string

func (*GetClientActiveDevicesRequest) ProtoMessage 

func (*GetClientActiveDevicesRequest) ProtoMessage()

func (*GetClientActiveDevicesRequest) ProtoReflect 

func (x *GetClientActiveDevicesRequest) ProtoReflect() protoreflect.Message

func (*GetClientActiveDevicesRequest) Reset 

func (x *GetClientActiveDevicesRequest) Reset()

func (*GetClientActiveDevicesRequest) String 

func (x *GetClientActiveDevicesRequest) String() string

type GetClientActiveDevicesResponse 

type GetClientActiveDevicesResponse struct {

	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// is_client_online is a boolean to indicate if the client is online
	IsClientOnline bool `protobuf:"varint,2,opt,name=is_client_online,json=isClientOnline,proto3" json:"is_client_online,omitempty"`
	// list of active devices of a client
	Devices []*Device `protobuf:"bytes,3,rep,name=devices,proto3" json:"devices,omitempty"`
	// contains filtered or unexported fields
}

GetClientActiveDevicesResponse is the response of GetClientActiveDevices API

func (*GetClientActiveDevicesResponse) Descriptor deprecated 

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

Deprecated: Use GetClientActiveDevicesResponse.ProtoReflect.Descriptor instead.

func (*GetClientActiveDevicesResponse) GetDevices 

func (x *GetClientActiveDevicesResponse) GetDevices() []*Device

func (*GetClientActiveDevicesResponse) GetIsClientOnline 

func (x *GetClientActiveDevicesResponse) GetIsClientOnline() bool

func (*GetClientActiveDevicesResponse) GetStatus 

func (x *GetClientActiveDevicesResponse) GetStatus() *ResponseStatus

func (*GetClientActiveDevicesResponse) ProtoMessage 

func (*GetClientActiveDevicesResponse) ProtoMessage()

func (*GetClientActiveDevicesResponse) ProtoReflect 

func (x *GetClientActiveDevicesResponse) ProtoReflect() protoreflect.Message

func (*GetClientActiveDevicesResponse) Reset 

func (x *GetClientActiveDevicesResponse) Reset()

func (*GetClientActiveDevicesResponse) String 

func (x *GetClientActiveDevicesResponse) String() string

type PushServiceClient 

type PushServiceClient interface {
	// Establish channel
	Channel(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ChannelRequest, ChannelResponse], error)
	// SendEventToClientChannel is called to send event to a client
	SendEventToClientChannel(ctx context.Context, in *SendEventToClientChannelRequest, opts ...grpc.CallOption) (*SendEventToClientChannelResponse, error)
	// SendEventToClientDeviceChannel is called to send event to a client device
	SendEventToClientDeviceChannel(ctx context.Context, in *SendEventToClientDeviceChannelRequest, opts ...grpc.CallOption) (*SendEventToClientDeviceChannelResponse, error)
	// SendEventToTopic is called to send event to a topic
	SendEventToTopic(ctx context.Context, in *SendEventToTopicRequest, opts ...grpc.CallOption) (*SendEventToTopicResponse, error)
	// SendEventToTopics is called to send event to multiple topics
	SendEventToTopics(ctx context.Context, in *SendEventToTopicsRequest, opts ...grpc.CallOption) (*SendEventToTopicsResponse, error)
	// GetClientActiveDevices is called to get active devices of a client
	GetClientActiveDevices(ctx context.Context, in *GetClientActiveDevicesRequest, opts ...grpc.CallOption) (*GetClientActiveDevicesResponse, error)
}

PushServiceClient is the client API for PushService 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.

PushService is used to push events to and from the client

func NewPushServiceClient 

func NewPushServiceClient(cc grpc.ClientConnInterface) PushServiceClient

type PushServiceServer 

type PushServiceServer interface {
	// Establish channel
	Channel(grpc.BidiStreamingServer[ChannelRequest, ChannelResponse]) error
	// SendEventToClientChannel is called to send event to a client
	SendEventToClientChannel(context.Context, *SendEventToClientChannelRequest) (*SendEventToClientChannelResponse, error)
	// SendEventToClientDeviceChannel is called to send event to a client device
	SendEventToClientDeviceChannel(context.Context, *SendEventToClientDeviceChannelRequest) (*SendEventToClientDeviceChannelResponse, error)
	// SendEventToTopic is called to send event to a topic
	SendEventToTopic(context.Context, *SendEventToTopicRequest) (*SendEventToTopicResponse, error)
	// SendEventToTopics is called to send event to multiple topics
	SendEventToTopics(context.Context, *SendEventToTopicsRequest) (*SendEventToTopicsResponse, error)
	// GetClientActiveDevices is called to get active devices of a client
	GetClientActiveDevices(context.Context, *GetClientActiveDevicesRequest) (*GetClientActiveDevicesResponse, error)
}

PushServiceServer is the server API for PushService service. All implementations should embed UnimplementedPushServiceServer for forward compatibility.

PushService is used to push events to and from the client

type PushService_ChannelClient 

type PushService_ChannelClient = grpc.BidiStreamingClient[ChannelRequest, ChannelResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type PushService_ChannelServer 

type PushService_ChannelServer = grpc.BidiStreamingServer[ChannelRequest, ChannelResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ResponseStatus 

type ResponseStatus struct {

	// Indicates whether the request was successful or not
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Indicates the error code associated with the request if it was unsuccessful
	ErrorCode string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// Includes additional meta information associated with the unsuccessful request
	Message map[string]string `` /* 155-byte string literal not displayed */
	// Indicates the standard grpc error code associated with the request if it was unsuccessful
	ErrorType string `protobuf:"bytes,4,opt,name=error_type,json=errorType,proto3" json:"error_type,omitempty"`
	// contains filtered or unexported fields
}

Represents a generic Response which indicates success/failure status of every request

func (*ResponseStatus) Descriptor deprecated 

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

Deprecated: Use ResponseStatus.ProtoReflect.Descriptor instead.

func (*ResponseStatus) GetErrorCode 

func (x *ResponseStatus) GetErrorCode() string

func (*ResponseStatus) GetErrorType 

func (x *ResponseStatus) GetErrorType() string

func (*ResponseStatus) GetMessage 

func (x *ResponseStatus) GetMessage() map[string]string

func (*ResponseStatus) GetSuccess 

func (x *ResponseStatus) GetSuccess() bool

func (*ResponseStatus) ProtoMessage 

func (*ResponseStatus) ProtoMessage()

func (*ResponseStatus) ProtoReflect 

func (x *ResponseStatus) ProtoReflect() protoreflect.Message

func (*ResponseStatus) Reset 

func (x *ResponseStatus) Reset()

func (*ResponseStatus) String 

func (x *ResponseStatus) String() string

type SendEventToClientChannelRequest 

type SendEventToClientChannelRequest struct {

	// client_id is client id to which the event is to be sent
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// event sent or received
	Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

SendEventToClientChannelRequest is the request to send event to a client

func (*SendEventToClientChannelRequest) Descriptor deprecated 

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

Deprecated: Use SendEventToClientChannelRequest.ProtoReflect.Descriptor instead.

func (*SendEventToClientChannelRequest) GetClientId 

func (x *SendEventToClientChannelRequest) GetClientId() string

func (*SendEventToClientChannelRequest) GetEvent 

func (x *SendEventToClientChannelRequest) GetEvent() *Event

func (*SendEventToClientChannelRequest) ProtoMessage 

func (*SendEventToClientChannelRequest) ProtoMessage()

func (*SendEventToClientChannelRequest) ProtoReflect 

func (x *SendEventToClientChannelRequest) ProtoReflect() protoreflect.Message

func (*SendEventToClientChannelRequest) Reset 

func (x *SendEventToClientChannelRequest) Reset()

func (*SendEventToClientChannelRequest) String 

func (x *SendEventToClientChannelRequest) String() string

type SendEventToClientChannelResponse 

type SendEventToClientChannelResponse struct {

	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SendEventToClientChannelResponse is the response of SendEventToClientChannel API

func (*SendEventToClientChannelResponse) Descriptor deprecated 

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

Deprecated: Use SendEventToClientChannelResponse.ProtoReflect.Descriptor instead.

func (*SendEventToClientChannelResponse) GetStatus 

func (x *SendEventToClientChannelResponse) GetStatus() *ResponseStatus

func (*SendEventToClientChannelResponse) ProtoMessage 

func (*SendEventToClientChannelResponse) ProtoMessage()

func (*SendEventToClientChannelResponse) ProtoReflect 

func (x *SendEventToClientChannelResponse) ProtoReflect() protoreflect.Message

func (*SendEventToClientChannelResponse) Reset 

func (x *SendEventToClientChannelResponse) Reset()

func (*SendEventToClientChannelResponse) String 

func (x *SendEventToClientChannelResponse) String() string

type SendEventToClientDeviceChannelRequest 

type SendEventToClientDeviceChannelRequest struct {

	// client_id is client id to which the event is to be sent
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// device_id is the device id to which the event is to be sent
	DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// event sent or received
	Event *Event `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

SendEventToClientDeviceChannelRequest is the request to send event to a client with a device

func (*SendEventToClientDeviceChannelRequest) Descriptor deprecated 

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

Deprecated: Use SendEventToClientDeviceChannelRequest.ProtoReflect.Descriptor instead.

func (*SendEventToClientDeviceChannelRequest) GetClientId 

func (x *SendEventToClientDeviceChannelRequest) GetClientId() string

func (*SendEventToClientDeviceChannelRequest) GetDeviceId 

func (x *SendEventToClientDeviceChannelRequest) GetDeviceId() string

func (*SendEventToClientDeviceChannelRequest) GetEvent 

func (x *SendEventToClientDeviceChannelRequest) GetEvent() *Event

func (*SendEventToClientDeviceChannelRequest) ProtoMessage 

func (*SendEventToClientDeviceChannelRequest) ProtoMessage()

func (*SendEventToClientDeviceChannelRequest) ProtoReflect 

func (x *SendEventToClientDeviceChannelRequest) ProtoReflect() protoreflect.Message

func (*SendEventToClientDeviceChannelRequest) Reset 

func (x *SendEventToClientDeviceChannelRequest) Reset()

func (*SendEventToClientDeviceChannelRequest) String 

func (x *SendEventToClientDeviceChannelRequest) String() string

type SendEventToClientDeviceChannelResponse 

type SendEventToClientDeviceChannelResponse struct {

	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SendEventToClientDeviceChannelResponse is the response of SendEventToClientDeviceChannel API

func (*SendEventToClientDeviceChannelResponse) Descriptor deprecated 

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

Deprecated: Use SendEventToClientDeviceChannelResponse.ProtoReflect.Descriptor instead.

func (*SendEventToClientDeviceChannelResponse) GetStatus 

func (x *SendEventToClientDeviceChannelResponse) GetStatus() *ResponseStatus

func (*SendEventToClientDeviceChannelResponse) ProtoMessage 

func (*SendEventToClientDeviceChannelResponse) ProtoMessage()

func (*SendEventToClientDeviceChannelResponse) ProtoReflect 

func (x *SendEventToClientDeviceChannelResponse) ProtoReflect() protoreflect.Message

func (*SendEventToClientDeviceChannelResponse) Reset 

func (x *SendEventToClientDeviceChannelResponse) Reset()

func (*SendEventToClientDeviceChannelResponse) String 

func (x *SendEventToClientDeviceChannelResponse) String() string

type SendEventToTopicRequest 

type SendEventToTopicRequest struct {

	// topic to which the event is to be sent
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// event sent or received
	Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

SendEventToTopicRequest is the request to send event to a topic

func (*SendEventToTopicRequest) Descriptor deprecated 

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

Deprecated: Use SendEventToTopicRequest.ProtoReflect.Descriptor instead.

func (*SendEventToTopicRequest) GetEvent 

func (x *SendEventToTopicRequest) GetEvent() *Event

func (*SendEventToTopicRequest) GetTopic 

func (x *SendEventToTopicRequest) GetTopic() string

func (*SendEventToTopicRequest) ProtoMessage 

func (*SendEventToTopicRequest) ProtoMessage()

func (*SendEventToTopicRequest) ProtoReflect 

func (x *SendEventToTopicRequest) ProtoReflect() protoreflect.Message

func (*SendEventToTopicRequest) Reset 

func (x *SendEventToTopicRequest) Reset()

func (*SendEventToTopicRequest) String 

func (x *SendEventToTopicRequest) String() string

type SendEventToTopicResponse 

type SendEventToTopicResponse struct {

	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SendEventToTopicResponse is the response of SendEventToTopic API

func (*SendEventToTopicResponse) Descriptor deprecated 

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

Deprecated: Use SendEventToTopicResponse.ProtoReflect.Descriptor instead.

func (*SendEventToTopicResponse) GetStatus 

func (x *SendEventToTopicResponse) GetStatus() *ResponseStatus

func (*SendEventToTopicResponse) ProtoMessage 

func (*SendEventToTopicResponse) ProtoMessage()

func (*SendEventToTopicResponse) ProtoReflect 

func (x *SendEventToTopicResponse) ProtoReflect() protoreflect.Message

func (*SendEventToTopicResponse) Reset 

func (x *SendEventToTopicResponse) Reset()

func (*SendEventToTopicResponse) String 

func (x *SendEventToTopicResponse) String() string

type SendEventToTopicsRequest 

type SendEventToTopicsRequest struct {

	// list of SendEventToTopicRequest
	Requests []*SendEventToTopicRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

SendEventToTopicsRequest is the request to send event to multiple topics

func (*SendEventToTopicsRequest) Descriptor deprecated 

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

Deprecated: Use SendEventToTopicsRequest.ProtoReflect.Descriptor instead.

func (*SendEventToTopicsRequest) GetRequests 

func (x *SendEventToTopicsRequest) GetRequests() []*SendEventToTopicRequest

func (*SendEventToTopicsRequest) ProtoMessage 

func (*SendEventToTopicsRequest) ProtoMessage()

func (*SendEventToTopicsRequest) ProtoReflect 

func (x *SendEventToTopicsRequest) ProtoReflect() protoreflect.Message

func (*SendEventToTopicsRequest) Reset 

func (x *SendEventToTopicsRequest) Reset()

func (*SendEventToTopicsRequest) String 

func (x *SendEventToTopicsRequest) String() string

type SendEventToTopicsResponse 

type SendEventToTopicsResponse struct {

	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SendEventToTopicsResponse is the response of SendEventToTopics API

func (*SendEventToTopicsResponse) Descriptor deprecated 

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

Deprecated: Use SendEventToTopicsResponse.ProtoReflect.Descriptor instead.

func (*SendEventToTopicsResponse) GetStatus 

func (x *SendEventToTopicsResponse) GetStatus() *ResponseStatus

func (*SendEventToTopicsResponse) ProtoMessage 

func (*SendEventToTopicsResponse) ProtoMessage()

func (*SendEventToTopicsResponse) ProtoReflect 

func (x *SendEventToTopicsResponse) ProtoReflect() protoreflect.Message

func (*SendEventToTopicsResponse) Reset 

func (x *SendEventToTopicsResponse) Reset()

func (*SendEventToTopicsResponse) String 

func (x *SendEventToTopicsResponse) String() string

type TopicSubscriptionRequest 

type TopicSubscriptionRequest struct {

	// topic to subscribe
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

TopicSubscriptionRequest

func (*TopicSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use TopicSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*TopicSubscriptionRequest) GetTopic 

func (x *TopicSubscriptionRequest) GetTopic() string

func (*TopicSubscriptionRequest) ProtoMessage 

func (*TopicSubscriptionRequest) ProtoMessage()

func (*TopicSubscriptionRequest) ProtoReflect 

func (x *TopicSubscriptionRequest) ProtoReflect() protoreflect.Message

func (*TopicSubscriptionRequest) Reset 

func (x *TopicSubscriptionRequest) Reset()

func (*TopicSubscriptionRequest) String 

func (x *TopicSubscriptionRequest) String() string

type TopicSubscriptionRequestAck 

type TopicSubscriptionRequestAck struct {

	// topic
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

TopicSubscriptionRequest

func (*TopicSubscriptionRequestAck) Descriptor deprecated 

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

Deprecated: Use TopicSubscriptionRequestAck.ProtoReflect.Descriptor instead.

func (*TopicSubscriptionRequestAck) GetStatus 

func (x *TopicSubscriptionRequestAck) GetStatus() *ResponseStatus

func (*TopicSubscriptionRequestAck) GetTopic 

func (x *TopicSubscriptionRequestAck) GetTopic() string

func (*TopicSubscriptionRequestAck) ProtoMessage 

func (*TopicSubscriptionRequestAck) ProtoMessage()

func (*TopicSubscriptionRequestAck) ProtoReflect 

func (x *TopicSubscriptionRequestAck) ProtoReflect() protoreflect.Message

func (*TopicSubscriptionRequestAck) Reset 

func (x *TopicSubscriptionRequestAck) Reset()

func (*TopicSubscriptionRequestAck) String 

func (x *TopicSubscriptionRequestAck) String() string

type TopicUnsubscriptionRequest 

type TopicUnsubscriptionRequest struct {

	// topic to unsubscribe
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

TopicUnsubscriptionRequest

func (*TopicUnsubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use TopicUnsubscriptionRequest.ProtoReflect.Descriptor instead.

func (*TopicUnsubscriptionRequest) GetTopic 

func (x *TopicUnsubscriptionRequest) GetTopic() string

func (*TopicUnsubscriptionRequest) ProtoMessage 

func (*TopicUnsubscriptionRequest) ProtoMessage()

func (*TopicUnsubscriptionRequest) ProtoReflect 

func (x *TopicUnsubscriptionRequest) ProtoReflect() protoreflect.Message

func (*TopicUnsubscriptionRequest) Reset 

func (x *TopicUnsubscriptionRequest) Reset()

func (*TopicUnsubscriptionRequest) String 

func (x *TopicUnsubscriptionRequest) String() string

type TopicUnsubscriptionRequestAck 

type TopicUnsubscriptionRequestAck struct {

	// topic
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// generic response which indicates success/failure status of every request
	Status *ResponseStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

TopicUnsubscriptionRequestAck

func (*TopicUnsubscriptionRequestAck) Descriptor deprecated 

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

Deprecated: Use TopicUnsubscriptionRequestAck.ProtoReflect.Descriptor instead.

func (*TopicUnsubscriptionRequestAck) GetStatus 

func (x *TopicUnsubscriptionRequestAck) GetStatus() *ResponseStatus

func (*TopicUnsubscriptionRequestAck) GetTopic 

func (x *TopicUnsubscriptionRequestAck) GetTopic() string

func (*TopicUnsubscriptionRequestAck) ProtoMessage 

func (*TopicUnsubscriptionRequestAck) ProtoMessage()

func (*TopicUnsubscriptionRequestAck) ProtoReflect 

func (x *TopicUnsubscriptionRequestAck) ProtoReflect() protoreflect.Message

func (*TopicUnsubscriptionRequestAck) Reset 

func (x *TopicUnsubscriptionRequestAck) Reset()

func (*TopicUnsubscriptionRequestAck) String 

func (x *TopicUnsubscriptionRequestAck) String() string

type UnimplementedPushServiceServer 

type UnimplementedPushServiceServer struct{}

UnimplementedPushServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedPushServiceServer) Channel 

func (UnimplementedPushServiceServer) Channel(grpc.BidiStreamingServer[ChannelRequest, ChannelResponse]) error

func (UnimplementedPushServiceServer) GetClientActiveDevices 

func (UnimplementedPushServiceServer) GetClientActiveDevices(context.Context, *GetClientActiveDevicesRequest) (*GetClientActiveDevicesResponse, error)

func (UnimplementedPushServiceServer) SendEventToClientChannel 

func (UnimplementedPushServiceServer) SendEventToClientChannel(context.Context, *SendEventToClientChannelRequest) (*SendEventToClientChannelResponse, error)

func (UnimplementedPushServiceServer) SendEventToClientDeviceChannel 

func (UnimplementedPushServiceServer) SendEventToClientDeviceChannel(context.Context, *SendEventToClientDeviceChannelRequest) (*SendEventToClientDeviceChannelResponse, error)

func (UnimplementedPushServiceServer) SendEventToTopic 

func (UnimplementedPushServiceServer) SendEventToTopic(context.Context, *SendEventToTopicRequest) (*SendEventToTopicResponse, error)

func (UnimplementedPushServiceServer) SendEventToTopics 

func (UnimplementedPushServiceServer) SendEventToTopics(context.Context, *SendEventToTopicsRequest) (*SendEventToTopicsResponse, error)

type UnsafePushServiceServer 

type UnsafePushServiceServer interface {
	// contains filtered or unexported methods
}

UnsafePushServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PushServiceServer will result in compilation errors.

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.