types

Documentation

Index

• type DeferedStreamRecord
• type IServer
• type IStreamIteratorHandler
• type MessageId
• type Size64
• type StreamInfo
  • func NewStreamInfo(uuid StreamUUID) *StreamInfo
  • func (s *StreamInfo) MatchFilterProperties(jqFilter *gojq.Query) (bool, error)
  • func (s *StreamInfo) SetProperties(properties *StreamProperties)
  • func (s *StreamInfo) UpdateProperties(properties *StreamProperties)
• type StreamInfoList
• type StreamIteratorRequest
• type StreamIteratorUUID
• type StreamProperties
• type StreamUUID
• type StreamUUIDList

Types

type DeferedStreamRecord

type DeferedStreamRecord struct {
	Id           MessageId   `json:"i"`
	CreationDate time.Time   `json:"d"`
	Msg          interface{} `json:"m"`
}

Defered stream record to be saved

type IServer

type IServer interface {
	Initialize(ctx context.Context) error
	Start() error
	Shutdown() error
	GetWebConfig() *config.WebServerConfig
}

type IStreamIteratorHandler

type IStreamIteratorHandler interface {
	Open() error
	Close() error
	Seek(request *StreamIteratorRequest) error
	SaveSeek() error
	GetNextRecord() (MessageId, interface{}, bool, bool, error)
}

type MessageId

type MessageId = uint64

type Size64

type Size64 = uint64

type StreamInfo

type StreamInfo struct {
	UUID         StreamUUID       `json:"uuid" example:"4ce589e2-b483-467b-8b59-758b339801db"`
	CptMessages  Size64           `json:"cptMessages" example:"12345"`
	SizeInBytes  Size64           `json:"sizeInBytes" example:"4567890"`
	CreationDate time.Time        `json:"creationDate"`
	LastUpdate   time.Time        `json:"lastUpdate"`
	Properties   StreamProperties `json:"properties"`
	LastMsgId    MessageId        `json:"lastMsgId"`
}

func NewStreamInfo

func NewStreamInfo(uuid StreamUUID) *StreamInfo

func (*StreamInfo) MatchFilterProperties

func (s *StreamInfo) MatchFilterProperties(jqFilter *gojq.Query) (bool, error)

func (*StreamInfo) SetProperties

func (s *StreamInfo) SetProperties(properties *StreamProperties)

func (*StreamInfo) UpdateProperties

func (s *StreamInfo) UpdateProperties(properties *StreamProperties)

type StreamInfoList

type StreamInfoList []*StreamInfo

type StreamIteratorRequest

type StreamIteratorRequest struct {
	IteratorType       string    `` /* 135-byte string literal not displayed */
	MessageId          MessageId `json:"messageId"`
	Timestamp          time.Time `json:"timestamp"`
	JqFilter           string    `json:"jqFilter"`
	MaxWaitTimeSeconds int       `json:"maxWaitTimeSeconds"`
	Name               string    `json:"name"`
}

type StreamIteratorUUID

type StreamIteratorUUID = uuid.UUID

type StreamProperties

type StreamProperties = map[string]interface{}

type StreamUUID

type StreamUUID = uuid.UUID

type StreamUUIDList

type StreamUUIDList []StreamUUID