Documentation ¶
Index ¶
- Variables
- type Auth
- func (*Auth) Descriptor() ([]byte, []int)deprecated
- func (x *Auth) GetDevice() string
- func (x *Auth) GetId() string
- func (x *Auth) GetOffset() int64
- func (x *Auth) GetToken() string
- func (x *Auth) GetType() MsgType
- func (*Auth) ProtoMessage()
- func (x *Auth) ProtoReflect() protoreflect.Message
- func (x *Auth) Reset()
- func (x *Auth) String() string
- type ErrType
- type Header
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetAuthorization() []byte
- func (x *Message) GetCiphertext() []byte
- func (x *Message) GetCollapseKey() []byte
- func (x *Message) GetId() string
- func (x *Message) GetMessageType() []byte
- func (x *Message) GetNotificationPayload() []byte
- func (x *Message) GetOffset() int64
- func (x *Message) GetPriority() uint32
- func (x *Message) GetRecipient() string
- func (x *Message) GetSender() string
- func (x *Message) GetTimestamp() *timestamppb.Timestamp
- func (x *Message) GetType() MsgType
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type MsgType
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)deprecated
- func (x *Notification) GetError() string
- func (x *Notification) GetErrtype() ErrType
- func (x *Notification) GetId() string
- func (x *Notification) GetType() MsgType
- func (*Notification) ProtoMessage()
- func (x *Notification) ProtoReflect() protoreflect.Message
- func (x *Notification) Reset()
- func (x *Notification) String() string
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetId() string
- func (x *Status) GetLastSeen() *timestamppb.Timestamp
- func (x *Status) GetOnline() bool
- func (x *Status) GetRecipient() string
- func (x *Status) GetType() MsgType
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type Watch
- func (*Watch) Descriptor() ([]byte, []int)deprecated
- func (x *Watch) GetId() string
- func (x *Watch) GetRecipient() string
- func (x *Watch) GetType() MsgType
- func (x *Watch) GetWatch() bool
- func (*Watch) ProtoMessage()
- func (x *Watch) ProtoReflect() protoreflect.Message
- func (x *Watch) Reset()
- func (x *Watch) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrType_name = map[int32]string{ 0: "ErrConnection", 1: "ErrBadRequest", 2: "ErrInternal", 3: "ErrMessage", 4: "ErrAuth", 5: "ErrACL", } ErrType_value = map[string]int32{ "ErrConnection": 0, "ErrBadRequest": 1, "ErrInternal": 2, "ErrMessage": 3, "ErrAuth": 4, "ErrACL": 5, } )
Enum value maps for ErrType.
View Source
var ( MsgType_name = map[int32]string{ 0: "MSG", 1: "ACK", 2: "ERR", 3: "AUTH", 5: "WTC", 6: "STS", } MsgType_value = map[string]int32{ "MSG": 0, "ACK": 1, "ERR": 2, "AUTH": 3, "WTC": 5, "STS": 6, } )
Enum value maps for MsgType.
View Source
var File_auth_proto protoreflect.FileDescriptor
View Source
var File_errtype_proto protoreflect.FileDescriptor
View Source
var File_header_proto protoreflect.FileDescriptor
View Source
var File_message_proto protoreflect.FileDescriptor
View Source
var File_msgtype_proto protoreflect.FileDescriptor
View Source
var File_notification_proto protoreflect.FileDescriptor
View Source
var File_status_proto protoreflect.FileDescriptor
View Source
var File_watch_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Auth ¶
type Auth struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=msgproto.MsgType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"` Device string `protobuf:"bytes,4,opt,name=device,proto3" json:"device,omitempty"` Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*Auth) Descriptor
deprecated
func (*Auth) ProtoMessage ¶
func (*Auth) ProtoMessage()
func (*Auth) ProtoReflect ¶
func (x *Auth) ProtoReflect() protoreflect.Message
type ErrType ¶
type ErrType int32
func (ErrType) Descriptor ¶
func (ErrType) Descriptor() protoreflect.EnumDescriptor
func (ErrType) EnumDescriptor
deprecated
func (ErrType) Number ¶
func (x ErrType) Number() protoreflect.EnumNumber
func (ErrType) Type ¶
func (ErrType) Type() protoreflect.EnumType
type Header ¶
type Header struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=msgproto.MsgType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*Header) Descriptor
deprecated
func (*Header) ProtoMessage ¶
func (*Header) ProtoMessage()
func (*Header) ProtoReflect ¶
func (x *Header) ProtoReflect() protoreflect.Message
type Message ¶
type Message struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=msgproto.MsgType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Sender string `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"` Recipient string `protobuf:"bytes,4,opt,name=recipient,proto3" json:"recipient,omitempty"` Ciphertext []byte `protobuf:"bytes,5,opt,name=ciphertext,proto3" json:"ciphertext,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Offset int64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"` Priority uint32 `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"` MessageType []byte `protobuf:"bytes,9,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` CollapseKey []byte `protobuf:"bytes,10,opt,name=collapse_key,json=collapseKey,proto3" json:"collapse_key,omitempty"` NotificationPayload []byte `protobuf:"bytes,11,opt,name=notification_payload,json=notificationPayload,proto3" json:"notification_payload,omitempty"` Authorization []byte `protobuf:"bytes,12,opt,name=authorization,proto3" json:"authorization,omitempty"` // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetAuthorization ¶
func (*Message) GetCiphertext ¶
func (*Message) GetCollapseKey ¶
func (*Message) GetMessageType ¶
func (*Message) GetNotificationPayload ¶
func (*Message) GetPriority ¶
func (*Message) GetRecipient ¶
func (*Message) GetTimestamp ¶
func (x *Message) GetTimestamp() *timestamppb.Timestamp
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type MsgType ¶
type MsgType int32
func (MsgType) Descriptor ¶
func (MsgType) Descriptor() protoreflect.EnumDescriptor
func (MsgType) EnumDescriptor
deprecated
func (MsgType) Number ¶
func (x MsgType) Number() protoreflect.EnumNumber
func (MsgType) Type ¶
func (MsgType) Type() protoreflect.EnumType
type Notification ¶
type Notification struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=msgproto.MsgType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Errtype ErrType `protobuf:"varint,4,opt,name=errtype,proto3,enum=msgproto.ErrType" json:"errtype,omitempty"` // contains filtered or unexported fields }
func (*Notification) Descriptor
deprecated
func (*Notification) Descriptor() ([]byte, []int)
Deprecated: Use Notification.ProtoReflect.Descriptor instead.
func (*Notification) GetError ¶
func (x *Notification) GetError() string
func (*Notification) GetErrtype ¶
func (x *Notification) GetErrtype() ErrType
func (*Notification) GetId ¶
func (x *Notification) GetId() string
func (*Notification) GetType ¶
func (x *Notification) GetType() MsgType
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) ProtoReflect ¶
func (x *Notification) ProtoReflect() protoreflect.Message
func (*Notification) Reset ¶
func (x *Notification) Reset()
func (*Notification) String ¶
func (x *Notification) String() string
type Status ¶
type Status struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=msgproto.MsgType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Recipient string `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"` Online bool `protobuf:"varint,4,opt,name=online,proto3" json:"online,omitempty"` LastSeen *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"` // contains filtered or unexported fields }
func (*Status) Descriptor
deprecated
func (*Status) GetLastSeen ¶
func (x *Status) GetLastSeen() *timestamppb.Timestamp
func (*Status) GetRecipient ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type Watch ¶
type Watch struct { Type MsgType `protobuf:"varint,1,opt,name=type,proto3,enum=msgproto.MsgType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Recipient string `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"` Watch bool `protobuf:"varint,4,opt,name=watch,proto3" json:"watch,omitempty"` // contains filtered or unexported fields }
func (*Watch) Descriptor
deprecated
func (*Watch) GetRecipient ¶
func (*Watch) ProtoMessage ¶
func (*Watch) ProtoMessage()
func (*Watch) ProtoReflect ¶
func (x *Watch) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.