ingester

Documentation

Index

• type Processor
  • func NewGistIngester(cfg config.Config) Processor
  • func NewStateIngester(cfg config.Config) Processor
• type Service
  • func NewService(cfg config.Config, processor Processor) *Service
  • func (s *Service) Run(ctx context.Context)

Types

type Processor

type Processor interface {
	// contains filtered or unexported methods
}

func NewGistIngester

func NewGistIngester(cfg config.Config) Processor

func NewStateIngester

func NewStateIngester(cfg config.Config) Processor

type Service

type Service struct {
	Processor
	// contains filtered or unexported fields
}

func NewService

func NewService(cfg config.Config, processor Processor) *Service

func (*Service) Run

func (s *Service) Run(ctx context.Context)