impl

Documentation

Index

• type GatewayStore
  • func NewGatewayStore(db *database.SQLiteDB, resolver sqlparser.ReadStatementResolver) *GatewayStore
  • func (s *GatewayStore) GetReceipt(ctx context.Context, chainID tableland.ChainID, txnHash string) (gateway.Receipt, bool, error)
  • func (s *GatewayStore) GetSchemaByTableName(ctx context.Context, tblName string) (gateway.TableSchema, error)
  • func (s *GatewayStore) GetTable(ctx context.Context, chainID tableland.ChainID, tableID tables.TableID) (gateway.Table, error)
  • func (s *GatewayStore) Read(ctx context.Context, stmt parsing.ReadStmt) (*gateway.TableData, error)

Types

type GatewayStore

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

GatewayStore is the storage layer of the gateway.

func NewGatewayStore

func NewGatewayStore(db *database.SQLiteDB, resolver sqlparser.ReadStatementResolver) *GatewayStore

NewGatewayStore creates a new GatewayStore.

func (*GatewayStore) GetReceipt

func (s *GatewayStore) GetReceipt(
	ctx context.Context, chainID tableland.ChainID, txnHash string,
) (gateway.Receipt, bool, error)

GetReceipt gets the receipt of a given transaction hash.

func (*GatewayStore) GetSchemaByTableName

func (s *GatewayStore) GetSchemaByTableName(ctx context.Context, tblName string) (gateway.TableSchema, error)

GetSchemaByTableName returns the table schema given its name.

func (*GatewayStore) GetTable

func (s *GatewayStore) GetTable(
	ctx context.Context, chainID tableland.ChainID, tableID tables.TableID,
) (gateway.Table, error)

GetTable returns a table information.

func (*GatewayStore) Read

func (s *GatewayStore) Read(ctx context.Context, stmt parsing.ReadStmt) (*gateway.TableData, error)

Read executes a parsed read statement.