msgdump

Documentation

Index

• func DirForNetwork(dir string, nn gpbft.NetworkName) string
• type GMessageEnvelope
• type PJustification
• type PMessage
• type PPayload
• type ParquetEnvelope
  • func ToParquet(gme GMessageEnvelope) (ParquetEnvelope, error)
• type ParquetWriter
  • func NewParquetWriter[T any](path string) (*ParquetWriter[T], error)
  • func (pw *ParquetWriter[T]) Close() error
  • func (pw *ParquetWriter[T]) Rotate() error
  • func (pw *ParquetWriter[T]) Write(row T) (int, error)
  • func (pw *ParquetWriter[T]) WriteRows(rows []T) (int, error)

Functions

func DirForNetwork

func DirForNetwork(dir string, nn gpbft.NetworkName) string

Types

type GMessageEnvelope

type GMessageEnvelope struct {
	UnixMicroTime int64
	NetworkName   string
	Message       gpbft.GMessage
}

type PJustification

type PJustification struct {
	Vote      PPayload
	Signers   []uint64
	Signature []byte
}

type PMessage

type PMessage struct {
	Sender        gpbft.ActorID
	Vote          PPayload
	Signature     []byte
	Ticket        gpbft.Ticket
	Justification *PJustification
}

type PPayload

type PPayload struct {
	Instance         uint64
	Round            uint64
	Phase            string `parquet:"Phase,enum"`
	SupplementalData gpbft.SupplementalData
	Value            gpbft.ECChain
}

type ParquetEnvelope

type ParquetEnvelope struct {
	TimestampMicro int64 `parquet:"TimestampMicro,timestamp(microsecond)"`
	NetworkName    string
	Message        PMessage
}

func ToParquet

func ToParquet(gme GMessageEnvelope) (ParquetEnvelope, error)

type ParquetWriter

type ParquetWriter[T any] struct {
	// contains filtered or unexported fields
}

func NewParquetWriter

func NewParquetWriter[T any](path string) (*ParquetWriter[T], error)

func (*ParquetWriter[T]) Close

func (pw *ParquetWriter[T]) Close() error

func (*ParquetWriter[T]) Rotate

func (pw *ParquetWriter[T]) Rotate() error

func (*ParquetWriter[T]) Write

func (pw *ParquetWriter[T]) Write(row T) (int, error)

func (*ParquetWriter[T]) WriteRows

func (pw *ParquetWriter[T]) WriteRows(rows []T) (int, error)