dascache

Documentation

Index

• type DasCache
  • func NewDasCache(ctx context.Context, wg *sync.WaitGroup) *DasCache
  • func (d *DasCache) AddBlockOutPoint(outPoint []string)
  • func (d *DasCache) AddCellInputByAction(action common.DasAction, inputs []*types.CellInput)
  • func (d *DasCache) AddOutPoint(outPoint []string)
  • func (d *DasCache) AddOutPointWithDuration(outPoint []string, duration time.Duration)
  • func (d *DasCache) ClearOutPoint(outPoint []string)
  • func (d *DasCache) ExistOutPoint(outPoint string) bool
  • func (d *DasCache) RunClearExpiredOutPoint(t time.Duration)

Types

type DasCache

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

func NewDasCache

func NewDasCache(ctx context.Context, wg *sync.WaitGroup) *DasCache

func (*DasCache) AddBlockOutPoint

func (d *DasCache) AddBlockOutPoint(outPoint []string)

func (*DasCache) AddCellInputByAction

func (d *DasCache) AddCellInputByAction(action common.DasAction, inputs []*types.CellInput)

func (*DasCache) AddOutPoint

func (d *DasCache) AddOutPoint(outPoint []string)

func (*DasCache) AddOutPointWithDuration

func (d *DasCache) AddOutPointWithDuration(outPoint []string, duration time.Duration)

func (*DasCache) ClearOutPoint

func (d *DasCache) ClearOutPoint(outPoint []string)

func (*DasCache) ExistOutPoint

func (d *DasCache) ExistOutPoint(outPoint string) bool

func (*DasCache) RunClearExpiredOutPoint

func (d *DasCache) RunClearExpiredOutPoint(t time.Duration)