pin

Documentation

Index

• type Store
  • func NewStore(db pg.DB) *Store
  • func (s *Store) AllWaiter(height uint64) <-chan struct{}
  • func (s *Store) CreatePin(ctx context.Context, name string, height uint64) error
  • func (s *Store) Height(name string) uint64
  • func (s *Store) Listen(ctx context.Context, pinName, dbURL string)
  • func (s *Store) LoadAll(ctx context.Context) error
  • func (s *Store) PinWaiter(pinName string, height uint64) <-chan struct{}
  • func (s *Store) ProcessBlocks(ctx context.Context, c *protocol.Chain, pinName string, ...)

Types

type Store

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

func NewStore

func NewStore(db pg.DB) *Store

func (*Store) AllWaiter

func (s *Store) AllWaiter(height uint64) <-chan struct{}

func (*Store) CreatePin

func (s *Store) CreatePin(ctx context.Context, name string, height uint64) error

func (*Store) Height

func (s *Store) Height(name string) uint64

func (*Store) Listen

func (s *Store) Listen(ctx context.Context, pinName, dbURL string)

func (*Store) LoadAll

func (s *Store) LoadAll(ctx context.Context) error

func (*Store) PinWaiter

func (s *Store) PinWaiter(pinName string, height uint64) <-chan struct{}

func (*Store) ProcessBlocks

func (s *Store) ProcessBlocks(ctx context.Context, c *protocol.Chain, pinName string, cb func(context.Context, *legacy.Block) error)