Documentation ¶
Index ¶
- Variables
- type Writer
- func (w *Writer) Bootstrap(ctx context.Context, conns *servicesconn.Connections, persist idb.Persist) error
- func (w *Writer) Consume(ctx context.Context, conns *servicesconn.Connections, c services.Consumable, ...) error
- func (w *Writer) ConsumeConsensus(_ context.Context, _ *servicesconn.Connections, _ services.Consumable, ...) error
- func (w *Writer) InsertTransactionBlock(ctx services.ConsumerCtx, txID ids.ID, blkTxID ids.ID) error
- func (w *Writer) InsertTransactionValidator(ctx services.ConsumerCtx, txID ids.ID, validator platformvm.Validator) error
- func (*Writer) Name() string
- func (w *Writer) ParseJSON(txBytes []byte) ([]byte, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MaxSerializationLen = (16 * 1024 * 1024) - 1 ChainID = ids.ID{} ErrUnknownBlockType = errors.New("unknown block type") )
Functions ¶
This section is empty.
Types ¶
type Writer ¶ added in v1.1.0
type Writer struct {
// contains filtered or unexported fields
}
func (*Writer) Bootstrap ¶ added in v1.1.0
func (w *Writer) Bootstrap(ctx context.Context, conns *servicesconn.Connections, persist idb.Persist) error
func (*Writer) Consume ¶ added in v1.1.0
func (w *Writer) Consume(ctx context.Context, conns *servicesconn.Connections, c services.Consumable, persist idb.Persist) error
func (*Writer) ConsumeConsensus ¶ added in v1.1.2
func (w *Writer) ConsumeConsensus(_ context.Context, _ *servicesconn.Connections, _ services.Consumable, _ idb.Persist) error
func (*Writer) InsertTransactionBlock ¶ added in v1.1.3
func (*Writer) InsertTransactionValidator ¶ added in v1.1.3
func (w *Writer) InsertTransactionValidator(ctx services.ConsumerCtx, txID ids.ID, validator platformvm.Validator) error
Click to show internal directories.
Click to hide internal directories.