warpy_sync

type BlockDownloader struct {
	*task.Task

	Output        chan *BlockInfoPayload
	OutputPollTxs chan uint64
	// contains filtered or unexported fields
}

type BlockInfoPayload struct {
	Transactions []*types.Transaction
	Height       uint64
	Hash         string
	Timestamp    uint64
}

type Controller struct {
	*task.Task
}

type Input struct {
	Function string   `json:"function"`
	Points   int64    `json:"points"`
	AdminId  string   `json:"adminId"`
	Members  []Member `json:"members"`
	NoBoost  bool     `json:"noBoost"`
}

type InteractionPayload struct {
	FromAddress string
	Points      int64
}

type LastSyncedBlockPayload struct {
	Height    uint64
	Hash      string
	Timestamp uint64
}

type Member struct {
	Id     string   `json:"id"`
	Roles  []string `json:"roles"`
	TxId   string   `json:"txId"`
	Points int64    `json:"points"`
}

type PollerDeposit struct {
	*task.Task

	Output chan *[]InteractionPayload
	// contains filtered or unexported fields
}

type SommelierTransactionPayload struct {
	Transaction *types.Transaction
	FromAddress string
	Block       *BlockInfoPayload
	Method      *abi.Method
	ParsedInput []byte
	Input       map[string]interface{}
}

type Store struct {
	*task.Processor[*LastSyncedBlockPayload, *LastSyncedBlockPayload]
	// contains filtered or unexported fields
}

type StoreDeposit struct {
	*task.Task
	// contains filtered or unexported fields
}

type SyncerDelta struct {
	*task.Task

	Output                   chan *LastSyncedBlockPayload
	OutputInteractionPayload chan *[]InteractionPayload
	// contains filtered or unexported fields
}

type SyncerDeposit struct {
	*task.Task

	Output                   chan *LastSyncedBlockPayload
	OutputTransactionPayload chan *SommelierTransactionPayload
	// contains filtered or unexported fields
}

type Writer struct {
	*task.Task
	// contains filtered or unexported fields
}