dump

package
v0.34.4 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2021 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDump        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDump          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDump = fmt.Errorf("proto: unexpected end of group")
)

Functions

func Load added in v0.34.4 

func Load(source Source, st *state.State) error

Load a dump into state. We store all the events from the source chain in a single zeroth block with all the events at each height in their own pseudo transaction.

func Write added in v0.34.4 

func Write(out io.Writer, source Source, useBinaryEncoding bool, options Option) error

Write a dump to the Writer out by pulling rows from stream

Types

type AccountStorage 

type AccountStorage struct {
	Address              github_com_hyperledger_burrow_crypto.Address `protobuf:"bytes,1,opt,name=Address,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Address"`
	Storage              []*Storage                                   `protobuf:"bytes,2,rep,name=Storage,proto3" json:"Storage,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

func (*AccountStorage) Descriptor 

func (*AccountStorage) Descriptor() ([]byte, []int)

func (*AccountStorage) GetStorage 

func (m *AccountStorage) GetStorage() []*Storage

func (*AccountStorage) Marshal 

func (m *AccountStorage) Marshal() (dAtA []byte, err error)

func (*AccountStorage) MarshalTo 

func (m *AccountStorage) MarshalTo(dAtA []byte) (int, error)

func (*AccountStorage) MarshalToSizedBuffer added in v0.34.4 

func (m *AccountStorage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountStorage) ProtoMessage 

func (*AccountStorage) ProtoMessage()

func (*AccountStorage) Reset 

func (m *AccountStorage) Reset()

func (*AccountStorage) Size 

func (m *AccountStorage) Size() (n int)

func (*AccountStorage) String 

func (m *AccountStorage) String() string

func (*AccountStorage) Unmarshal 

func (m *AccountStorage) Unmarshal(dAtA []byte) error

func (*AccountStorage) XXX_DiscardUnknown 

func (m *AccountStorage) XXX_DiscardUnknown()

func (*AccountStorage) XXX_Marshal 

func (m *AccountStorage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountStorage) XXX_Merge 

func (m *AccountStorage) XXX_Merge(src proto.Message)

func (*AccountStorage) XXX_MessageName 

func (*AccountStorage) XXX_MessageName() string

func (*AccountStorage) XXX_Size 

func (m *AccountStorage) XXX_Size() int

func (*AccountStorage) XXX_Unmarshal 

func (m *AccountStorage) XXX_Unmarshal(b []byte) error

type Blockchain added in v0.34.4 

type Blockchain interface {
	ChainID() string
	LastBlockHeight() uint64
}

type CollectSink added in v0.34.4 

type CollectSink struct {
	Rows    []string
	Current int
}

func (*CollectSink) Recv added in v0.34.4 

func (c *CollectSink) Recv() (d *Dump, err error)

func (*CollectSink) Send added in v0.34.4 

func (c *CollectSink) Send(d *Dump) error

type Dump 

type Dump struct {
	Height               uint64          `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	Account              *acm.Account    `protobuf:"bytes,2,opt,name=Account,proto3" json:"Account,omitempty"`
	AccountStorage       *AccountStorage `protobuf:"bytes,3,opt,name=AccountStorage,proto3" json:"AccountStorage,omitempty"`
	EVMEvent             *EVMEvent       `protobuf:"bytes,4,opt,name=EVMEvent,proto3" json:"EVMEvent,omitempty"`
	Name                 *names.Entry    `protobuf:"bytes,5,opt,name=Name,proto3" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Dump) Descriptor 

func (*Dump) Descriptor() ([]byte, []int)

func (*Dump) GetAccount 

func (m *Dump) GetAccount() *acm.Account

func (*Dump) GetAccountStorage 

func (m *Dump) GetAccountStorage() *AccountStorage

func (*Dump) GetEVMEvent 

func (m *Dump) GetEVMEvent() *EVMEvent

func (*Dump) GetHeight 

func (m *Dump) GetHeight() uint64

func (*Dump) GetName 

func (m *Dump) GetName() *names.Entry

func (*Dump) Marshal 

func (m *Dump) Marshal() (dAtA []byte, err error)

func (*Dump) MarshalTo 

func (m *Dump) MarshalTo(dAtA []byte) (int, error)

func (*Dump) MarshalToSizedBuffer added in v0.34.4 

func (m *Dump) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Dump) ProtoMessage 

func (*Dump) ProtoMessage()

func (*Dump) Reset 

func (m *Dump) Reset()

func (*Dump) Size 

func (m *Dump) Size() (n int)

func (*Dump) String 

func (m *Dump) String() string

func (*Dump) Unmarshal 

func (m *Dump) Unmarshal(dAtA []byte) error

func (*Dump) XXX_DiscardUnknown 

func (m *Dump) XXX_DiscardUnknown()

func (*Dump) XXX_Marshal 

func (m *Dump) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dump) XXX_Merge 

func (m *Dump) XXX_Merge(src proto.Message)

func (*Dump) XXX_MessageName 

func (*Dump) XXX_MessageName() string

func (*Dump) XXX_Size 

func (m *Dump) XXX_Size() int

func (*Dump) XXX_Unmarshal 

func (m *Dump) XXX_Unmarshal(b []byte) error

type Dumper added in v0.34.4 

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

func NewDumper added in v0.34.4 

func NewDumper(state *state.State, blockchain Blockchain) *Dumper

Return a Dumper that can Transmit Dump rows to a Sink by pulling them out of the the provided State

func (*Dumper) Source added in v0.34.4 

func (ds *Dumper) Source(startHeight, endHeight uint64, options Option) Source

Return a Source that is a Pipe fed from this Dumper's Transmit function

func (*Dumper) Transmit added in v0.34.4 

func (ds *Dumper) Transmit(sink Sink, startHeight, endHeight uint64, options Option) error

func (*Dumper) WithLogger added in v0.34.4 

func (ds *Dumper) WithLogger(logger *logging.Logger) *Dumper

type EVMEvent 

type EVMEvent struct {
	// The original ChainID from for this event
	ChainID string `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"ChainID,omitempty"`
	// The original index for this event
	Index uint64 `protobuf:"varint,4,opt,name=Index,proto3" json:"Index,omitempty"`
	// The original block time for this transaction
	Time time.Time `protobuf:"bytes,2,opt,name=Time,proto3,stdtime" json:"Time"`
	// The event itself
	Event                *exec.LogEvent `protobuf:"bytes,3,opt,name=Event,proto3" json:"Event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EVMEvent) Descriptor 

func (*EVMEvent) Descriptor() ([]byte, []int)

func (*EVMEvent) GetChainID 

func (m *EVMEvent) GetChainID() string

func (*EVMEvent) GetEvent 

func (m *EVMEvent) GetEvent() *exec.LogEvent

func (*EVMEvent) GetIndex added in v0.34.4 

func (m *EVMEvent) GetIndex() uint64

func (*EVMEvent) GetTime 

func (m *EVMEvent) GetTime() time.Time

func (*EVMEvent) Marshal 

func (m *EVMEvent) Marshal() (dAtA []byte, err error)

func (*EVMEvent) MarshalTo 

func (m *EVMEvent) MarshalTo(dAtA []byte) (int, error)

func (*EVMEvent) MarshalToSizedBuffer added in v0.34.4 

func (m *EVMEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EVMEvent) ProtoMessage 

func (*EVMEvent) ProtoMessage()

func (*EVMEvent) Reset 

func (m *EVMEvent) Reset()

func (*EVMEvent) Size 

func (m *EVMEvent) Size() (n int)

func (*EVMEvent) String 

func (m *EVMEvent) String() string

func (*EVMEvent) Unmarshal 

func (m *EVMEvent) Unmarshal(dAtA []byte) error

func (*EVMEvent) XXX_DiscardUnknown 

func (m *EVMEvent) XXX_DiscardUnknown()

func (*EVMEvent) XXX_Marshal 

func (m *EVMEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EVMEvent) XXX_Merge 

func (m *EVMEvent) XXX_Merge(src proto.Message)

func (*EVMEvent) XXX_MessageName 

func (*EVMEvent) XXX_MessageName() string

func (*EVMEvent) XXX_Size 

func (m *EVMEvent) XXX_Size() int

func (*EVMEvent) XXX_Unmarshal 

func (m *EVMEvent) XXX_Unmarshal(b []byte) error

type MockSource added in v0.34.4 

type MockSource struct {
	Accounts   int
	MaxStorage int
	Names      int
	Events     int
	*Mockchain
	// contains filtered or unexported fields
}

func NewMockSource added in v0.34.4 

func NewMockSource(accounts, maxStorage, names, events int) *MockSource

func (*MockSource) Recv added in v0.34.4 

func (m *MockSource) Recv() (*Dump, error)

type Mockchain added in v0.34.4 

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

func NewMockchain added in v0.34.4 

func NewMockchain(chainID string, lastBlockHeight uint64) *Mockchain

func (*Mockchain) ChainID added in v0.34.4 

func (mc *Mockchain) ChainID() string

func (*Mockchain) LastBlockHeight added in v0.34.4 

func (mc *Mockchain) LastBlockHeight() uint64

type NullSink added in v0.34.4 

type NullSink struct{}

func (NullSink) Send added in v0.34.4 

func (NullSink) Send(*Dump) error

type Option added in v0.34.4 

type Option uint64
const (
	// Whether to send/receive these classes of data
	Accounts Option = 1 << iota
	Names
	Events
)
const (
	None Option = 0
	All         = Accounts | Names | Events
)

func (Option) Enabled added in v0.34.4 

func (options Option) Enabled(option Option) bool

type Pipe added in v0.34.4 

type Pipe chan msg

Implements both Sink and Source

func (Pipe) Recv added in v0.34.4 

func (p Pipe) Recv() (*Dump, error)

func (Pipe) Send added in v0.34.4 

func (p Pipe) Send(dump *Dump) error

type Sink added in v0.34.4 

type Sink interface {
	Send(*Dump) error
}

type Source added in v0.34.4 

type Source interface {
	Recv() (*Dump, error)
}

func NewFileReader added in v0.34.4 

func NewFileReader(filename string) (Source, error)

type Storage 

type Storage struct {
	Key                  github_com_hyperledger_burrow_binary.Word256  `protobuf:"bytes,1,opt,name=Key,proto3,customtype=github.com/hyperledger/burrow/binary.Word256" json:"Key"`
	Value                github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,2,opt,name=Value,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"Value"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*Storage) Descriptor 

func (*Storage) Descriptor() ([]byte, []int)

func (*Storage) Marshal 

func (m *Storage) Marshal() (dAtA []byte, err error)

func (*Storage) MarshalTo 

func (m *Storage) MarshalTo(dAtA []byte) (int, error)

func (*Storage) MarshalToSizedBuffer added in v0.34.4 

func (m *Storage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Storage) ProtoMessage 

func (*Storage) ProtoMessage()

func (*Storage) Reset 

func (m *Storage) Reset()

func (*Storage) Size 

func (m *Storage) Size() (n int)

func (*Storage) String 

func (m *Storage) String() string

func (*Storage) Unmarshal 

func (m *Storage) Unmarshal(dAtA []byte) error

func (*Storage) XXX_DiscardUnknown 

func (m *Storage) XXX_DiscardUnknown()

func (*Storage) XXX_Marshal 

func (m *Storage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Storage) XXX_Merge 

func (m *Storage) XXX_Merge(src proto.Message)

func (*Storage) XXX_MessageName 

func (*Storage) XXX_MessageName() string

func (*Storage) XXX_Size 

func (m *Storage) XXX_Size() int

func (*Storage) XXX_Unmarshal 

func (m *Storage) XXX_Unmarshal(b []byte) error

type StreamReader added in v0.34.4 

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

func NewJSONReader added in v0.34.4 

func NewJSONReader(reader io.Reader) (*StreamReader, error)

func NewProtobufReader added in v0.34.4 

func NewProtobufReader(reader io.Reader) (*StreamReader, error)

func NewStreamReader added in v0.34.4 

func NewStreamReader(reader io.Reader, decode func(*Dump) error) (*StreamReader, error)

func (*StreamReader) Recv added in v0.34.4 

func (sr *StreamReader) Recv() (*Dump, error)

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.