Documentation ¶
Index ¶
- Variables
- type PtxDataModel
- type PtxDataProposerModel
- type Writer
- func (w *Writer) Bootstrap(ctx context.Context, conns *utils.Connections, persist db.Persist) error
- func (w *Writer) Consume(ctx context.Context, conns *utils.Connections, c services.Consumable, ...) error
- func (w *Writer) ConsumeConsensus(_ context.Context, _ *utils.Connections, _ services.Consumable, _ db.Persist) 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 PtxDataModel ¶ added in v1.6.0
type PtxDataModel struct { Tx *platformvm.Tx `json:"tx,omitempty"` TxType *string `json:"txType,omitempty"` Block *platformvm.Block `json:"block,omitempty"` BlockID *string `json:"blockID,omitempty"` BlockType *string `json:"blockType,omitempty"` Proposer *PtxDataProposerModel `json:"proposer,omitempty"` ProposerType *string `json:"proposerType,omitempty"` }
type PtxDataProposerModel ¶ added in v1.6.0
type PtxDataProposerModel struct { ID string `json:"tx"` ParentID string `json:"parentID"` PChainHeight uint64 `json:"pChainHeight"` Proposer string `json:"proposer"` TimeStamp time.Time `json:"timeStamp"` }
func NewPtxDataProposerModel ¶ added in v1.6.0
func NewPtxDataProposerModel(b block.Block) *PtxDataProposerModel
type Writer ¶ added in v1.1.0
type Writer struct {
// contains filtered or unexported fields
}
func (*Writer) Consume ¶ added in v1.1.0
func (w *Writer) Consume(ctx context.Context, conns *utils.Connections, c services.Consumable, persist db.Persist) error
func (*Writer) ConsumeConsensus ¶ added in v1.1.2
func (w *Writer) ConsumeConsensus(_ context.Context, _ *utils.Connections, _ services.Consumable, _ db.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.