flow

type Block struct {
	Ts                   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Id                   []byte                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	ParentID             []byte                 `protobuf:"bytes,3,opt,name=parentID,proto3" json:"parentID,omitempty"`
	Height               uint64                 `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"`
	CollectionGuarantees []*CollectionGuarantee `protobuf:"bytes,5,rep,name=collectionGuarantees,proto3" json:"collectionGuarantees,omitempty"`
	Seals                []*BlockSeal           `protobuf:"bytes,6,rep,name=seals,proto3" json:"seals,omitempty"`
	// contains filtered or unexported fields
}

type BlockSeal struct {
	BlockID            []byte `protobuf:"bytes,1,opt,name=blockID,proto3" json:"blockID,omitempty"`
	ExecutionReceiptID []byte `protobuf:"bytes,2,opt,name=executionReceiptID,proto3" json:"executionReceiptID,omitempty"`
	// contains filtered or unexported fields
}

type CollectionGuarantee struct {
	CollectionID []byte `protobuf:"bytes,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// contains filtered or unexported fields
}

type Config struct {
	Host              string
	FromBlock         uint64
	NumBlocks         uint64
	MaxGrpcMsgSize    int
	MaxApiUsage       int // Limit GetEventsForHeightRange API usage rate.
	MaxWorkerPoolSize int
	CacheSize         int
	ChannelSize       int
	Timeout           time.Duration
	ReportInterval    time.Duration
}

type Connector struct {
	*connector.Connector
	*Config
	// contains filtered or unexported fields
}

type ContractID struct {
	Addr string
	Name string
}

type EventType struct {
	ContractAddr string
	ContractName string
	EventName    string
}

type ISmartContract interface {
	Address() string
	Name() string
	Events() []string
	Message(*Log) proto.Message
}

type Log struct {
	BlockID   flow.Identifier
	Height    uint64
	Timestamp time.Time
	// Type is the qualified event type.
	Type EventType
	// TransactionID is the ID of the transaction this event was emitted from.
	TransactionID flow.Identifier
	// TransactionIndex is the index of the transaction this event was emitted from, within its containing block.
	TransactionIndex int
	// EventIndex is the index of the event within the transaction it was emitted from.
	EventIndex int
	// Value contains the event data.
	Value cadence.Event
	// Bytes representing event data.
	Payload []byte
}

type ProposalKey struct {
	Address        []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	KeyIndex       int64  `protobuf:"varint,2,opt,name=keyIndex,proto3" json:"keyIndex,omitempty"`
	SequenceNumber uint64 `protobuf:"varint,3,opt,name=sequenceNumber,proto3" json:"sequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

type Repository interface {
	GetLatestBlock(ctx context.Context, isSealed bool) (*flow.Block, error)
	GetBlockByHeight(ctx context.Context, height uint64) (*flow.Block, error)
	GetCollection(ctx context.Context, colID flow.Identifier) (*flow.Collection, error)
	GetTransaction(ctx context.Context, txID flow.Identifier) (*flow.Transaction, error)
	GetEventsForBlockIDs(ctx context.Context, eventType string, blockIDs []flow.Identifier) ([]flow.BlockEvents, error)
	GetEventsForHeightRange(ctx context.Context, eventType string, startHeight uint64, endHeight uint64) ([]flow.BlockEvents, error)
}

type Subscription struct {
	*Config
	// contains filtered or unexported fields
}

type Transaction struct {
	Ts                 *timestamppb.Timestamp  `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Id                 []byte                  `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	BlockID            []byte                  `protobuf:"bytes,3,opt,name=blockID,proto3" json:"blockID,omitempty"`
	CollectionID       []byte                  `protobuf:"bytes,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Script             []byte                  `protobuf:"bytes,5,opt,name=script,proto3" json:"script,omitempty"`
	Arguments          [][]byte                `protobuf:"bytes,6,rep,name=arguments,proto3" json:"arguments,omitempty"`
	ReferenceBlockID   []byte                  `protobuf:"bytes,7,opt,name=referenceBlockID,proto3" json:"referenceBlockID,omitempty"`
	GasLimit           uint64                  `protobuf:"varint,8,opt,name=gasLimit,proto3" json:"gasLimit,omitempty"`
	ProposalKey        *ProposalKey            `protobuf:"bytes,9,opt,name=proposalKey,proto3" json:"proposalKey,omitempty"`
	Payer              []byte                  `protobuf:"bytes,10,opt,name=payer,proto3" json:"payer,omitempty"`
	Authorizers        [][]byte                `protobuf:"bytes,11,rep,name=authorizers,proto3" json:"authorizers,omitempty"`
	PayloadSignatures  []*TransactionSignature `protobuf:"bytes,12,rep,name=payloadSignatures,proto3" json:"payloadSignatures,omitempty"`
	EnvelopeSignatures []*TransactionSignature `protobuf:"bytes,13,rep,name=envelopeSignatures,proto3" json:"envelopeSignatures,omitempty"`
	BlockNumber        uint64                  `protobuf:"varint,14,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	// contains filtered or unexported fields
}

type TransactionSignature struct {
	Address     []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	SignerIndex int64  `protobuf:"varint,2,opt,name=signerIndex,proto3" json:"signerIndex,omitempty"`
	KeyIndex    int64  `protobuf:"varint,3,opt,name=keyIndex,proto3" json:"keyIndex,omitempty"`
	Signature   []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

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