core

Documentation

Index

• type FilterMessage
  • func (f FilterMessage) Filter(operator string) (string, map[string]interface{})
  • func (f FilterMessage) Page() string
  • func (f FilterMessage) Sort() string
• type FilterSubscriber
  • func (f FilterSubscriber) Filter(operator string) (string, map[string]interface{})
• type FilterTopic
  • func (f FilterTopic) Filter(operator string) (string, map[string]interface{})
• type Message
• type MessageStatus
• type Messages
  • func (messages Messages) Ids() []uuid.UUID
• type Subscriber
  • func (s Subscriber) Bucket() string
• type SubscriberOpt
• type Subscribers
  • func (subscribers Subscribers) MapByTopic() map[uuid.UUID]Subscribers
• type Topic
  • func (t Topic) Empty() bool
• type Topics
  • func (topics Topics) Ids() []uuid.UUID

Types

type FilterMessage

type FilterMessage struct {
	TopicId       []uuid.UUID
	Status        []MessageStatus
	SortBy        string
	SortDirection string
	Offset        int
	Limit         int
}

func (FilterMessage) Filter

func (f FilterMessage) Filter(operator string) (string, map[string]interface{})

func (FilterMessage) Page

func (f FilterMessage) Page() string

func (FilterMessage) Sort

func (f FilterMessage) Sort() string

type FilterSubscriber

type FilterSubscriber struct {
	TopicId     []uuid.UUID
	Name        []string
	WithDeleted bool
}

func (FilterSubscriber) Filter

func (f FilterSubscriber) Filter(operator string) (string, map[string]interface{})

type FilterTopic

type FilterTopic struct {
	Name        []string
	WithDeleted bool
}

func (FilterTopic) Filter

func (f FilterTopic) Filter(operator string) (string, map[string]interface{})

type Message

type Message struct {
	Id        uuid.UUID     `db:"id"`
	TopicId   uuid.UUID     `db:"topic_id"`
	Message   string        `db:"message"`
	Status    MessageStatus `db:"status"`
	CreatedAt string        `db:"created_at"`
}

type MessageStatus

type MessageStatus string

const (
	MessageStatusWaiting   MessageStatus = "waiting"
	MessageStatusDelivered MessageStatus = "delivered"
)

type Messages

type Messages []Message

func (Messages) Ids

func (messages Messages) Ids() []uuid.UUID

type Subscriber

type Subscriber struct {
	Id        uuid.UUID       `db:"id"`
	TopicId   uuid.UUID       `db:"topic_id"`
	TopicName string          `db:"topic_name"`
	Name      string          `db:"name"`
	Option    json.RawMessage `db:"option"`
	CreatedAt string          `db:"created_at"`
	DeletedAt null.String     `db:"deleted_at"`
}

func (Subscriber) Bucket

func (s Subscriber) Bucket() string

type SubscriberOpt

type SubscriberOpt struct {
	MaxAttempts        int    `json:"max_attempts"`
	VisibilityDuration string `json:"visibility_duration"`
}

type Subscribers

type Subscribers []Subscriber

func (Subscribers) MapByTopic

func (subscribers Subscribers) MapByTopic() map[uuid.UUID]Subscribers

type Topic

type Topic struct {
	Id        uuid.UUID   `db:"id"`
	Name      string      `db:"name"`
	CreatedAt string      `db:"created_at"`
	DeletedAt null.String `db:"deleted_at"`
}

func (Topic) Empty

func (t Topic) Empty() bool

type Topics

type Topics []Topic

func (Topics) Ids

func (topics Topics) Ids() []uuid.UUID