reward

Documentation

Index

• type HTTPWriter
  • func NewHTTPWriter() *HTTPWriter
  • func (hW *HTTPWriter) Call(req *http.Request)
  • func (hW *HTTPWriter) Close() (*http.Response, error)
  • func (hW *HTTPWriter) NewRequest(ctx context.Context, address string) (*http.Request, error)
  • func (hW *HTTPWriter) WriteData(v interface{}) error
• type RewardsPopulation
  • func (of *RewardsPopulation) Ingest(ctx context.Context, streamName string, startSequence uint64, limit uint32) (h structs.Heights, err error)
  • func (of *RewardsPopulation) IngestEarnedRewards(ctx context.Context, prefix string, req ingestion.Request, limit uint32) (structs.Heights, error)

Types

type HTTPWriter

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

func NewHTTPWriter

func NewHTTPWriter() *HTTPWriter

func (*HTTPWriter) Call

func (hW *HTTPWriter) Call(req *http.Request)

func (*HTTPWriter) Close

func (hW *HTTPWriter) Close() (*http.Response, error)

func (*HTTPWriter) NewRequest

func (hW *HTTPWriter) NewRequest(ctx context.Context, address string) (*http.Request, error)

func (*HTTPWriter) WriteData

func (hW *HTTPWriter) WriteData(v interface{}) error

type RewardsPopulation

type RewardsPopulation struct {
	DsClient          datastore.DatastoreServiceClient
	GrpcStoreClient   store.StoreCaller
	HttpOutputAddress string
}

func (*RewardsPopulation) Ingest

func (of *RewardsPopulation) Ingest(ctx context.Context, streamName string, startSequence uint64, limit uint32) (h structs.Heights, err error)

func (*RewardsPopulation) IngestEarnedRewards

func (of *RewardsPopulation) IngestEarnedRewards(ctx context.Context, prefix string, req ingestion.Request, limit uint32) (structs.Heights, error)