objects

Documentation

Overview

TODO(): This code needs to be moved to some other place in pallium. This is

not rest specific code.

Index

• type Content
• type Event
• type ForwardStreamToken
  • func NewForwardStreamToken(o uint64) ForwardStreamToken
  • func (t ForwardStreamToken) String() string
• type InitialSync
• type InitialSyncEvent
• type InitialSyncRoomData
• type PaginationChunk
• type PaginationStreamToken
  • func NewPaginationStreamToken(to, so uint64) PaginationStreamToken
  • func (t PaginationStreamToken) String() string
• type StreamToken
  • func ParseStreamToken(s string) (StreamToken, error)

Types

type Content

type Content map[string]interface{}

type Event

type Event struct {
	EventID   string  `json:"event_id"`
	EventType string  `json:"type"`
	Content   Content `json:"content"`
	RoomID    string  `json:"room_id"`
	UserID    string  `json:"user_id"`
}

type ForwardStreamToken

type ForwardStreamToken struct {
	TopologicalOrder uint64
}

func NewForwardStreamToken

func NewForwardStreamToken(o uint64) ForwardStreamToken

func (ForwardStreamToken) String

func (t ForwardStreamToken) String() string

type InitialSync

type InitialSync struct {
	End      string                `json:"end"`
	Presence []InitialSyncEvent    `json:"presence,omitempty"`
	Rooms    []InitialSyncRoomData `json:"rooms,omitempty"`
}

type InitialSyncEvent

type InitialSyncEvent struct {
	Type    string  `json:"type"`
	Content Content `json:"content"`
}

type InitialSyncRoomData

type InitialSyncRoomData struct {
	Membership string           `json:"membership"`
	RoomID     string           `json:"room_id"`
	Messages   *PaginationChunk `json:"messages,omitempty"`
	State      []Event          `json:"state"`
}

type PaginationChunk

type PaginationChunk struct {
	Start string  `json:"start"`
	End   string  `json:"end"`
	Chunk []Event `json:"chunk"`
}

type PaginationStreamToken

type PaginationStreamToken struct {
	ForwardStreamToken
	StreamingOrder uint64
}

func NewPaginationStreamToken

func NewPaginationStreamToken(to, so uint64) PaginationStreamToken

func (PaginationStreamToken) String

func (t PaginationStreamToken) String() string

type StreamToken

type StreamToken interface {
	String() string
}

func ParseStreamToken

func ParseStreamToken(s string) (StreamToken, error)