payload

Documentation

Index

• Constants
• type CompressedWriter
  • func NewCompressedWriter(brFile *os.File) *CompressedWriter
  • func (w *CompressedWriter) Close() error
  • func (w *CompressedWriter) WriteObject(events model.Object, unmarshalled Unmarshalled) error
  • func (w *CompressedWriter) WriteString(data string) error
• type EventsUnmarshalled
• type FileInfo
• type FileType
• type MessagesUnmarshalled
• type PayloadManager
  • func NewPayloadManager(ctx context.Context, filenamePrefix string) (*PayloadManager, error)
  • func (pm *PayloadManager) Close()
  • func (pm *PayloadManager) GetFile(fileType FileType) *os.File
  • func (pm *PayloadManager) NewChunkedFile(ctx context.Context, filenamePrefix string) error
  • func (pm *PayloadManager) ReportPayloadSizes() error
  • func (pm *PayloadManager) SeekStart(ctx context.Context)
• type ResourcesUnmarshalled
• type Unmarshalled
• type WebSocketEventsUnmarshalled

Constants

const BROTLI_COMPRESSION_LEVEL = 5

Types

type CompressedWriter

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

func NewCompressedWriter

func NewCompressedWriter(brFile *os.File) *CompressedWriter

Initializes a new writer with the configured compression level

func (*CompressedWriter) Close

func (w *CompressedWriter) Close() error

Appends a closing bracket to close the JSON array, and closes the underlying writer

func (*CompressedWriter) WriteObject

func (w *CompressedWriter) WriteObject(events model.Object, unmarshalled Unmarshalled) error

Merges the inner contents of the input events objects into a large JSON array

func (*CompressedWriter) WriteString

func (w *CompressedWriter) WriteString(data string) error

type EventsUnmarshalled

type EventsUnmarshalled struct {
	Events []interface{}
}

type FileInfo

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

type FileType

type FileType string

const (
	EventsCompressed          FileType = "EventsCompressed"
	ResourcesCompressed       FileType = "ResourcesCompressed"
	WebSocketEventsCompressed FileType = "WebSocketEventsCompressed"
	EventsChunked             FileType = "EventsChunked"
	TimelineIndicatorEvents   FileType = "TimelineIndicatorEvents"
)

type MessagesUnmarshalled

type MessagesUnmarshalled struct {
	Messages []interface{}
}

type PayloadManager

type PayloadManager struct {
	EventsCompressed          *CompressedWriter
	ResourcesCompressed       *CompressedWriter
	WebSocketEventsCompressed *CompressedWriter
	EventsChunked             *CompressedWriter
	TimelineIndicatorEvents   *CompressedWriter
	ChunkIndex                int
	// contains filtered or unexported fields
}

func NewPayloadManager

func NewPayloadManager(ctx context.Context, filenamePrefix string) (*PayloadManager, error)

func (*PayloadManager) Close

func (pm *PayloadManager) Close()

func (*PayloadManager) GetFile

func (pm *PayloadManager) GetFile(fileType FileType) *os.File

func (*PayloadManager) NewChunkedFile

func (pm *PayloadManager) NewChunkedFile(ctx context.Context, filenamePrefix string) error

func (*PayloadManager) ReportPayloadSizes

func (pm *PayloadManager) ReportPayloadSizes() error

func (*PayloadManager) SeekStart

func (pm *PayloadManager) SeekStart(ctx context.Context)

Reset file pointers to beginning of file for reading

type ResourcesUnmarshalled

type ResourcesUnmarshalled struct {
	Resources []interface{}
}

type Unmarshalled

type Unmarshalled interface {
	// contains filtered or unexported methods
}

type WebSocketEventsUnmarshalled

type WebSocketEventsUnmarshalled struct {
	WebSocketEvents []interface{}
}