data

Documentation

Index

• Variables
• type Data
  • func NewData(bootstrap *conf.Bootstrap, logger *log.Helper) (*Data, func())
  • func (d *Data) AppendCleanup(cleanup func())
  • func (d *Data) DB(ctx context.Context) *gorm.DB
  • func (d *Data) ExecTx(ctx context.Context, fn func(ctx context.Context) error) error
• type ReportTeeAttestationEventRepo
  • func NewReportTeeAttestationEventRepo(data *Data, logger log.Logger) *ReportTeeAttestationEventRepo
  • func (t *ReportTeeAttestationEventRepo) CreateReportTeeAttestationEvent(ctx context.Context, event biz.ReportTeeAttestationEvent) (*biz.ReportTeeAttestationEvent, error)
  • func (t *ReportTeeAttestationEventRepo) FindReportTeeAttestationEvent(ctx context.Context, hash string, txIndex int) (*biz.ReportTeeAttestationEvent, *gorm.DB)
  • func (t *ReportTeeAttestationEventRepo) LastReportTeeAttestationEvent(rtae *biz.ReportTeeAttestationEvent) (*biz.ReportTeeAttestationEvent, error)
• type TransactionManager
• type TransactionRepo
  • func NewTransactionRepo(data *Data, logger log.Logger) *TransactionRepo
  • func (t *TransactionRepo) CreateTransaction(ctx context.Context, transaction *biz.Transaction) (*biz.Transaction, error)
• type VerifierRepo
  • func NewVerifierRepo(data *Data) *VerifierRepo
  • func (r *VerifierRepo) ListAll(ctx context.Context) ([]*model.Verifier, error)

Variables

var ProviderSet = wire.NewSet(
	NewData,
	NewVerifierRepo,
	NewTransactionRepo,
	NewReportTeeAttestationEventRepo,
	wire.Bind(new(biz.VerifierRepo), new(*VerifierRepo)),
	wire.Bind(new(biz.TransactionRepo), new(*TransactionRepo)),
	wire.Bind(new(biz.ReportTeeAttestationEventRepo), new(*ReportTeeAttestationEventRepo)),
)

ProviderSet is data providers.

Types

type Data

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

Data .

func NewData

func NewData(bootstrap *conf.Bootstrap, logger *log.Helper) (*Data, func())

func (*Data) AppendCleanup

func (d *Data) AppendCleanup(cleanup func())

func (*Data) DB

func (d *Data) DB(ctx context.Context) *gorm.DB

DB try to get transaction handle by the context, if the handle do not exist, will return data's DB instance directly so do not forget do some sql without withContext func

func (*Data) ExecTx

func (d *Data) ExecTx(ctx context.Context, fn func(ctx context.Context) error) error

ExecTx transaction manager's core func, implemented it by gorm and context value func now

type ReportTeeAttestationEventRepo

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

func NewReportTeeAttestationEventRepo

func NewReportTeeAttestationEventRepo(data *Data, logger log.Logger) *ReportTeeAttestationEventRepo

func (*ReportTeeAttestationEventRepo) CreateReportTeeAttestationEvent

func (t *ReportTeeAttestationEventRepo) CreateReportTeeAttestationEvent(ctx context.Context, event biz.ReportTeeAttestationEvent) (*biz.ReportTeeAttestationEvent, error)

func (*ReportTeeAttestationEventRepo) FindReportTeeAttestationEvent

func (t *ReportTeeAttestationEventRepo) FindReportTeeAttestationEvent(ctx context.Context, hash string, txIndex int) (*biz.ReportTeeAttestationEvent, *gorm.DB)

func (*ReportTeeAttestationEventRepo) LastReportTeeAttestationEvent

func (t *ReportTeeAttestationEventRepo) LastReportTeeAttestationEvent(rtae *biz.ReportTeeAttestationEvent) (*biz.ReportTeeAttestationEvent, error)

type TransactionManager

type TransactionManager interface {
	ExecTx(ctx context.Context, fn func(ctx context.Context) error) error
}

type TransactionRepo

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

func NewTransactionRepo

func NewTransactionRepo(data *Data, logger log.Logger) *TransactionRepo

func (*TransactionRepo) CreateTransaction

func (t *TransactionRepo) CreateTransaction(ctx context.Context, transaction *biz.Transaction) (*biz.Transaction, error)

type VerifierRepo

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

func NewVerifierRepo

func NewVerifierRepo(data *Data) *VerifierRepo

func (*VerifierRepo) ListAll

func (r *VerifierRepo) ListAll(ctx context.Context) ([]*model.Verifier, error)