Versions in this module Expand all Collapse all v5 v5.0.1 May 25, 2021 Changes in this version + const MaxSequence + const PNCreate + const PNDelete + const PNManage + const PNObjectsChannelEvent + const PNObjectsMembershipEvent + const PNObjectsNoneEvent + const PNObjectsUUIDEvent + const PNRead + const PNWrite + const StrChannelsTimetoken + const StrChannelsTimetokenLength + const StrInvalidTTL + const StrMissingChannel + const StrMissingChannelGroup + const StrMissingDeviceID + const StrMissingFileID + const StrMissingFileName + const StrMissingMessage + const StrMissingPubKey + const StrMissingPushTitle + const StrMissingPushTopic + const StrMissingPushType + const StrMissingSecretKey + const StrMissingSubKey + const StrMissingUUID + const Version + func EnumArrayToStringArray(include interface{}) []string + func NewHTTP1Client(connectTimeout, responseReadTimeout, maxIdleConnsPerHost int) *http.Client + func NewHTTP2Client(connectTimeout int, responseReadTimeout int) *http.Client + func ParseFileInfo(filesPayload map[string]interface{}) (PNFileDetails, PNPublishMessage) + func SetArrayTypeQueryParam(q *url.Values, val []string, key string) + func SetPushEnvironment(q *url.Values, env PNPushEnvironment) + func SetPushTopic(q *url.Values, topic string) + func SetQueryParam(q *url.Values, queryParam map[string]string) + func SetQueryParamAsCommaSepString(q *url.Values, val []string, key string) + type AddChannelToChannelGroupResponse struct + type AddPushNotificationsOnChannelsResponse struct + type AllChannelGroupResponse struct + ChannelGroup string + Channels []string + type ChannelPermissions struct + Delete bool + Read bool + Write bool + type ChannelPermissionsWithToken struct + BitMaskPerms int64 + Permissions ChannelPermissions + TTL int + Timestamp int64 + Token string + type Config struct + AuthKey string + CipherKey string + ConnectTimeout int + DisablePNOtherProcessing bool + FileMessagePublishRetryLimit int + FileUploadRequestTimeout int + FilterExpression string + HeartbeatInterval int + Log *log.Logger + MaxIdleConnsPerHost int + MaxWorkers int + MaximumLatencyDataAge int + MaximumReconnectionRetries int + MessageQueueOverflowCount int + NonSubscribeRequestTimeout int + Origin string + PNReconnectionPolicy ReconnectionPolicy + PresenceTimeout int + PublishKey string + SecretKey string + Secure bool + StoreTokensOnGrant bool + SubscribeKey string + SubscribeRequestTimeout int + SuppressLeaveEvents bool + UUID string + UseHTTP2 bool + UsePAMV3 bool + UseRandomInitializationVector bool + func NewConfig() *Config + func NewDemoConfig() *Config + func (c *Config) SetPresenceTimeout(timeout int) *Config + func (c *Config) SetPresenceTimeoutWithCustomInterval(timeout, interval int) *Config + type Context interface + Deadline func() (deadline time.Time, ok bool) + Done func() <-chan struct{} + Err func() error + Value func(key interface{}) interface{} + type DeleteChannelGroupResponse struct + type FetchResponse struct + Messages map[string][]FetchResponseItem + type FetchResponseItem struct + File PNFileDetails + Message interface{} + MessageActions map[string]PNHistoryMessageActionsTypeMap + MessageType int + Meta interface{} + Timetoken string + UUID string + type GetStateResponse struct + State map[string]interface{} + UUID string + type GrantResources struct + Channels map[string]int64 + Groups map[string]int64 + Spaces map[string]int64 + Users map[string]int64 + type GrantResourcesWithPermissions struct + Channels map[string]ChannelPermissionsWithToken + ChannelsPattern map[string]ChannelPermissionsWithToken + Groups map[string]GroupPermissionsWithToken + GroupsPattern map[string]GroupPermissionsWithToken + Spaces map[string]UserSpacePermissionsWithToken + SpacesPattern map[string]UserSpacePermissionsWithToken + Users map[string]UserSpacePermissionsWithToken + UsersPattern map[string]UserSpacePermissionsWithToken + func ParseGrantResources(res GrantResources, token string, timetoken int64, ttl int) *GrantResourcesWithPermissions + type GrantResponse struct + ChannelGroups map[string]*PNPAMEntityData + Channels map[string]*PNPAMEntityData + DeleteEnabled bool + GetEnabled bool + JoinEnabled bool + Level string + ManageEnabled bool + ReadEnabled bool + SubscribeKey string + TTL int + UUIDs map[string]*PNPAMEntityData + UpdateEnabled bool + WriteEnabled bool + type GroupPermissions struct + Manage bool + Read bool + type GroupPermissionsWithToken struct + BitMaskPerms int64 + Permissions GroupPermissions + TTL int + Timestamp int64 + Token string + type HeartbeatManager struct + func (m *HeartbeatManager) Destroy() + type HereNowChannelData struct + ChannelName string + Occupancy int + Occupants []HereNowOccupantsData + type HereNowOccupantsData struct + State map[string]interface{} + UUID string + type HereNowResponse struct + Channels []HereNowChannelData + TotalChannels int + TotalOccupancy int + type HistoryDeleteResponse struct + type HistoryResponse struct + EndTimetoken int64 + Messages []HistoryResponseItem + StartTimetoken int64 + type HistoryResponseItem struct + Message interface{} + Meta interface{} + Timetoken int64 + type JobQItem struct + Client *http.Client + JobResponse chan *JobQResponse + Req *http.Request + type JobQResponse struct + Error error + Resp *http.Response + type LatencyEntry struct + D int64 + L float64 + type ListPushProvisionsRequestResponse struct + Channels []string + type Listener struct + ChannelEvent chan *PNChannelEvent + File chan *PNFilesEvent + MembershipEvent chan *PNMembershipEvent + Message chan *PNMessage + MessageActionsEvent chan *PNMessageActionsEvent + Presence chan *PNPresence + Signal chan *PNMessage + Status chan *PNStatus + UUIDEvent chan *PNUUIDEvent + func NewListener() *Listener + type ListenerManager struct + type MessageAction struct + ActionType string + ActionValue string + type MessageCountsResponse struct + Channels map[string]int + type OperationType int + const PNAccessManagerGrant + const PNAccessManagerGrantToken + const PNAccessManagerRevoke + const PNAddChannelsToChannelGroupOperation + const PNAddMessageActionsOperation + const PNAddPushNotificationsOnChannelsOperation + const PNChannelsForGroupOperation + const PNCreateSpaceOperation + const PNCreateUserOperation + const PNDeleteFileOperation + const PNDeleteMessagesOperation + const PNDeleteSpaceOperation + const PNDeleteUserOperation + const PNDownloadFileOperation + const PNFetchMessagesOperation + const PNFireOperation + const PNGetAllChannelMetadataOperation + const PNGetAllUUIDMetadataOperation + const PNGetChannelMembersOperation + const PNGetChannelMetadataOperation + const PNGetFileURLOperation + const PNGetMembershipsOperation + const PNGetMessageActionsOperation + const PNGetSpaceOperation + const PNGetSpacesOperation + const PNGetStateOperation + const PNGetUUIDMetadataOperation + const PNGetUserOperation + const PNGetUsersOperation + const PNHeartBeatOperation + const PNHereNowOperation + const PNHistoryOperation + const PNHistoryWithActionsOperation + const PNListFilesOperation + const PNManageMembersOperation + const PNManageMembershipsOperation + const PNMessageCountsOperation + const PNPublishFileMessageOperation + const PNPublishOperation + const PNPushNotificationsEnabledChannelsOperation + const PNRemoveAllPushNotificationsOperation + const PNRemoveChannelFromChannelGroupOperation + const PNRemoveChannelMembersOperation + const PNRemoveChannelMetadataOperation + const PNRemoveGroupOperation + const PNRemoveMembershipsOperation + const PNRemoveMessageActionsOperation + const PNRemovePushNotificationsFromChannelsOperation + const PNRemoveUUIDMetadataOperation + const PNSendFileOperation + const PNSendFileToS3Operation + const PNSetChannelMembersOperation + const PNSetChannelMetadataOperation + const PNSetMembershipsOperation + const PNSetStateOperation + const PNSetUUIDMetadataOperation + const PNSignalOperation + const PNSubscribeOperation + const PNTimeOperation + const PNUnsubscribeOperation + const PNUpdateSpaceOperation + const PNUpdateUserOperation + const PNWhereNowOperation + func (t OperationType) String() string + type Operations struct + type PNAPNS2Data struct + CollapseID string + Expiration string + Targets []PNPushTarget + Version string + type PNAPNSData struct + APS PNAPSData + Custom map[string]interface{} + type PNAPSData struct + Alert interface{} + Badge int + Body string + Custom map[string]interface{} + Sound string + Subtitle string + Title string + type PNAccessManagerKeyData struct + DeleteEnabled bool + GetEnabled bool + JoinEnabled bool + ManageEnabled bool + ReadEnabled bool + TTL int + UpdateEnabled bool + WriteEnabled bool + type PNAddMessageActionsResponse struct + Data PNMessageActionsResponse + type PNChannel struct + Custom map[string]interface{} + Description string + ETag string + ID string + Name string + Updated string + type PNChannelEvent struct + ActualChannel string + Channel string + ChannelID string + Custom map[string]interface{} + Description string + ETag string + Event PNObjectsEvent + Name string + SubscribedChannel string + Subscription string + Timestamp string + Updated string + type PNChannelMembers struct + Created string + Custom map[string]interface{} + ETag string + ID string + UUID PNUUID + Updated string + type PNChannelMembersInclude int + const PNChannelMembersIncludeCustom + const PNChannelMembersIncludeUUID + const PNChannelMembersIncludeUUIDCustom + func (s PNChannelMembersInclude) String() string + type PNChannelMembersRemove struct + UUID PNChannelMembersUUID + type PNChannelMembersRemoveChangeset struct + Remove []PNChannelMembersRemove + type PNChannelMembersSet struct + Custom map[string]interface{} + UUID PNChannelMembersUUID + type PNChannelMembersSetChangeset struct + Set []PNChannelMembersSet + type PNChannelMembersUUID struct + ID string + type PNChannelMetadataInclude int + const PNChannelMetadataIncludeCustom + func (s PNChannelMetadataInclude) String() string + type PNDeleteFileResponse struct + type PNDownloadFileResponse struct + File io.Reader + type PNFCMData struct + Custom map[string]interface{} + Data PNFCMDataFields + type PNFCMDataFields struct + Custom map[string]interface{} + Summary interface{} + type PNFileData struct + ID string + type PNFileDetails struct + ID string + Name string + URL string + type PNFileInfo struct + Created string + ID string + Name string + Size int + type PNFileInfoForPublish struct + ID string + Name string + type PNFileMessageAndDetails struct + PNFile PNFileDetails + PNMessage PNPublishMessage + type PNFileUploadRequest struct + FormFields []PNFormField + Method string + URL string + type PNFilesEvent struct + ActualChannel string + Channel string + File PNFileMessageAndDetails + Publisher string + SubscribedChannel string + Subscription string + Timetoken int64 + UserMetadata interface{} + type PNFormField struct + Key string + Value string + type PNGetAllChannelMetadataResponse struct + Data []PNChannel + Next string + Prev string + TotalCount int + type PNGetAllUUIDMetadataResponse struct + Data []PNUUID + Next string + Prev string + TotalCount int + type PNGetChannelMembersResponse struct + Data []PNChannelMembers + Next string + Prev string + TotalCount int + type PNGetChannelMetadataResponse struct + Data PNChannel + type PNGetFileURLResponse struct + URL string + type PNGetMembershipsResponse struct + Data []PNMemberships + Next string + Prev string + TotalCount int + type PNGetMessageActionsMore struct + End string + Limit int + Start string + URL string + type PNGetMessageActionsResponse struct + Data []PNMessageActionsResponse + More PNGetMessageActionsMore + type PNGetUUIDMetadataResponse struct + Data PNUUID + type PNGrantBitMask int64 + type PNGrantTokenData struct + Message string + Token string + type PNGrantTokenDecoded struct + Meta map[string]interface{} + Patterns GrantResources + Resources GrantResources + Signature []byte + TTL int + Timestamp int64 + Version int + func GetPermissions(token string) (PNGrantTokenDecoded, error) + type PNGrantTokenResponse struct + Data PNGrantTokenData + type PNGrantType int + const PNCreateEnabled + const PNDeleteEnabled + const PNGetEnabled + const PNJoinEnabled + const PNManageEnabled + const PNReadEnabled + const PNUpdateEnabled + const PNWriteEnabled + type PNHistoryMessageActionTypeVal struct + ActionTimetoken string + UUID string + type PNHistoryMessageActionsTypeMap struct + ActionsTypeValues map[string][]PNHistoryMessageActionTypeVal + type PNListFilesResponse struct + Count int + Data []PNFileInfo + Next string + type PNMPNSData struct + BackContent string + BackTitle string + Count int + Custom map[string]interface{} + Title string + Type string + type PNManageChannelMembersBody struct + Remove []PNChannelMembersRemove + Set []PNChannelMembersSet + type PNManageMembersResponse struct + Data []PNChannelMembers + Next string + Prev string + TotalCount int + type PNManageMembershipsBody struct + Remove []PNMembershipsRemove + Set []PNMembershipsSet + type PNManageMembershipsResponse struct + Data []PNMemberships + Next string + Prev string + TotalCount int + type PNMembersAddChangeSet struct + Set []PNMembershipsSet + type PNMembershipEvent struct + ActualChannel string + Channel string + ChannelID string + Custom map[string]interface{} + Description string + Event PNObjectsEvent + SubscribedChannel string + Subscription string + Timestamp string + UUID string + type PNMemberships struct + Channel PNChannel + Created string + Custom map[string]interface{} + ETag string + ID string + Updated string + type PNMembershipsChannel struct + ID string + type PNMembershipsInclude int + const PNMembershipsIncludeChannel + const PNMembershipsIncludeChannelCustom + const PNMembershipsIncludeCustom + func (s PNMembershipsInclude) String() string + type PNMembershipsRemove struct + Channel PNMembershipsChannel + type PNMembershipsRemoveChangeSet struct + Remove []PNMembershipsRemove + type PNMembershipsSet struct + Channel PNMembershipsChannel + Custom map[string]interface{} + type PNMessage struct + ActualChannel string + Channel string + Message interface{} + Publisher string + SubscribedChannel string + Subscription string + Timetoken int64 + UserMetadata interface{} + type PNMessageActionsEvent struct + ActualChannel string + Channel string + Data PNMessageActionsResponse + Event PNMessageActionsEventType + SubscribedChannel string + Subscription string + type PNMessageActionsEventType string + const PNMessageActionsAdded + const PNMessageActionsRemoved + type PNMessageActionsResponse struct + ActionTimetoken string + ActionType string + ActionValue string + MessageTimetoken string + UUID string + type PNMessageType int + const PNMessageTypeFile + const PNMessageTypeMessageActions + const PNMessageTypeObjects + const PNMessageTypeSignal + type PNObjectsEvent string + const PNObjectsEventRemove + const PNObjectsEventSet + type PNObjectsEventType string + type PNObjectsResponse struct + Channel string + Custom map[string]interface{} + Data map[string]interface{} + Description string + ETag string + Email string + Event PNObjectsEvent + EventType PNObjectsEventType + ExternalID string + ID string + Name string + ProfileURL string + Timestamp string + Updated string + type PNPAMEntityData struct + AuthKeys map[string]*PNAccessManagerKeyData + DeleteEnabled bool + GetEnabled bool + JoinEnabled bool + ManageEnabled bool + Name string + ReadEnabled bool + TTL int + UpdateEnabled bool + WriteEnabled bool + type PNPresence struct + ActualChannel string + Channel string + Event string + HereNowRefresh bool + Join []string + Leave []string + Occupancy int + State interface{} + SubscribedChannel string + Subscription string + Timeout []string + Timestamp int64 + Timetoken int64 + UUID string + UserMetadata map[string]interface{} + type PNPublishFileMessage struct + PNFile *PNFileInfoForPublish + PNMessage *PNPublishMessage + type PNPublishMessage struct + Text string + type PNPushEnvironment string + const PNPushEnvironmentDevelopment + const PNPushEnvironmentProduction + type PNPushTarget struct + Environment PNPushEnvironment + ExcludeDevices []string + Topic string + type PNPushType int + const PNPushTypeAPNS + const PNPushTypeAPNS2 + const PNPushTypeGCM + const PNPushTypeMPNS + const PNPushTypeNone + func (p PNPushType) String() string + type PNRemoveChannelMembersResponse struct + Data []PNChannelMembers + Next string + Prev string + TotalCount int + type PNRemoveChannelMetadataResponse struct + Data interface{} + type PNRemoveMembershipsResponse struct + Data []PNMemberships + Next string + Prev string + TotalCount int + type PNRemoveMessageActionsResponse struct + Data interface{} + type PNRemoveUUIDMetadataResponse struct + Data interface{} + type PNResourceType int + const PNChannels + const PNGroups + const PNSpaces + const PNUsers + type PNSendFileBody struct + Name string + type PNSendFileResponse struct + Data PNFileData + Timestamp int64 + type PNSendFileResponseForS3 struct + Data PNFileData + FileUploadRequest PNFileUploadRequest + type PNSendFileToS3Response struct + type PNSetChannelMembersResponse struct + Data []PNChannelMembers + Next string + Prev string + TotalCount int + type PNSetChannelMetadataResponse struct + Data PNChannel + type PNSetMembershipsResponse struct + Data []PNMemberships + Next string + Prev string + TotalCount int + type PNSetUUIDMetadataResponse struct + Data PNUUID + type PNStatus struct + AffectedChannelGroups []string + AffectedChannels []string + AuthKey string + Category StatusCategory + ClientRequest interface{} + Error bool + ErrorData error + Operation OperationType + Origin string + StatusCode int + TLSEnabled bool + UUID string + type PNUUID struct + Custom map[string]interface{} + ETag string + Email string + ExternalID string + ID string + Name string + ProfileURL string + Updated string + type PNUUIDEvent struct + ActualChannel string + Channel string + Custom map[string]interface{} + Description string + ETag string + Email string + Event PNObjectsEvent + ExternalID string + Name string + ProfileURL string + SubscribedChannel string + Subscription string + Timestamp string + UUID string + Updated string + type PNUUIDMetadataInclude int + const PNUUIDMetadataIncludeCustom + func (s PNUUIDMetadataInclude) String() string + type PermissionsBody struct + Meta map[string]interface{} + Patterns GrantResources + Resources GrantResources + type PubNub struct + Config *Config + func NewPubNub(pnconf *Config) *PubNub + func NewPubNubDemo() *PubNub + func (pn *PubNub) AddChannelToChannelGroup() *addChannelToChannelGroupBuilder + func (pn *PubNub) AddChannelToChannelGroupWithContext(ctx Context) *addChannelToChannelGroupBuilder + func (pn *PubNub) AddListener(listener *Listener) + func (pn *PubNub) AddMessageAction() *addMessageActionsBuilder + func (pn *PubNub) AddMessageActionWithContext(ctx Context) *addMessageActionsBuilder + func (pn *PubNub) AddPushNotificationsOnChannels() *addPushNotificationsOnChannelsBuilder + func (pn *PubNub) AddPushNotificationsOnChannelsWithContext(ctx Context) *addPushNotificationsOnChannelsBuilder + func (pn *PubNub) CreatePushPayload() *publishPushHelperBuilder + func (pn *PubNub) CreatePushPayloadWithContext(ctx Context) *publishPushHelperBuilder + func (pn *PubNub) DeleteChannelGroup() *deleteChannelGroupBuilder + func (pn *PubNub) DeleteChannelGroupWithContext(ctx Context) *deleteChannelGroupBuilder + func (pn *PubNub) DeleteFile() *deleteFileBuilder + func (pn *PubNub) DeleteFileWithContext(ctx Context) *deleteFileBuilder + func (pn *PubNub) DeleteMessages() *historyDeleteBuilder + func (pn *PubNub) DeleteMessagesWithContext(ctx Context) *historyDeleteBuilder + func (pn *PubNub) Destroy() + func (pn *PubNub) DownloadFile() *downloadFileBuilder + func (pn *PubNub) DownloadFileWithContext(ctx Context) *downloadFileBuilder + func (pn *PubNub) Fetch() *fetchBuilder + func (pn *PubNub) FetchWithContext(ctx Context) *fetchBuilder + func (pn *PubNub) Fire() *fireBuilder + func (pn *PubNub) FireWithContext(ctx Context) *fireBuilder + func (pn *PubNub) GetAllChannelMetadata() *getAllChannelMetadataBuilder + func (pn *PubNub) GetAllChannelMetadataWithContext(ctx Context) *getAllChannelMetadataBuilder + func (pn *PubNub) GetAllUUIDMetadata() *getAllUUIDMetadataBuilder + func (pn *PubNub) GetAllUUIDMetadataWithContext(ctx Context) *getAllUUIDMetadataBuilder + func (pn *PubNub) GetChannelMembers() *getChannelMembersBuilderV2 + func (pn *PubNub) GetChannelMembersWithContext(ctx Context) *getChannelMembersBuilderV2 + func (pn *PubNub) GetChannelMetadata() *getChannelMetadataBuilder + func (pn *PubNub) GetChannelMetadataWithContext(ctx Context) *getChannelMetadataBuilder + func (pn *PubNub) GetClient() *http.Client + func (pn *PubNub) GetFileURL() *getFileURLBuilder + func (pn *PubNub) GetFileURLWithContext(ctx Context) *getFileURLBuilder + func (pn *PubNub) GetListeners() map[*Listener]bool + func (pn *PubNub) GetMemberships() *getMembershipsBuilderV2 + func (pn *PubNub) GetMembershipsWithContext(ctx Context) *getMembershipsBuilderV2 + func (pn *PubNub) GetMessageActions() *getMessageActionsBuilder + func (pn *PubNub) GetMessageActionsWithContext(ctx Context) *getMessageActionsBuilder + func (pn *PubNub) GetState() *getStateBuilder + func (pn *PubNub) GetStateWithContext(ctx Context) *getStateBuilder + func (pn *PubNub) GetSubscribeClient() *http.Client + func (pn *PubNub) GetSubscribedChannels() []string + func (pn *PubNub) GetSubscribedGroups() []string + func (pn *PubNub) GetToken(resourceID string, resourceType PNResourceType) string + func (pn *PubNub) GetTokens() GrantResourcesWithPermissions + func (pn *PubNub) GetTokensByResource(resourceType PNResourceType) GrantResourcesWithPermissions + func (pn *PubNub) GetUUIDMetadata() *getUUIDMetadataBuilder + func (pn *PubNub) GetUUIDMetadataWithContext(ctx Context) *getUUIDMetadataBuilder + func (pn *PubNub) Grant() *grantBuilder + func (pn *PubNub) GrantToken() *grantTokenBuilder + func (pn *PubNub) GrantTokenWithContext(ctx Context) *grantTokenBuilder + func (pn *PubNub) GrantWithContext(ctx Context) *grantBuilder + func (pn *PubNub) Heartbeat() *heartbeatBuilder + func (pn *PubNub) HeartbeatWithContext(ctx Context) *heartbeatBuilder + func (pn *PubNub) HereNow() *hereNowBuilder + func (pn *PubNub) HereNowWithContext(ctx Context) *hereNowBuilder + func (pn *PubNub) History() *historyBuilder + func (pn *PubNub) HistoryWithContext(ctx Context) *historyBuilder + func (pn *PubNub) Leave() *leaveBuilder + func (pn *PubNub) LeaveWithContext(ctx Context) *leaveBuilder + func (pn *PubNub) ListChannelsInChannelGroup() *allChannelGroupBuilder + func (pn *PubNub) ListChannelsInChannelGroupWithContext(ctx Context) *allChannelGroupBuilder + func (pn *PubNub) ListFiles() *listFilesBuilder + func (pn *PubNub) ListFilesWithContext(ctx Context) *listFilesBuilder + func (pn *PubNub) ListPushProvisions() *listPushProvisionsRequestBuilder + func (pn *PubNub) ListPushProvisionsWithContext(ctx Context) *listPushProvisionsRequestBuilder + func (pn *PubNub) ManageChannelMembers() *manageChannelMembersBuilderV2 + func (pn *PubNub) ManageChannelMembersWithContext(ctx Context) *manageChannelMembersBuilderV2 + func (pn *PubNub) ManageMemberships() *manageMembershipsBuilderV2 + func (pn *PubNub) ManageMembershipsWithContext(ctx Context) *manageMembershipsBuilderV2 + func (pn *PubNub) MessageCounts() *messageCountsBuilder + func (pn *PubNub) MessageCountsWithContext(ctx Context) *messageCountsBuilder + func (pn *PubNub) Presence() *presenceBuilder + func (pn *PubNub) PresenceWithContext(ctx Context) *presenceBuilder + func (pn *PubNub) Publish() *publishBuilder + func (pn *PubNub) PublishFileMessage() *publishFileMessageBuilder + func (pn *PubNub) PublishFileMessageWithContext(ctx Context) *publishFileMessageBuilder + func (pn *PubNub) PublishWithContext(ctx Context) *publishBuilder + func (pn *PubNub) RemoveAllPushNotifications() *removeAllPushChannelsForDeviceBuilder + func (pn *PubNub) RemoveAllPushNotificationsWithContext(ctx Context) *removeAllPushChannelsForDeviceBuilder + func (pn *PubNub) RemoveChannelFromChannelGroup() *removeChannelFromChannelGroupBuilder + func (pn *PubNub) RemoveChannelFromChannelGroupWithContext(ctx Context) *removeChannelFromChannelGroupBuilder + func (pn *PubNub) RemoveChannelMembers() *removeChannelMembersBuilder + func (pn *PubNub) RemoveChannelMembersWithContext(ctx Context) *removeChannelMembersBuilder + func (pn *PubNub) RemoveChannelMetadata() *removeChannelMetadataBuilder + func (pn *PubNub) RemoveChannelMetadataWithContext(ctx Context) *removeChannelMetadataBuilder + func (pn *PubNub) RemoveListener(listener *Listener) + func (pn *PubNub) RemoveMemberships() *removeMembershipsBuilder + func (pn *PubNub) RemoveMembershipsWithContext(ctx Context) *removeMembershipsBuilder + func (pn *PubNub) RemoveMessageAction() *removeMessageActionsBuilder + func (pn *PubNub) RemoveMessageActionWithContext(ctx Context) *removeMessageActionsBuilder + func (pn *PubNub) RemovePushNotificationsFromChannels() *removeChannelsFromPushBuilder + func (pn *PubNub) RemovePushNotificationsFromChannelsWithContext(ctx Context) *removeChannelsFromPushBuilder + func (pn *PubNub) RemoveUUIDMetadata() *removeUUIDMetadataBuilder + func (pn *PubNub) RemoveUUIDMetadataWithContext(ctx Context) *removeUUIDMetadataBuilder + func (pn *PubNub) ResetTokenManager() + func (pn *PubNub) SendFile() *sendFileBuilder + func (pn *PubNub) SendFileWithContext(ctx Context) *sendFileBuilder + func (pn *PubNub) SetChannelMembers() *setChannelMembersBuilder + func (pn *PubNub) SetChannelMembersWithContext(ctx Context) *setChannelMembersBuilder + func (pn *PubNub) SetChannelMetadata() *setChannelMetadataBuilder + func (pn *PubNub) SetChannelMetadataWithContext(ctx Context) *setChannelMetadataBuilder + func (pn *PubNub) SetClient(c *http.Client) + func (pn *PubNub) SetMemberships() *setMembershipsBuilder + func (pn *PubNub) SetMembershipsWithContext(ctx Context) *setMembershipsBuilder + func (pn *PubNub) SetState() *setStateBuilder + func (pn *PubNub) SetStateWithContext(ctx Context) *setStateBuilder + func (pn *PubNub) SetSubscribeClient(client *http.Client) + func (pn *PubNub) SetToken(token string) + func (pn *PubNub) SetTokens(tokens []string) + func (pn *PubNub) SetUUIDMetadata() *setUUIDMetadataBuilder + func (pn *PubNub) SetUUIDMetadataWithContext(ctx Context) *setUUIDMetadataBuilder + func (pn *PubNub) Signal() *signalBuilder + func (pn *PubNub) SignalWithContext(ctx Context) *signalBuilder + func (pn *PubNub) Subscribe() *subscribeBuilder + func (pn *PubNub) Time() *timeBuilder + func (pn *PubNub) TimeWithContext(ctx Context) *timeBuilder + func (pn *PubNub) Unsubscribe() *unsubscribeBuilder + func (pn *PubNub) UnsubscribeAll() + func (pn *PubNub) WhereNow() *whereNowBuilder + func (pn *PubNub) WhereNowWithContext(ctx Context) *whereNowBuilder + type PublishFileMessageResponse struct + Timestamp int64 + type PublishResponse struct + Timestamp int64 + type ReconnectionManager struct + DoneTimer chan bool + ExponentialMultiplier int + FailedCalls int + Milliseconds int + OnMaxReconnectionExhaustion func() + OnReconnection func() + func (m *ReconnectionManager) HandleOnMaxReconnectionExhaustion(handler func()) + func (m *ReconnectionManager) HandleReconnection(handler func()) + type ReconnectionPolicy int + const PNExponentialPolicy + const PNLinearPolicy + const PNNonePolicy + type RemoveAllPushChannelsForDeviceResponse struct + type RemoveChannelFromChannelGroupResponse struct + type RemoveChannelsFromPushResponse struct + type RequestWorkers struct + MaxWorkers int + Sem chan bool + Workers []Worker + WorkersChannel chan chan *JobQItem + func (p *RequestWorkers) Close() + func (p *RequestWorkers) ReadQueue(pubnub *PubNub) + func (p *RequestWorkers) Start(pubnub *PubNub, ctx Context) + type ResourcePermissions struct + Create bool + Delete bool + Manage bool + Read bool + Write bool + type ResponseInfo struct + AuthKey string + Operation OperationType + Origin string + OriginalResponse *http.Response + StatusCode int + TLSEnabled bool + UUID string + type SetChannelMetadataBody struct + Custom map[string]interface{} + Description string + Name string + type SetStateResponse struct + Message string + State interface{} + type SetUUIDMetadataBody struct + Custom map[string]interface{} + Email string + ExternalID string + Name string + ProfileURL string + type SignalResponse struct + Timestamp int64 + type StateManager struct + type StateOperation struct + type StatusCategory int + const PNAccessDeniedCategory + const PNAcknowledgmentCategory + const PNBadRequestCategory + const PNCancelledCategory + const PNConnectedCategory + const PNDisconnectedCategory + const PNLoopStopCategory + const PNNoStubMatchedCategory + const PNReconnectedCategory + const PNReconnectionAttemptsExhausted + const PNRequestMessageCountExceededCategory + const PNTimeoutCategory + const PNUnknownCategory + func (c StatusCategory) String() string + type StatusResponse struct + AdditionalData interface{} + AffectedChannelGroups []string + AffectedChannels []string + AuthKey string + Category StatusCategory + Error error + Operation OperationType + Origin string + OriginalResponse string + Request string + StatusCode int + TLSEnabled bool + UUID string + type SubscribeOperation struct + ChannelGroups []string + Channels []string + FilterExpression string + PresenceEnabled bool + QueryParam map[string]string + State map[string]interface{} + Timetoken int64 + type SubscriptionItem struct + type SubscriptionManager struct + func (m *SubscriptionManager) AddListener(listener *Listener) + func (m *SubscriptionManager) Destroy() + func (m *SubscriptionManager) Disconnect() + func (m *SubscriptionManager) GetListeners() map[*Listener]bool + func (m *SubscriptionManager) RemoveAllListeners() + func (m *SubscriptionManager) RemoveListener(listener *Listener) + type TelemetryManager struct + IsRunning bool + func (m *TelemetryManager) CleanUpTelemetryData() + func (m *TelemetryManager) OperationLatency() map[string]string + func (m *TelemetryManager) StoreLatency(latency float64, t OperationType) + type TimeResponse struct + Timetoken int64 + type TokenManager struct + Tokens GrantResourcesWithPermissions + func (m *TokenManager) CleanUp() + func (m *TokenManager) GetAllTokens() GrantResourcesWithPermissions + func (m *TokenManager) GetToken(resourceID string, resourceType PNResourceType) string + func (m *TokenManager) GetTokensByResource(resourceType PNResourceType) GrantResourcesWithPermissions + func (m *TokenManager) SetAuthParan(q *url.Values, resourceID string, resourceType PNResourceType) + func (m *TokenManager) StoreToken(token string) + func (m *TokenManager) StoreTokens(token []string) + type UnsubscribeOperation struct + ChannelGroups []string + Channels []string + QueryParam map[string]string + type UserSpacePermissions struct + Create bool + Delete bool + Manage bool + Read bool + Write bool + type UserSpacePermissionsWithToken struct + BitMaskPerms int64 + Permissions UserSpacePermissions + TTL int + Timestamp int64 + Token string + type WhereNowResponse struct + Channels []string + type Worker struct + JobChannel chan *JobQItem + WorkersChannel chan chan *JobQItem + func (pw Worker) Process(pubnub *PubNub) Other modules containing this package github.com/crimsonred/go