go_fcm_receiver

package module

Go to main page

Versions in this module

v1

v1.0.8

Jul 1, 2023

v1.0.7

Jul 1, 2023

Changes in this version

+ const DefaultFcmMessageTtl

v1.0.6

Aug 23, 2022

v1.0.5

Aug 19, 2022

v1.0.4

Aug 2, 2022

Changes in this version

type FCMClient

+ func (f *FCMClient) Close()

v1.0.3

Jul 29, 2022

v1.0.2

Jul 2, 2022

Changes in this version

type FCMClient

+ func (f *FCMClient) RemovePersistentId(id string)

v1.0.1

Jun 26, 2022

v1.0.0

Jun 25, 2022

Changes in this version

+ const AppIdBase

+ const CheckInUrl

+ const Default_AndroidCheckinProto_Type

+ const FcmEndpointUrl

+ const FcmSocketAddress

+ const FcmSubscribeUrl

+ const KBatchPresenceStanzaTag

+ const KBindAccountRequestTag

+ const KBindAccountResponseTag

+ const KCloseTag

+ const KDataMessageStanzaTag

+ const KHeartbeatAckTag

+ const KHeartbeatPingTag

+ const KHttpRequestTag

+ const KHttpResponseTag

+ const KIqStanzaTag

+ const KLoginRequestTag

+ const KLoginResponseTag

+ const KMCSVersion

+ const KMessageStanzaTag

+ const KNumProtoTypes

+ const KPresenceStanzaTag

+ const KSizePacketLenMax

+ const KSizePacketLenMin

+ const KStreamErrorStanzaTag

+ const KTagPacketLen

+ const KTalkMetadataTag

+ const KVersionPacketLen

+ const MCS_PROTO_BYTES

+ const MCS_SIZE

+ const MCS_TAG_AND_SIZE

+ const MCS_VERSION_TAG_AND_SIZE

+ const RegisterUrl

+ var ChromeBuildProto_Channel_name = map[int32]string

+ var ChromeBuildProto_Channel_value = map[string]int32

+ var ChromeBuildProto_Platform_name = map[int32]string

+ var ChromeBuildProto_Platform_value = map[string]int32

+ var ClientEvent_Type_name = map[int32]string

+ var ClientEvent_Type_value = map[string]int32

+ var DeviceType_name = map[int32]string

+ var DeviceType_value = map[string]int32

+ var FcmServerKey = []byte

+ var File_proto_android_checkin_proto protoreflect.FileDescriptor

+ var File_proto_checkin_proto protoreflect.FileDescriptor

+ var File_proto_mcs_proto protoreflect.FileDescriptor

+ var IqStanza_IqType_name = map[int32]string

+ var IqStanza_IqType_value = map[string]int32

+ var LoginRequest_AuthService_name = map[int32]string

+ var LoginRequest_AuthService_value = map[string]int32

+ func CreateAuthSecret() ([]byte, error)

+ func CreateKeys() (*ecdsa.PrivateKey, *ecdsa.PublicKey, []byte, error)

+ func CreateLoginRequestRaw(androidId *uint64, securityToken *uint64, persistentIds []string) ([]byte, error)

+ func CreatePrivateKeyP256() (*ecdsa.PrivateKey, error)

+ func DecodePrivateKey(key []byte) (*ecdsa.PrivateKey, error)

+ func DecryptMessage(cryptoKey []byte, encryption []byte, rawData []byte, authSecret []byte, ...) ([]byte, error)

+ func EncodePrivateKey(key *ecdsa.PrivateKey) ([]byte, error)

+ func PubBytes(pub *ecdsa.PublicKey) []byte

+ func ReadInt32(buf []byte) (int, int, error)

+ func ReadUint32(buf []byte) (int, int, error)

+ func StringsSliceContains(s []string, e string) bool

+ type AndroidCheckinProto struct

+ CellOperator *string

+ ChromeBuild *ChromeBuildProto

+ LastCheckinMsec *int64

+ Roaming *string

+ SimOperator *string

+ Type *DeviceType

+ UserNumber *int32

+ func (*AndroidCheckinProto) Descriptor() ([]byte, []int)

+ func (*AndroidCheckinProto) ProtoMessage()

+ func (x *AndroidCheckinProto) GetCellOperator() string

+ func (x *AndroidCheckinProto) GetChromeBuild() *ChromeBuildProto

+ func (x *AndroidCheckinProto) GetLastCheckinMsec() int64

+ func (x *AndroidCheckinProto) GetRoaming() string

+ func (x *AndroidCheckinProto) GetSimOperator() string

+ func (x *AndroidCheckinProto) GetType() DeviceType

+ func (x *AndroidCheckinProto) GetUserNumber() int32

+ func (x *AndroidCheckinProto) ProtoReflect() protoreflect.Message

+ func (x *AndroidCheckinProto) Reset()

+ func (x *AndroidCheckinProto) String() string

+ type AndroidCheckinRequest struct

+ AccountCookie []string

+ Checkin *AndroidCheckinProto

+ DesiredBuild *string

+ Digest *string

+ Esn *string

+ Fragment *int32

+ Id *int64

+ Imei *string

+ Locale *string

+ LoggingId *int64

+ MacAddr []string

+ MacAddrType []string

+ MarketCheckin *string

+ Meid *string

+ OtaCert []string

+ SecurityToken *uint64

+ SerialNumber *string

+ TimeZone *string

+ UserName *string

+ UserSerialNumber *int32

+ Version *int32

+ func CreateCheckInRequest(androidId *int64, securityToken *uint64) *AndroidCheckinRequest

+ func (*AndroidCheckinRequest) Descriptor() ([]byte, []int)

+ func (*AndroidCheckinRequest) ProtoMessage()

+ func (x *AndroidCheckinRequest) GetAccountCookie() []string

+ func (x *AndroidCheckinRequest) GetCheckin() *AndroidCheckinProto

+ func (x *AndroidCheckinRequest) GetDesiredBuild() string

+ func (x *AndroidCheckinRequest) GetDigest() string

+ func (x *AndroidCheckinRequest) GetEsn() string

+ func (x *AndroidCheckinRequest) GetFragment() int32

+ func (x *AndroidCheckinRequest) GetId() int64

+ func (x *AndroidCheckinRequest) GetImei() string

+ func (x *AndroidCheckinRequest) GetLocale() string

+ func (x *AndroidCheckinRequest) GetLoggingId() int64

+ func (x *AndroidCheckinRequest) GetMacAddr() []string

+ func (x *AndroidCheckinRequest) GetMacAddrType() []string

+ func (x *AndroidCheckinRequest) GetMarketCheckin() string

+ func (x *AndroidCheckinRequest) GetMeid() string

+ func (x *AndroidCheckinRequest) GetOtaCert() []string

+ func (x *AndroidCheckinRequest) GetSecurityToken() uint64

+ func (x *AndroidCheckinRequest) GetSerialNumber() string

+ func (x *AndroidCheckinRequest) GetTimeZone() string

+ func (x *AndroidCheckinRequest) GetUserName() string

+ func (x *AndroidCheckinRequest) GetUserSerialNumber() int32

+ func (x *AndroidCheckinRequest) GetVersion() int32

+ func (x *AndroidCheckinRequest) ProtoReflect() protoreflect.Message

+ func (x *AndroidCheckinRequest) Reset()

+ func (x *AndroidCheckinRequest) String() string

+ type AndroidCheckinResponse struct

+ AndroidId *uint64

+ DeleteSetting []string

+ Digest *string

+ MarketOk *bool

+ SecurityToken *uint64

+ Setting []*GservicesSetting

+ SettingsDiff *bool

+ StatsOk *bool

+ TimeMsec *int64

+ VersionInfo *string

+ func (*AndroidCheckinResponse) Descriptor() ([]byte, []int)

+ func (*AndroidCheckinResponse) ProtoMessage()

+ func (x *AndroidCheckinResponse) GetAndroidId() uint64

+ func (x *AndroidCheckinResponse) GetDeleteSetting() []string

+ func (x *AndroidCheckinResponse) GetDigest() string

+ func (x *AndroidCheckinResponse) GetMarketOk() bool

+ func (x *AndroidCheckinResponse) GetSecurityToken() uint64

+ func (x *AndroidCheckinResponse) GetSetting() []*GservicesSetting

+ func (x *AndroidCheckinResponse) GetSettingsDiff() bool

+ func (x *AndroidCheckinResponse) GetStatsOk() bool

+ func (x *AndroidCheckinResponse) GetTimeMsec() int64

+ func (x *AndroidCheckinResponse) GetVersionInfo() string

+ func (x *AndroidCheckinResponse) ProtoReflect() protoreflect.Message

+ func (x *AndroidCheckinResponse) Reset()

+ func (x *AndroidCheckinResponse) String() string

+ type AppData struct

+ Key *string

+ Value *string

+ func (*AppData) Descriptor() ([]byte, []int)

+ func (*AppData) ProtoMessage()

+ func (x *AppData) GetKey() string

+ func (x *AppData) GetValue() string

+ func (x *AppData) ProtoReflect() protoreflect.Message

+ func (x *AppData) Reset()

+ func (x *AppData) String() string

+ type ChromeBuildProto struct

+ Channel *ChromeBuildProto_Channel

+ ChromeVersion *string

+ Platform *ChromeBuildProto_Platform

+ func (*ChromeBuildProto) Descriptor() ([]byte, []int)

+ func (*ChromeBuildProto) ProtoMessage()

+ func (x *ChromeBuildProto) GetChannel() ChromeBuildProto_Channel

+ func (x *ChromeBuildProto) GetChromeVersion() string

+ func (x *ChromeBuildProto) GetPlatform() ChromeBuildProto_Platform

+ func (x *ChromeBuildProto) ProtoReflect() protoreflect.Message

+ func (x *ChromeBuildProto) Reset()

+ func (x *ChromeBuildProto) String() string

+ type ChromeBuildProto_Channel int32

+ const ChromeBuildProto_CHANNEL_BETA

+ const ChromeBuildProto_CHANNEL_CANARY

+ const ChromeBuildProto_CHANNEL_DEV

+ const ChromeBuildProto_CHANNEL_STABLE

+ const ChromeBuildProto_CHANNEL_UNKNOWN

+ func (ChromeBuildProto_Channel) Descriptor() protoreflect.EnumDescriptor

+ func (ChromeBuildProto_Channel) EnumDescriptor() ([]byte, []int)

+ func (ChromeBuildProto_Channel) Type() protoreflect.EnumType

+ func (x *ChromeBuildProto_Channel) UnmarshalJSON(b []byte) error

+ func (x ChromeBuildProto_Channel) Enum() *ChromeBuildProto_Channel

+ func (x ChromeBuildProto_Channel) Number() protoreflect.EnumNumber

+ func (x ChromeBuildProto_Channel) String() string

+ type ChromeBuildProto_Platform int32

+ const ChromeBuildProto_PLATFORM_ANDROID

+ const ChromeBuildProto_PLATFORM_CROS

+ const ChromeBuildProto_PLATFORM_IOS

+ const ChromeBuildProto_PLATFORM_LINUX

+ const ChromeBuildProto_PLATFORM_MAC

+ const ChromeBuildProto_PLATFORM_WIN

+ func (ChromeBuildProto_Platform) Descriptor() protoreflect.EnumDescriptor

+ func (ChromeBuildProto_Platform) EnumDescriptor() ([]byte, []int)

+ func (ChromeBuildProto_Platform) Type() protoreflect.EnumType

+ func (x *ChromeBuildProto_Platform) UnmarshalJSON(b []byte) error

+ func (x ChromeBuildProto_Platform) Enum() *ChromeBuildProto_Platform

+ func (x ChromeBuildProto_Platform) Number() protoreflect.EnumNumber

+ func (x ChromeBuildProto_Platform) String() string

+ type ClientEvent struct

+ ErrorCode *int32

+ NetworkType *int32

+ NumberDiscardedEvents *uint32

+ TimeConnectionEndedMs *uint64

+ TimeConnectionEstablishedMs *uint64

+ TimeConnectionStartedMs *uint64

+ Type *ClientEvent_Type

+ func (*ClientEvent) Descriptor() ([]byte, []int)

+ func (*ClientEvent) ProtoMessage()

+ func (x *ClientEvent) GetErrorCode() int32

+ func (x *ClientEvent) GetNetworkType() int32

+ func (x *ClientEvent) GetNumberDiscardedEvents() uint32

+ func (x *ClientEvent) GetTimeConnectionEndedMs() uint64

+ func (x *ClientEvent) GetTimeConnectionEstablishedMs() uint64

+ func (x *ClientEvent) GetTimeConnectionStartedMs() uint64

+ func (x *ClientEvent) GetType() ClientEvent_Type

+ func (x *ClientEvent) ProtoReflect() protoreflect.Message

+ func (x *ClientEvent) Reset()

+ func (x *ClientEvent) String() string

+ type ClientEvent_Type int32

+ const ClientEvent_DISCARDED_EVENTS

+ const ClientEvent_FAILED_CONNECTION

+ const ClientEvent_SUCCESSFUL_CONNECTION

+ const ClientEvent_UNKNOWN

+ func (ClientEvent_Type) Descriptor() protoreflect.EnumDescriptor

+ func (ClientEvent_Type) EnumDescriptor() ([]byte, []int)

+ func (ClientEvent_Type) Type() protoreflect.EnumType

+ func (x *ClientEvent_Type) UnmarshalJSON(b []byte) error

+ func (x ClientEvent_Type) Enum() *ClientEvent_Type

+ func (x ClientEvent_Type) Number() protoreflect.EnumNumber

+ func (x ClientEvent_Type) String() string

+ type Close struct

+ func DecodeClose(data []byte) (*Close, error)

+ func (*Close) Descriptor() ([]byte, []int)

+ func (*Close) ProtoMessage()

+ func (x *Close) ProtoReflect() protoreflect.Message

+ func (x *Close) Reset()

+ func (x *Close) String() string

+ type DataMessageStanza struct

+ AppData []*AppData

+ Category *string

+ DeviceUserId *int64

+ From *string

+ FromTrustedServer *bool

+ Id *string

+ ImmediateAck *bool

+ LastStreamIdReceived *int32

+ PersistentId *string

+ Queued *int32

+ RawData []byte

+ RegId *string

+ Sent *int64

+ Status *int64

+ StreamId *int32

+ To *string

+ Token *string

+ Ttl *int32

+ func DecodeDataMessageStanza(data []byte) (*DataMessageStanza, error)

+ func (*DataMessageStanza) Descriptor() ([]byte, []int)

+ func (*DataMessageStanza) ProtoMessage()

+ func (x *DataMessageStanza) GetAppData() []*AppData

+ func (x *DataMessageStanza) GetCategory() string

+ func (x *DataMessageStanza) GetDeviceUserId() int64

+ func (x *DataMessageStanza) GetFrom() string

+ func (x *DataMessageStanza) GetFromTrustedServer() bool

+ func (x *DataMessageStanza) GetId() string

+ func (x *DataMessageStanza) GetImmediateAck() bool

+ func (x *DataMessageStanza) GetLastStreamIdReceived() int32

+ func (x *DataMessageStanza) GetPersistentId() string

+ func (x *DataMessageStanza) GetQueued() int32

+ func (x *DataMessageStanza) GetRawData() []byte

+ func (x *DataMessageStanza) GetRegId() string

+ func (x *DataMessageStanza) GetSent() int64

+ func (x *DataMessageStanza) GetStatus() int64

+ func (x *DataMessageStanza) GetStreamId() int32

+ func (x *DataMessageStanza) GetTo() string

+ func (x *DataMessageStanza) GetToken() string

+ func (x *DataMessageStanza) GetTtl() int32

+ func (x *DataMessageStanza) ProtoReflect() protoreflect.Message

+ func (x *DataMessageStanza) Reset()

+ func (x *DataMessageStanza) String() string

+ type DeviceType int32

+ const DeviceType_DEVICE_ANDROID_OS

+ const DeviceType_DEVICE_CHROME_BROWSER

+ const DeviceType_DEVICE_CHROME_OS

+ const DeviceType_DEVICE_IOS_OS

+ func (DeviceType) Descriptor() protoreflect.EnumDescriptor

+ func (DeviceType) EnumDescriptor() ([]byte, []int)

+ func (DeviceType) Type() protoreflect.EnumType

+ func (x *DeviceType) UnmarshalJSON(b []byte) error

+ func (x DeviceType) Enum() *DeviceType

+ func (x DeviceType) Number() protoreflect.EnumNumber

+ func (x DeviceType) String() string

+ type ErrorInfo struct

+ Code *int32

+ Extension *Extension

+ Message *string

+ Type *string

+ func (*ErrorInfo) Descriptor() ([]byte, []int)

+ func (*ErrorInfo) ProtoMessage()

+ func (x *ErrorInfo) GetCode() int32

+ func (x *ErrorInfo) GetExtension() *Extension

+ func (x *ErrorInfo) GetMessage() string

+ func (x *ErrorInfo) GetType() string

+ func (x *ErrorInfo) ProtoReflect() protoreflect.Message

+ func (x *ErrorInfo) Reset()

+ func (x *ErrorInfo) String() string

+ type Extension struct

+ Data []byte

+ Id *int32

+ func (*Extension) Descriptor() ([]byte, []int)

+ func (*Extension) ProtoMessage()

+ func (x *Extension) GetData() []byte

+ func (x *Extension) GetId() int32

+ func (x *Extension) ProtoReflect() protoreflect.Message

+ func (x *Extension) Reset()

+ func (x *Extension) String() string

+ type FCMClient struct

+ AndroidId uint64

+ FcmToken string

+ GcmToken string

+ HeartbeatInterval time.Duration

+ HttpClient http.Client

+ OnDataMessage func(message []byte)

+ PersistentIds []string

+ SecurityToken uint64

+ SenderId int64

+ func (f *FCMClient) CreateAppId() string

+ func (f *FCMClient) CreateNewKeys() (string, string, error)

+ func (f *FCMClient) GetAuthSecretBase64() string

+ func (f *FCMClient) GetPrivateKeyBase64() (string, error)

+ func (f *FCMClient) LoadKeys(privateKeyBase64 string, authSecretBase64 string) error

+ func (f *FCMClient) Register() (string, string, uint64, uint64, error)

+ func (f *FCMClient) SendCheckInRequest(requestBody *AndroidCheckinRequest) (*AndroidCheckinResponse, error)

+ func (f *FCMClient) SendRegisterRequest() (string, error)

+ func (f *FCMClient) SendSubscribeRequest() (*FCMSubscribeResponse, error)

+ func (f *FCMClient) StartListening() error

+ type FCMSocketHandler struct

+ HeartbeatInterval time.Duration

+ IsAlive bool

+ OnMessage func(messageTag int, messageObject interface{}) error

+ Socket *tls.Conn

+ func (f *FCMSocketHandler) Init()

+ func (f *FCMSocketHandler) SendHeartbeatPing() error

+ func (f *FCMSocketHandler) StartSocketHandler() error

+ type FCMSubscribeResponse struct

+ PushSet string

+ Token string

+ type GservicesSetting struct

+ Name []byte

+ Value []byte

+ func (*GservicesSetting) Descriptor() ([]byte, []int)

+ func (*GservicesSetting) ProtoMessage()

+ func (x *GservicesSetting) GetName() []byte

+ func (x *GservicesSetting) GetValue() []byte

+ func (x *GservicesSetting) ProtoReflect() protoreflect.Message

+ func (x *GservicesSetting) Reset()

+ func (x *GservicesSetting) String() string

+ type HeartbeatAck struct

+ LastStreamIdReceived *int32

+ Status *int64

+ StreamId *int32

+ func DecodeHeartbeatAck(data []byte) (*HeartbeatAck, error)

+ func (*HeartbeatAck) Descriptor() ([]byte, []int)

+ func (*HeartbeatAck) ProtoMessage()

+ func (x *HeartbeatAck) GetLastStreamIdReceived() int32

+ func (x *HeartbeatAck) GetStatus() int64

+ func (x *HeartbeatAck) GetStreamId() int32

+ func (x *HeartbeatAck) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatAck) Reset()

+ func (x *HeartbeatAck) String() string

+ type HeartbeatConfig struct

+ IntervalMs *int32

+ Ip *string

+ UploadStat *bool

+ func (*HeartbeatConfig) Descriptor() ([]byte, []int)

+ func (*HeartbeatConfig) ProtoMessage()

+ func (x *HeartbeatConfig) GetIntervalMs() int32

+ func (x *HeartbeatConfig) GetIp() string

+ func (x *HeartbeatConfig) GetUploadStat() bool

+ func (x *HeartbeatConfig) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatConfig) Reset()

+ func (x *HeartbeatConfig) String() string

+ type HeartbeatPing struct

+ LastStreamIdReceived *int32

+ Status *int64

+ StreamId *int32

+ func DecodeHeartbeatPing(data []byte) (*HeartbeatPing, error)

+ func (*HeartbeatPing) Descriptor() ([]byte, []int)

+ func (*HeartbeatPing) ProtoMessage()

+ func (x *HeartbeatPing) GetLastStreamIdReceived() int32

+ func (x *HeartbeatPing) GetStatus() int64

+ func (x *HeartbeatPing) GetStreamId() int32

+ func (x *HeartbeatPing) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatPing) Reset()

+ func (x *HeartbeatPing) String() string

+ type HeartbeatStat struct

+ IntervalMs *int32

+ Ip *string

+ Timeout *bool

+ func (*HeartbeatStat) Descriptor() ([]byte, []int)

+ func (*HeartbeatStat) ProtoMessage()

+ func (x *HeartbeatStat) GetIntervalMs() int32

+ func (x *HeartbeatStat) GetIp() string

+ func (x *HeartbeatStat) GetTimeout() bool

+ func (x *HeartbeatStat) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatStat) Reset()

+ func (x *HeartbeatStat) String() string

+ type IqStanza struct

+ AccountId *int64

+ Error *ErrorInfo

+ Extension *Extension

+ From *string

+ Id *string

+ LastStreamIdReceived *int32

+ PersistentId *string

+ RmqId *int64

+ Status *int64

+ StreamId *int32

+ To *string

+ Type *IqStanza_IqType

+ func DecodeIqStanza(data []byte) (*IqStanza, error)

+ func (*IqStanza) Descriptor() ([]byte, []int)

+ func (*IqStanza) ProtoMessage()

+ func (x *IqStanza) GetAccountId() int64

+ func (x *IqStanza) GetError() *ErrorInfo

+ func (x *IqStanza) GetExtension() *Extension

+ func (x *IqStanza) GetFrom() string

+ func (x *IqStanza) GetId() string

+ func (x *IqStanza) GetLastStreamIdReceived() int32

+ func (x *IqStanza) GetPersistentId() string

+ func (x *IqStanza) GetRmqId() int64

+ func (x *IqStanza) GetStatus() int64

+ func (x *IqStanza) GetStreamId() int32

+ func (x *IqStanza) GetTo() string

+ func (x *IqStanza) GetType() IqStanza_IqType

+ func (x *IqStanza) ProtoReflect() protoreflect.Message

+ func (x *IqStanza) Reset()

+ func (x *IqStanza) String() string

+ type IqStanza_IqType int32

+ const IqStanza_GET

+ const IqStanza_IQ_ERROR

+ const IqStanza_RESULT

+ const IqStanza_SET

+ func (IqStanza_IqType) Descriptor() protoreflect.EnumDescriptor

+ func (IqStanza_IqType) EnumDescriptor() ([]byte, []int)

+ func (IqStanza_IqType) Type() protoreflect.EnumType

+ func (x *IqStanza_IqType) UnmarshalJSON(b []byte) error

+ func (x IqStanza_IqType) Enum() *IqStanza_IqType

+ func (x IqStanza_IqType) Number() protoreflect.EnumNumber

+ func (x IqStanza_IqType) String() string

+ type LoginRequest struct

+ AccountId *int64

+ AdaptiveHeartbeat *bool

+ AuthService *LoginRequest_AuthService

+ AuthToken *string

+ ClientEvent []*ClientEvent

+ DeviceId *string

+ Domain *string

+ HeartbeatStat *HeartbeatStat

+ Id *string

+ LastRmqId *int64

+ NetworkType *int32

+ ReceivedPersistentId []string

+ Resource *string

+ Setting []*Setting

+ Status *int64

+ UseRmq2 *bool

+ User *string

+ func DecodeLoginRequest(data []byte) (*LoginRequest, error)

+ func (*LoginRequest) Descriptor() ([]byte, []int)

+ func (*LoginRequest) ProtoMessage()

+ func (x *LoginRequest) GetAccountId() int64

+ func (x *LoginRequest) GetAdaptiveHeartbeat() bool

+ func (x *LoginRequest) GetAuthService() LoginRequest_AuthService

+ func (x *LoginRequest) GetAuthToken() string

+ func (x *LoginRequest) GetClientEvent() []*ClientEvent

+ func (x *LoginRequest) GetDeviceId() string

+ func (x *LoginRequest) GetDomain() string

+ func (x *LoginRequest) GetHeartbeatStat() *HeartbeatStat

+ func (x *LoginRequest) GetId() string

+ func (x *LoginRequest) GetLastRmqId() int64

+ func (x *LoginRequest) GetNetworkType() int32

+ func (x *LoginRequest) GetReceivedPersistentId() []string

+ func (x *LoginRequest) GetResource() string

+ func (x *LoginRequest) GetSetting() []*Setting

+ func (x *LoginRequest) GetStatus() int64

+ func (x *LoginRequest) GetUseRmq2() bool

+ func (x *LoginRequest) GetUser() string

+ func (x *LoginRequest) ProtoReflect() protoreflect.Message

+ func (x *LoginRequest) Reset()

+ func (x *LoginRequest) String() string

+ type LoginRequest_AuthService int32

+ const LoginRequest_ANDROID_ID

+ func (LoginRequest_AuthService) Descriptor() protoreflect.EnumDescriptor

+ func (LoginRequest_AuthService) EnumDescriptor() ([]byte, []int)

+ func (LoginRequest_AuthService) Type() protoreflect.EnumType

+ func (x *LoginRequest_AuthService) UnmarshalJSON(b []byte) error

+ func (x LoginRequest_AuthService) Enum() *LoginRequest_AuthService

+ func (x LoginRequest_AuthService) Number() protoreflect.EnumNumber

+ func (x LoginRequest_AuthService) String() string

+ type LoginResponse struct

+ Error *ErrorInfo

+ HeartbeatConfig *HeartbeatConfig

+ Id *string

+ Jid *string

+ LastStreamIdReceived *int32

+ ServerTimestamp *int64

+ Setting []*Setting

+ StreamId *int32

+ func DecodeLoginResponse(data []byte) (*LoginResponse, error)

+ func (*LoginResponse) Descriptor() ([]byte, []int)

+ func (*LoginResponse) ProtoMessage()

+ func (x *LoginResponse) GetError() *ErrorInfo

+ func (x *LoginResponse) GetHeartbeatConfig() *HeartbeatConfig

+ func (x *LoginResponse) GetId() string

+ func (x *LoginResponse) GetJid() string

+ func (x *LoginResponse) GetLastStreamIdReceived() int32

+ func (x *LoginResponse) GetServerTimestamp() int64

+ func (x *LoginResponse) GetSetting() []*Setting

+ func (x *LoginResponse) GetStreamId() int32

+ func (x *LoginResponse) ProtoReflect() protoreflect.Message

+ func (x *LoginResponse) Reset()

+ func (x *LoginResponse) String() string

+ type SelectiveAck struct

+ Id []string

+ func (*SelectiveAck) Descriptor() ([]byte, []int)

+ func (*SelectiveAck) ProtoMessage()

+ func (x *SelectiveAck) GetId() []string

+ func (x *SelectiveAck) ProtoReflect() protoreflect.Message

+ func (x *SelectiveAck) Reset()

+ func (x *SelectiveAck) String() string

+ type Setting struct

+ Name *string

+ Value *string

+ func (*Setting) Descriptor() ([]byte, []int)

+ func (*Setting) ProtoMessage()

+ func (x *Setting) GetName() string

+ func (x *Setting) GetValue() string

+ func (x *Setting) ProtoReflect() protoreflect.Message

+ func (x *Setting) Reset()

+ func (x *Setting) String() string

+ type StreamAck struct

+ func (*StreamAck) Descriptor() ([]byte, []int)

+ func (*StreamAck) ProtoMessage()

+ func (x *StreamAck) ProtoReflect() protoreflect.Message

+ func (x *StreamAck) Reset()

+ func (x *StreamAck) String() string

+ type StreamErrorStanza struct

+ Text *string

+ Type *string

+ func DecodeStreamErrorStanza(data []byte) (*StreamErrorStanza, error)

+ func (*StreamErrorStanza) Descriptor() ([]byte, []int)

+ func (*StreamErrorStanza) ProtoMessage()

+ func (x *StreamErrorStanza) GetText() string

+ func (x *StreamErrorStanza) GetType() string

+ func (x *StreamErrorStanza) ProtoReflect() protoreflect.Message

+ func (x *StreamErrorStanza) Reset()

+ func (x *StreamErrorStanza) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL