kre

Documentation

Index

• func GetKREIngestorName() string
• type Loader
  • func NewLoader(hist history.Reader, committer ingestion.Committer, ...) *Loader
  • func (l *Loader) Process(ctx context.Context, interval time.Duration) error
• type Submitter

Functions

func GetKREIngestorName

func GetKREIngestorName() string

Types

type Loader

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

func NewLoader

func NewLoader(
	hist history.Reader,
	committer ingestion.Committer,
	lock ingestion.DistributedLock,
	sc solana.Client,
	tc *token.Client,
	creationsSubmitter Submitter,
	paymentsSubmitter Submitter,
	stateStore accountinfo.StateStore,
) *Loader

func (*Loader) Process

func (l *Loader) Process(ctx context.Context, interval time.Duration) error

type Submitter

type Submitter interface {
	Submit(ctx context.Context, src interface{}) (err error)
}