stream

package
v1.8.1 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const STREAM_STATE_NONE = 0
View Source 
const STREAM_STATE_RUNNING = 2
View Source 
const STREAM_STATE_STARTING = 1
View Source 
const STREAM_STATE_STOPPING = 3

Variables

This section is empty.

Functions

func ValidateStreamIteratorRequest 

func ValidateStreamIteratorRequest(ctx context.Context, data []byte) error

Types

type CloseRecordsIteratorResponse 

type CloseRecordsIteratorResponse struct {
	Status             string             `json:"status"`
	Message            string             `json:"message"`
	StreamUUID         StreamUUID         `json:"streamUUID"`
	StreamIteratorUUID StreamIteratorUUID `json:"streamIteratorUUID"`
}

type CreateRecordsIteratorResponse 

type CreateRecordsIteratorResponse struct {
	Status             string             `json:"status"`
	Message            string             `json:"message"`
	StreamUUID         StreamUUID         `json:"streamUUID"`
	StreamIteratorUUID StreamIteratorUUID `json:"streamIteratorUUID"`
}

type GetRecordsIteratorStatsResponse 

type GetRecordsIteratorStatsResponse struct {
	Status             string             `json:"status"`
	Message            string             `json:"message"`
	StreamUUID         StreamUUID         `json:"streamUUID"`
	StreamIteratorUUID StreamIteratorUUID `json:"streamIteratorUUID"`
	LastRecordIdRead   MessageId          `json:"lastRecordIdRead"`
	Name               string             `json:"name"`
}

type GetStreamRecordsResponse 

type GetStreamRecordsResponse struct {
	Status             string             `json:"status"`
	Duration           int64              `json:"duration"`
	Count              int64              `json:"count"`
	CountErrors        int64              `json:"countErrors"`
	CountSkipped       int64              `json:"countSkipped"`
	Remain             bool               `json:"remain"`
	LastRecordIdRead   MessageId          `json:"lastRecordIdRead"`
	StreamUUID         StreamUUID         `json:"streamUUID"`
	StreamIteratorUUID StreamIteratorUUID `json:"streamIteratorUUID"`
	Records            []interface{}      `json:"records"`
}

type LoginAccountResponse 

type LoginAccountResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
	JWT     string `json:"jwt"`
}

type LoginUserResponse 

type LoginUserResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
	JWT     string `json:"jwt"`
}

type PutStreamRecordsResponse 

type PutStreamRecordsResponse struct {
	Status     string      `json:"status"`
	StreamUUID StreamUUID  `json:"streamUUID"`
	Duration   int64       `json:"duration"`
	Count      int64       `json:"count"`
	MessageIds []MessageId `json:"messageIds"`
}

type RebuildStreamIndexResponse 

type RebuildStreamIndexResponse struct {
	Status     string      `json:"status"`
	Message    string      `json:"message"`
	StreamUUID StreamUUID  `json:"streamUUID"`
	Duration   int64       `json:"duration"`
	IndexStats interface{} `json:"indexStats"`
}

type Stream 

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

func NewStream 

func NewStream(info *StreamInfo, ingestBuffer *buffering.StreamIngestBuffer, logger *zap.Logger, logVerbosity int) *Stream

func (*Stream) AddIterator 

func (s *Stream) AddIterator(it *StreamIterator) error

func (*Stream) Close 

func (s *Stream) Close() error

func (*Stream) CloseIterator 

func (s *Stream) CloseIterator(iterUUID StreamIteratorUUID) error

func (*Stream) CloseIterators 

func (s *Stream) CloseIterators() error

func (*Stream) GetInfo 

func (s *Stream) GetInfo() *StreamInfo

func (*Stream) GetIterator 

func (s *Stream) GetIterator(iterUUID StreamIteratorUUID) (*StreamIterator, error)

func (*Stream) GetIteratorsCount added in v1.5.0 

func (s *Stream) GetIteratorsCount() int

func (*Stream) GetProperties 

func (s *Stream) GetProperties() *StreamProperties

func (*Stream) GetRecords 

func (s *Stream) GetRecords(c *fasthttp.RequestCtx, iterUUID StreamIteratorUUID, maxRecords uint) (*GetStreamRecordsResponse, error)

func (*Stream) GetUUID 

func (s *Stream) GetUUID() StreamUUID

func (*Stream) Log 

func (s *Stream) Log()

func (*Stream) MatchFilterProperties 

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

func (*Stream) PutMessage 

func (s *Stream) PutMessage(c *fasthttp.RequestCtx, message map[string]interface{}) (MessageId, error)

func (*Stream) PutMessages 

func (s *Stream) PutMessages(c *fasthttp.RequestCtx, records []interface{}) ([]MessageId, error)

func (*Stream) Run 

func (s *Stream) Run()

func (*Stream) SetProperties 

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

func (*Stream) Start 

func (s *Stream) Start() error

func (*Stream) UpdateProperties 

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

type StreamIterator 

type StreamIterator struct {
	LastRecordIdRead MessageId
	Stats            StreamIteratorStats
	// contains filtered or unexported fields
}

func NewStreamIterator 

func NewStreamIterator(streamUUID StreamUUID, iteratorUUID StreamIteratorUUID, r *StreamIteratorRequest, handler IStreamIteratorHandler, logger *zap.Logger) (*StreamIterator, error)

func (*StreamIterator) Close 

func (it *StreamIterator) Close() error

func (*StreamIterator) GetName 

func (it *StreamIterator) GetName() string

func (*StreamIterator) GetRecords 

func (it *StreamIterator) GetRecords(c *fasthttp.RequestCtx, maxRecords uint) (*GetStreamRecordsResponse, error)

func (*StreamIterator) GetUUID 

func (it *StreamIterator) GetUUID() StreamIteratorUUID

func (*StreamIterator) Open 

func (it *StreamIterator) Open() error

func (*StreamIterator) SaveSeek 

func (it *StreamIterator) SaveSeek() error

func (*StreamIterator) Seek 

func (it *StreamIterator) Seek() error

type StreamIteratorMap 

type StreamIteratorMap = map[StreamIteratorUUID]*StreamIterator

type StreamIteratorStats 

type StreamIteratorStats struct {
	BytesRead      int64
	RecordsRead    int64
	RecordsErrors  int64
	RecordsSkipped int64
	RecordsSent    int64
	LastTimeRead   time.Time
}

statistics of an iterator

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.