event

Documentation

Index

• Constants
• Variables
• func EmitInvite(bus event.Bus, action string, chat entity.ChatInfo)
• func EmitMessageChange(bus event.Bus, status entity.Status, msgID string)
• func EmitNewMessage(bus event.Bus, msg entity.Message)
• type ChatEvent
• type ChatEventGroup
  • func NewChatEventGroup() ChatEventGroup
• type ChatEventObj
• type Empty
• type EvtObject
  • func (e EvtObject[A, P]) Action() A
  • func (e EvtObject[A, P]) Group() string
  • func (e EvtObject[A, P]) Name() string
  • func (e EvtObject[A, P]) Payload() P
• type ExternalEvent
• type ExternalEventObj
• type IEvent
  • func NewEvtObj[A any, P any](n string, g string, a A, p P) IEvent[A, P]
• type IEventGroup
• type MessageEvent
• type MessageEventGroup
  • func NewMessagingEventGroup() MessageEventGroup
• type MessageEventObj
• type Publishable

Constants

const ChangeStatus = "ChangeStatus"

const ChatGroup = "ChatEvent"

Event group name

const Invite = "INVITE"

Event Names

const InviteReceived = "RECEIVED"

const InviteSent = "SENT"

Event Actions

const MessageGroup = "messaging"

const NewMessage = "NewMessage"

Variables

var ChatEG = NewChatEventGroup()

var ErrNotSupported = errors.New("not implemented")

var MessagingEG = NewMessagingEventGroup()

var NewChatEvent = NewEvtObj[string, interface{}]

var NewExternalEvent = NewEvtObj[string, string]

var NewMessageEvent = NewEvtObj[entity.Status, interface{}]

Functions

func EmitInvite

func EmitInvite(bus event.Bus, action string, chat entity.ChatInfo)

func EmitMessageChange

func EmitMessageChange(bus event.Bus, status entity.Status, msgID string)

func EmitNewMessage

func EmitNewMessage(bus event.Bus, msg entity.Message)

Types

type ChatEvent

type ChatEvent = IEvent[string, interface{}]

type ChatEventGroup

type ChatEventGroup = IEventGroup[string, interface{}]

func NewChatEventGroup

func NewChatEventGroup() ChatEventGroup

type ChatEventObj

type ChatEventObj = EvtObject[string, interface{}]

type Empty

type Empty struct{}

type EvtObject

type EvtObject[A any, P any] struct {
	// contains filtered or unexported fields
}

func (EvtObject[A, P]) Action

func (e EvtObject[A, P]) Action() A

func (EvtObject[A, P]) Group

func (e EvtObject[A, P]) Group() string

func (EvtObject[A, P]) Name

func (e EvtObject[A, P]) Name() string

func (EvtObject[A, P]) Payload

func (e EvtObject[A, P]) Payload() P

type ExternalEvent

type ExternalEvent = IEvent[string, string]

type ExternalEventObj

type ExternalEventObj = EvtObject[string, string]

type IEvent

type IEvent[A any, P any] interface {
	Name() string
	Group() string
	Action() A
	Payload() P
}

func NewEvtObj

func NewEvtObj[A any, P any](n string, g string, a A, p P) IEvent[A, P]

type IEventGroup

type IEventGroup[A any, P any] interface {
	NewEvent(name string, action A, payload P) (IEvent[A, P], error)
	Validate(IEvent[A, P]) bool
}

type MessageEvent

type MessageEvent = IEvent[entity.Status, interface{}]

type MessageEventGroup

type MessageEventGroup = IEventGroup[entity.Status, interface{}]

func NewMessagingEventGroup

func NewMessagingEventGroup() MessageEventGroup

type MessageEventObj

type MessageEventObj = EvtObject[entity.Status, interface{}]

type Publishable

type Publishable interface {
	Cast() ExternalEvent
}