msgdump

Sep 18, 2024

Changes in this version

type PPayload

+ Phase string

Aug 13, 2024

Changes in this version

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

+ type GMessageEnvelope struct

+ Message gpbft.GMessage

+ NetworkName string

+ UnixMicroTime int64

+ func (t *GMessageEnvelope) MarshalCBOR(w io.Writer) error

+ func (t *GMessageEnvelope) UnmarshalCBOR(r io.Reader) (err error)

+ type GMessageEnvelopeDeffered struct

+ Message cbg.Deferred

+ NetworkName string

+ UnixMicroTime int64

+ func (t *GMessageEnvelopeDeffered) MarshalCBOR(w io.Writer) error

+ func (t *GMessageEnvelopeDeffered) UnmarshalCBOR(r io.Reader) (err error)

+ type PJustification struct

+ Signature []byte

+ Signers []uint64

+ Vote PPayload

+ type PMessage struct

+ Justification *PJustification

+ Sender gpbft.ActorID

+ Signature []byte

+ Ticket gpbft.Ticket

+ Vote PPayload

+ type PPayload struct

+ Instance uint64

+ Round uint64

+ Step string

+ SupplementalData gpbft.SupplementalData

+ Value gpbft.ECChain

+ type ParquetEnvelope struct

+ Message PMessage

+ NetworkName string

+ TimestampMicro int64

+ func ToParquet(gme GMessageEnvelope) (ParquetEnvelope, error)

+ type ParquetWriter struct

+ 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)

+ type Writer struct

+ func (w *Writer[T]) Write(item T) error