publisher

package
v0.0.0-...-bc28a72 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

This package holds the publisher interface implementations

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPublish        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPublish          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPublish = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ExternalChannelAccessType_name = map[int32]string{
	0: "Add",
	1: "Remove",
}
View Source 
var ExternalChannelAccessType_value = map[string]int32{
	"Add":    0,
	"Remove": 1,
}
View Source 
var ExternalChannelPresenceType_name = map[int32]string{
	0: "Join",
	1: "Leave",
}
View Source 
var ExternalChannelPresenceType_value = map[string]int32{
	"Join":  0,
	"Leave": 1,
}
View Source 
var ExternalNewEventType_name = map[int32]string{
	0: "OnlineStatus",
	1: "ChannelEvent",
	2: "ChannelPresence",
	3: "ChannelAccess",
}
View Source 
var ExternalNewEventType_value = map[string]int32{
	"OnlineStatus":    0,
	"ChannelEvent":    1,
	"ChannelPresence": 2,
	"ChannelAccess":   3,
}

Functions

This section is empty.

Types

type EmptyPublisher 

type EmptyPublisher struct{}

func NewEmptyPublisher 

func NewEmptyPublisher() *EmptyPublisher

func (*EmptyPublisher) PublishChannelAccessChange 

func (publisher *EmptyPublisher) PublishChannelAccessChange(appID string, channelID string, clientID string, isAdd bool)

func (*EmptyPublisher) PublishChannelEvent 

func (publisher *EmptyPublisher) PublishChannelEvent(appID string, channelID string, channelEvent *core.ChannelEvent)

func (*EmptyPublisher) PublishChannelOnlineChange 

func (publisher *EmptyPublisher) PublishChannelOnlineChange(appID string, channelID string, statusUpdate *core.OnlineStatusUpdate)

func (*EmptyPublisher) PublishChannelPresenceChange 

func (publisher *EmptyPublisher) PublishChannelPresenceChange(appID string, channelID string, clientID string, isJoin bool)

func (*EmptyPublisher) Subscribe 

func (publisher *EmptyPublisher) Subscribe(appID string, channelID string)

func (*EmptyPublisher) Unsubscribe 

func (publisher *EmptyPublisher) Unsubscribe(appID string, channelID string)

type ExternalChannelAccessEvent 

type ExternalChannelAccessEvent struct {
	ExternalAccessType   ExternalChannelAccessType `protobuf:"varint,1,opt,name=externalAccessType,proto3,enum=ExternalChannelAccessType" json:"externalAccessType,omitempty"`
	ClientID             string                    `protobuf:"bytes,2,opt,name=clientID,proto3" json:"clientID,omitempty"`
	ChannelID            string                    `protobuf:"bytes,3,opt,name=channelID,proto3" json:"channelID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExternalChannelAccessEvent) Descriptor 

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

func (*ExternalChannelAccessEvent) GetChannelID 

func (m *ExternalChannelAccessEvent) GetChannelID() string

func (*ExternalChannelAccessEvent) GetClientID 

func (m *ExternalChannelAccessEvent) GetClientID() string

func (*ExternalChannelAccessEvent) GetExternalAccessType 

func (m *ExternalChannelAccessEvent) GetExternalAccessType() ExternalChannelAccessType

func (*ExternalChannelAccessEvent) Marshal 

func (m *ExternalChannelAccessEvent) Marshal() (dAtA []byte, err error)

func (*ExternalChannelAccessEvent) MarshalTo 

func (m *ExternalChannelAccessEvent) MarshalTo(dAtA []byte) (int, error)

func (*ExternalChannelAccessEvent) MarshalToSizedBuffer 

func (m *ExternalChannelAccessEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExternalChannelAccessEvent) ProtoMessage 

func (*ExternalChannelAccessEvent) ProtoMessage()

func (*ExternalChannelAccessEvent) Reset 

func (m *ExternalChannelAccessEvent) Reset()

func (*ExternalChannelAccessEvent) Size 

func (m *ExternalChannelAccessEvent) Size() (n int)

func (*ExternalChannelAccessEvent) String 

func (m *ExternalChannelAccessEvent) String() string

func (*ExternalChannelAccessEvent) Unmarshal 

func (m *ExternalChannelAccessEvent) Unmarshal(dAtA []byte) error

func (*ExternalChannelAccessEvent) XXX_DiscardUnknown 

func (m *ExternalChannelAccessEvent) XXX_DiscardUnknown()

func (*ExternalChannelAccessEvent) XXX_Marshal 

func (m *ExternalChannelAccessEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalChannelAccessEvent) XXX_Merge 

func (m *ExternalChannelAccessEvent) XXX_Merge(src proto.Message)

func (*ExternalChannelAccessEvent) XXX_Size 

func (m *ExternalChannelAccessEvent) XXX_Size() int

func (*ExternalChannelAccessEvent) XXX_Unmarshal 

func (m *ExternalChannelAccessEvent) XXX_Unmarshal(b []byte) error

type ExternalChannelAccessType 

type ExternalChannelAccessType int32
const (
	ExternalChannelAccessType_Add    ExternalChannelAccessType = 0
	ExternalChannelAccessType_Remove ExternalChannelAccessType = 1
)

func (ExternalChannelAccessType) EnumDescriptor 

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

func (ExternalChannelAccessType) String 

func (x ExternalChannelAccessType) String() string

type ExternalChannelPresenceType 

type ExternalChannelPresenceType int32
const (
	ExternalChannelPresenceType_Join  ExternalChannelPresenceType = 0
	ExternalChannelPresenceType_Leave ExternalChannelPresenceType = 1
)

func (ExternalChannelPresenceType) EnumDescriptor 

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

func (ExternalChannelPresenceType) String 

func (x ExternalChannelPresenceType) String() string

type ExternalJoinLeaveClientEvent 

type ExternalJoinLeaveClientEvent struct {
	ClientID             string                      `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	ChannelID            string                      `protobuf:"bytes,2,opt,name=channelID,proto3" json:"channelID,omitempty"`
	PresenceType         ExternalChannelPresenceType `protobuf:"varint,3,opt,name=presenceType,proto3,enum=ExternalChannelPresenceType" json:"presenceType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ExternalJoinLeaveClientEvent) Descriptor 

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

func (*ExternalJoinLeaveClientEvent) GetChannelID 

func (m *ExternalJoinLeaveClientEvent) GetChannelID() string

func (*ExternalJoinLeaveClientEvent) GetClientID 

func (m *ExternalJoinLeaveClientEvent) GetClientID() string

func (*ExternalJoinLeaveClientEvent) GetPresenceType 

func (m *ExternalJoinLeaveClientEvent) GetPresenceType() ExternalChannelPresenceType

func (*ExternalJoinLeaveClientEvent) Marshal 

func (m *ExternalJoinLeaveClientEvent) Marshal() (dAtA []byte, err error)

func (*ExternalJoinLeaveClientEvent) MarshalTo 

func (m *ExternalJoinLeaveClientEvent) MarshalTo(dAtA []byte) (int, error)

func (*ExternalJoinLeaveClientEvent) MarshalToSizedBuffer 

func (m *ExternalJoinLeaveClientEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExternalJoinLeaveClientEvent) ProtoMessage 

func (*ExternalJoinLeaveClientEvent) ProtoMessage()

func (*ExternalJoinLeaveClientEvent) Reset 

func (m *ExternalJoinLeaveClientEvent) Reset()

func (*ExternalJoinLeaveClientEvent) Size 

func (m *ExternalJoinLeaveClientEvent) Size() (n int)

func (*ExternalJoinLeaveClientEvent) String 

func (m *ExternalJoinLeaveClientEvent) String() string

func (*ExternalJoinLeaveClientEvent) Unmarshal 

func (m *ExternalJoinLeaveClientEvent) Unmarshal(dAtA []byte) error

func (*ExternalJoinLeaveClientEvent) XXX_DiscardUnknown 

func (m *ExternalJoinLeaveClientEvent) XXX_DiscardUnknown()

func (*ExternalJoinLeaveClientEvent) XXX_Marshal 

func (m *ExternalJoinLeaveClientEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalJoinLeaveClientEvent) XXX_Merge 

func (m *ExternalJoinLeaveClientEvent) XXX_Merge(src proto.Message)

func (*ExternalJoinLeaveClientEvent) XXX_Size 

func (m *ExternalJoinLeaveClientEvent) XXX_Size() int

func (*ExternalJoinLeaveClientEvent) XXX_Unmarshal 

func (m *ExternalJoinLeaveClientEvent) XXX_Unmarshal(b []byte) error

type ExternalNewEvent 

type ExternalNewEvent struct {
	Type                 ExternalNewEventType          `protobuf:"varint,1,opt,name=type,proto3,enum=ExternalNewEventType" json:"type,omitempty"`
	ServerID             string                        `protobuf:"bytes,2,opt,name=serverID,proto3" json:"serverID,omitempty"`
	ExternalPublishEvent *ExternalPublishEvent         `protobuf:"bytes,3,opt,name=externalPublishEvent,proto3" json:"externalPublishEvent,omitempty"`
	ExternalOnlineStatus *ExternalOnlineStatusEvent    `protobuf:"bytes,4,opt,name=externalOnlineStatus,proto3" json:"externalOnlineStatus,omitempty"`
	ExternalJoinLeave    *ExternalJoinLeaveClientEvent `protobuf:"bytes,5,opt,name=externalJoinLeave,proto3" json:"externalJoinLeave,omitempty"`
	ExternalAccessEvent  *ExternalChannelAccessEvent   `protobuf:"bytes,6,opt,name=externalAccessEvent,proto3" json:"externalAccessEvent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ExternalNewEvent) Descriptor 

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

func (*ExternalNewEvent) GetExternalAccessEvent 

func (m *ExternalNewEvent) GetExternalAccessEvent() *ExternalChannelAccessEvent

func (*ExternalNewEvent) GetExternalJoinLeave 

func (m *ExternalNewEvent) GetExternalJoinLeave() *ExternalJoinLeaveClientEvent

func (*ExternalNewEvent) GetExternalOnlineStatus 

func (m *ExternalNewEvent) GetExternalOnlineStatus() *ExternalOnlineStatusEvent

func (*ExternalNewEvent) GetExternalPublishEvent 

func (m *ExternalNewEvent) GetExternalPublishEvent() *ExternalPublishEvent

func (*ExternalNewEvent) GetServerID 

func (m *ExternalNewEvent) GetServerID() string

func (*ExternalNewEvent) GetType 

func (m *ExternalNewEvent) GetType() ExternalNewEventType

func (*ExternalNewEvent) Marshal 

func (m *ExternalNewEvent) Marshal() (dAtA []byte, err error)

func (*ExternalNewEvent) MarshalTo 

func (m *ExternalNewEvent) MarshalTo(dAtA []byte) (int, error)

func (*ExternalNewEvent) MarshalToSizedBuffer 

func (m *ExternalNewEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExternalNewEvent) ProtoMessage 

func (*ExternalNewEvent) ProtoMessage()

func (*ExternalNewEvent) Reset 

func (m *ExternalNewEvent) Reset()

func (*ExternalNewEvent) Size 

func (m *ExternalNewEvent) Size() (n int)

func (*ExternalNewEvent) String 

func (m *ExternalNewEvent) String() string

func (*ExternalNewEvent) Unmarshal 

func (m *ExternalNewEvent) Unmarshal(dAtA []byte) error

func (*ExternalNewEvent) XXX_DiscardUnknown 

func (m *ExternalNewEvent) XXX_DiscardUnknown()

func (*ExternalNewEvent) XXX_Marshal 

func (m *ExternalNewEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalNewEvent) XXX_Merge 

func (m *ExternalNewEvent) XXX_Merge(src proto.Message)

func (*ExternalNewEvent) XXX_Size 

func (m *ExternalNewEvent) XXX_Size() int

func (*ExternalNewEvent) XXX_Unmarshal 

func (m *ExternalNewEvent) XXX_Unmarshal(b []byte) error

type ExternalNewEventType 

type ExternalNewEventType int32
const (
	ExternalNewEventType_OnlineStatus    ExternalNewEventType = 0
	ExternalNewEventType_ChannelEvent    ExternalNewEventType = 1
	ExternalNewEventType_ChannelPresence ExternalNewEventType = 2
	ExternalNewEventType_ChannelAccess   ExternalNewEventType = 3
)

func (ExternalNewEventType) EnumDescriptor 

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

func (ExternalNewEventType) String 

func (x ExternalNewEventType) String() string

type ExternalOnlineStatusEvent 

type ExternalOnlineStatusEvent struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	Status               bool     `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Timestamp            int64    `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExternalOnlineStatusEvent) Descriptor 

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

func (*ExternalOnlineStatusEvent) GetClientID 

func (m *ExternalOnlineStatusEvent) GetClientID() string

func (*ExternalOnlineStatusEvent) GetStatus 

func (m *ExternalOnlineStatusEvent) GetStatus() bool

func (*ExternalOnlineStatusEvent) GetTimestamp 

func (m *ExternalOnlineStatusEvent) GetTimestamp() int64

func (*ExternalOnlineStatusEvent) Marshal 

func (m *ExternalOnlineStatusEvent) Marshal() (dAtA []byte, err error)

func (*ExternalOnlineStatusEvent) MarshalTo 

func (m *ExternalOnlineStatusEvent) MarshalTo(dAtA []byte) (int, error)

func (*ExternalOnlineStatusEvent) MarshalToSizedBuffer 

func (m *ExternalOnlineStatusEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExternalOnlineStatusEvent) ProtoMessage 

func (*ExternalOnlineStatusEvent) ProtoMessage()

func (*ExternalOnlineStatusEvent) Reset 

func (m *ExternalOnlineStatusEvent) Reset()

func (*ExternalOnlineStatusEvent) Size 

func (m *ExternalOnlineStatusEvent) Size() (n int)

func (*ExternalOnlineStatusEvent) String 

func (m *ExternalOnlineStatusEvent) String() string

func (*ExternalOnlineStatusEvent) Unmarshal 

func (m *ExternalOnlineStatusEvent) Unmarshal(dAtA []byte) error

func (*ExternalOnlineStatusEvent) XXX_DiscardUnknown 

func (m *ExternalOnlineStatusEvent) XXX_DiscardUnknown()

func (*ExternalOnlineStatusEvent) XXX_Marshal 

func (m *ExternalOnlineStatusEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalOnlineStatusEvent) XXX_Merge 

func (m *ExternalOnlineStatusEvent) XXX_Merge(src proto.Message)

func (*ExternalOnlineStatusEvent) XXX_Size 

func (m *ExternalOnlineStatusEvent) XXX_Size() int

func (*ExternalOnlineStatusEvent) XXX_Unmarshal 

func (m *ExternalOnlineStatusEvent) XXX_Unmarshal(b []byte) error

type ExternalPublishEvent 

type ExternalPublishEvent struct {
	SenderID             string   `protobuf:"bytes,1,opt,name=senderID,proto3" json:"senderID,omitempty"`
	EventType            string   `protobuf:"bytes,2,opt,name=eventType,proto3" json:"eventType,omitempty"`
	Payload              string   `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Timestamp            int64    `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExternalPublishEvent) Descriptor 

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

func (*ExternalPublishEvent) GetEventType 

func (m *ExternalPublishEvent) GetEventType() string

func (*ExternalPublishEvent) GetPayload 

func (m *ExternalPublishEvent) GetPayload() string

func (*ExternalPublishEvent) GetSenderID 

func (m *ExternalPublishEvent) GetSenderID() string

func (*ExternalPublishEvent) GetTimestamp 

func (m *ExternalPublishEvent) GetTimestamp() int64

func (*ExternalPublishEvent) Marshal 

func (m *ExternalPublishEvent) Marshal() (dAtA []byte, err error)

func (*ExternalPublishEvent) MarshalTo 

func (m *ExternalPublishEvent) MarshalTo(dAtA []byte) (int, error)

func (*ExternalPublishEvent) MarshalToSizedBuffer 

func (m *ExternalPublishEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExternalPublishEvent) ProtoMessage 

func (*ExternalPublishEvent) ProtoMessage()

func (*ExternalPublishEvent) Reset 

func (m *ExternalPublishEvent) Reset()

func (*ExternalPublishEvent) Size 

func (m *ExternalPublishEvent) Size() (n int)

func (*ExternalPublishEvent) String 

func (m *ExternalPublishEvent) String() string

func (*ExternalPublishEvent) Unmarshal 

func (m *ExternalPublishEvent) Unmarshal(dAtA []byte) error

func (*ExternalPublishEvent) XXX_DiscardUnknown 

func (m *ExternalPublishEvent) XXX_DiscardUnknown()

func (*ExternalPublishEvent) XXX_Marshal 

func (m *ExternalPublishEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalPublishEvent) XXX_Merge 

func (m *ExternalPublishEvent) XXX_Merge(src proto.Message)

func (*ExternalPublishEvent) XXX_Size 

func (m *ExternalPublishEvent) XXX_Size() int

func (*ExternalPublishEvent) XXX_Unmarshal 

func (m *ExternalPublishEvent) XXX_Unmarshal(b []byte) error

type RedisPublisher 

type RedisPublisher struct {
	// contains filtered or unexported fields
}

RedisPublisher - Implementation of PublishHandler interface

func NewRedisPublisher 

func NewRedisPublisher() *RedisPublisher

NewRedisPublisher - Create a new instance of redis publisher

func (*RedisPublisher) PublishChannelAccessChange 

func (publisher *RedisPublisher) PublishChannelAccessChange(appID string, channelID string, clientID string, isAdd bool)

func (*RedisPublisher) PublishChannelEvent 

func (publisher *RedisPublisher) PublishChannelEvent(appID string, channelID string, channelEvent *core.ChannelEvent)

PublishChannelEvent - Send event for other servers listening for this event

func (*RedisPublisher) PublishChannelOnlineChange 

func (publisher *RedisPublisher) PublishChannelOnlineChange(appID string, channelID string, statusUpdate *core.OnlineStatusUpdate)

PublishChannelOnlineChange - Publish Online status change to other servers

func (*RedisPublisher) PublishChannelPresenceChange 

func (publisher *RedisPublisher) PublishChannelPresenceChange(appID string, channelID string, clientID string, isJoin bool)

func (*RedisPublisher) Subscribe 

func (publisher *RedisPublisher) Subscribe(appID string, channelID string)

Subscribe - Subscribe to a channel in redis

func (*RedisPublisher) Unsubscribe 

func (publisher *RedisPublisher) Unsubscribe(appID string, channelID string)

Unsubscribe - Unsubscribe from a channel in redis

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.