listener

Documentation

Index

• Constants
• type BlockStorage
• type DatabaseStorage
  • func NewPostgresStorage(driverName DriverName, dataSourceName string, channelID string) (DatabaseStorage, error)
  • func (m DatabaseStorage) Store(block *cb.Block) error
  • func (m DatabaseStorage) StoreBulk(blocks []*cb.Block) error
• type DriverName
• type ElasticSearchStorage
  • func NewElasticStorage(client *elasticsearch7.Client) ElasticSearchStorage
  • func (e ElasticSearchStorage) Store(block *cb.Block) error
  • func (e ElasticSearchStorage) StoreBulk(blocks []*cb.Block) error
• type IndexDoc
• type IndexKey
• type Item
• type ItemHistory
• type MeilisearchStorage
  • func NewMeilisearchStorage(client meilisearch.ClientInterface, channelID string) (MeilisearchStorage, error)
  • func (m MeilisearchStorage) Store(block *cb.Block) error
  • func (m MeilisearchStorage) StoreBulk(blocks []*cb.Block) error
• type Record

Constants

const (
	PostgresqlDriver = "postgres"
	MySQLDriver      = "mysql"
)

Types

type BlockStorage

type BlockStorage interface {
	Store(block *cb.Block) error
	StoreBulk(blocks []*cb.Block) error
}

type DatabaseStorage

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

func NewPostgresStorage

func NewPostgresStorage(driverName DriverName, dataSourceName string, channelID string) (DatabaseStorage, error)

func (DatabaseStorage) Store

func (m DatabaseStorage) Store(block *cb.Block) error

func (DatabaseStorage) StoreBulk

func (m DatabaseStorage) StoreBulk(blocks []*cb.Block) error

type DriverName

type DriverName string

type ElasticSearchStorage

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

func NewElasticStorage

func NewElasticStorage(client *elasticsearch7.Client) ElasticSearchStorage

func (ElasticSearchStorage) Store

func (e ElasticSearchStorage) Store(block *cb.Block) error

func (ElasticSearchStorage) StoreBulk

func (e ElasticSearchStorage) StoreBulk(blocks []*cb.Block) error

type IndexDoc

type IndexDoc = map[string]interface{}

type IndexKey

type IndexKey struct {
	ChaincodeID string
	ChannelID   string
}

type Item

type Item struct {
	ID          string      `json:"id"`
	Data        interface{} `json:"data"`
	TXID        string      `json:"txid"`
	BlockNumber int         `json:"blockNumber"`
	TXDate      int         `json:"tx_date"`
}

type ItemHistory

type ItemHistory struct {
	Data    interface{}
	TXID    string `json:"txid"`
	BlockID string `json:"blockId"`
	TXDate  string `json:"tx_date"`
}

type MeilisearchStorage

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

func NewMeilisearchStorage

func NewMeilisearchStorage(client meilisearch.ClientInterface, channelID string) (MeilisearchStorage, error)

func (MeilisearchStorage) Store

func (m MeilisearchStorage) Store(block *cb.Block) error

func (MeilisearchStorage) StoreBulk

func (m MeilisearchStorage) StoreBulk(blocks []*cb.Block) error

type Record

type Record struct {
	ID        string
	Data      datatypes.JSON
	Chaincode string
	CreatedAt time.Time
	UpdatedAt time.Time
}