bsn

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2024 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadSnapshot added in v1.2.10 

func LoadSnapshot(file ioutil2.SectionReader, store keyvalue.Beginner, logger log.Logger) error

Types

type Block 

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

func (*Block) Close 

func (b *Block) Close() (execute.BlockState, error)

func (*Block) Params 

func (b *Block) Params() execute.BlockParams

func (*Block) Process 

func (b *Block) Process(envelope *messaging.Envelope) ([]*protocol.TransactionStatus, error)

type BlockAnchor 

type BlockAnchor struct{}

func (BlockAnchor) Process 

func (x BlockAnchor) Process(batch *ChangeSet, ctx *MessageContext) (err error)

func (BlockAnchor) Validate 

func (x BlockAnchor) Validate(batch *ChangeSet, ctx *MessageContext) error

type BlockState 

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

func (*BlockState) ChangeSet added in v1.1.1 

func (b *BlockState) ChangeSet() record.Record

func (*BlockState) Commit 

func (b *BlockState) Commit() error

func (*BlockState) DidCompleteMajorBlock 

func (b *BlockState) DidCompleteMajorBlock() (uint64, time.Time, bool)

func (*BlockState) DidUpdateValidators added in v1.2.10 

func (b *BlockState) DidUpdateValidators() ([]*execute.ValidatorUpdate, bool)

func (*BlockState) Discard 

func (b *BlockState) Discard()

func (*BlockState) Hash 

func (b *BlockState) Hash() ([32]byte, error)

func (*BlockState) IsEmpty 

func (b *BlockState) IsEmpty() bool

func (*BlockState) Params 

func (b *BlockState) Params() execute.BlockParams

type BlockSummary 

type BlockSummary struct{}

func (BlockSummary) Process 

func (x BlockSummary) Process(batch *ChangeSet, ctx *MessageContext) (err error)

func (BlockSummary) Validate 

func (x BlockSummary) Validate(batch *ChangeSet, ctx *MessageContext) error

type ChangeSet 

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

func NewChangeSet 

func NewChangeSet(store keyvalue.Beginner, logger log.Logger) *ChangeSet

New

func (*ChangeSet) Begin 

func (c *ChangeSet) Begin() *ChangeSet

func (*ChangeSet) Commit 

func (c *ChangeSet) Commit() error

func (*ChangeSet) Discard 

func (c *ChangeSet) Discard()

func (*ChangeSet) IsDirty 

func (c *ChangeSet) IsDirty() bool

func (*ChangeSet) Key added in v1.1.1 

func (c *ChangeSet) Key() *record.Key

func (*ChangeSet) LastBlock 

func (c *ChangeSet) LastBlock() values.Value[*LastBlock]

func (*ChangeSet) Partition 

func (c *ChangeSet) Partition(id string) *database.Batch

func (*ChangeSet) Pending 

func (c *ChangeSet) Pending(partition string) *Pending

func (*ChangeSet) Resolve 

func (c *ChangeSet) Resolve(key *record.Key) (record.Record, *record.Key, error)

func (*ChangeSet) Summary 

func (c *ChangeSet) Summary(hash [32]byte) *Summary

func (*ChangeSet) Walk added in v1.1.1 

func (c *ChangeSet) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type Collector 

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

func StartCollector 

func StartCollector(opts CollectorOptions) (*Collector, error)

type CollectorOptions 

type CollectorOptions struct {
	Partition string
	Database  database.Beginner
	Events    *events.Bus
}

type DidCollectBlock 

type DidCollectBlock struct {
	Summary *messaging.BlockSummary
}

func (DidCollectBlock) IsEvent 

func (DidCollectBlock) IsEvent()

type Executor 

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

func NewExecutor 

func NewExecutor(opts ExecutorOptions) (*Executor, error)

func (*Executor) Begin 

func (x *Executor) Begin(params execute.BlockParams) (execute.Block, error)

func (*Executor) EnableTimers 

func (*Executor) EnableTimers()

func (*Executor) Init added in v1.2.0 

func (x *Executor) Init(validators []*execute.ValidatorUpdate) (additional []*execute.ValidatorUpdate, err error)

func (*Executor) LastBlock 

func (x *Executor) LastBlock() (*execute.BlockParams, [32]byte, error)

func (*Executor) StoreBlockTimers 

func (*Executor) StoreBlockTimers(ds *logging.DataSet)

func (*Executor) Validate 

func (x *Executor) Validate(envelope *messaging.Envelope, recheck bool) ([]*protocol.TransactionStatus, error)

type ExecutorFor 

type ExecutorFor[T any, V interface{ Type() T }] interface {
	Process(*ChangeSet, V) error
	Validate(*ChangeSet, V) error
}

type ExecutorOptions 

type ExecutorOptions struct {
	PartitionID string
	Logger      log.Logger
	Store       keyvalue.Beginner
	EventBus    *events.Bus
}

type LastBlock 

type LastBlock struct {
	Index uint64    `json:"index,omitempty" form:"index" query:"index" validate:"required"`
	Time  time.Time `json:"time,omitempty" form:"time" query:"time" validate:"required"`
	// contains filtered or unexported fields
}

func (*LastBlock) Copy 

func (v *LastBlock) Copy() *LastBlock

func (*LastBlock) CopyAsInterface 

func (v *LastBlock) CopyAsInterface() interface{}

func (*LastBlock) Equal 

func (v *LastBlock) Equal(u *LastBlock) bool

func (*LastBlock) IsValid 

func (v *LastBlock) IsValid() error

func (*LastBlock) MarshalBinary 

func (v *LastBlock) MarshalBinary() ([]byte, error)

func (*LastBlock) UnmarshalBinary 

func (v *LastBlock) UnmarshalBinary(data []byte) error

func (*LastBlock) UnmarshalBinaryFrom 

func (v *LastBlock) UnmarshalBinaryFrom(rd io.Reader) error

type MessageContext 

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

func (*MessageContext) Type 

func (m *MessageContext) Type() messaging.MessageType

type MessageExecutor 

type MessageExecutor = ExecutorFor[messaging.MessageType, *MessageContext]

type Pending 

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

func (*Pending) Commit 

func (c *Pending) Commit() error

func (*Pending) IsDirty 

func (c *Pending) IsDirty() bool

func (*Pending) Key added in v1.1.1 

func (c *Pending) Key() *record.Key

func (*Pending) OnBlock 

func (c *Pending) OnBlock(index uint64) values.Value[[32]byte]

func (*Pending) Resolve 

func (c *Pending) Resolve(key *record.Key) (record.Record, *record.Key, error)

func (*Pending) Walk added in v1.1.1 

func (c *Pending) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type Summary 

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

func (*Summary) Commit 

func (c *Summary) Commit() error

func (*Summary) IsDirty 

func (c *Summary) IsDirty() bool

func (*Summary) Key added in v1.1.1 

func (c *Summary) Key() *record.Key

func (*Summary) Main 

func (c *Summary) Main() values.Value[*messaging.BlockSummary]

func (*Summary) Resolve 

func (c *Summary) Resolve(key *record.Key) (record.Record, *record.Key, error)

func (*Summary) Signatures 

func (c *Summary) Signatures() values.Set[protocol.KeySignature]

func (*Summary) Walk added in v1.1.1 

func (c *Summary) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type SummaryContext added in v1.2.10 

type SummaryContext struct {
	*MessageContext
	// contains filtered or unexported fields
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.