ensresolver

Documentation

Index

• type EnsName
• type Publisher
• type Repo
  • func NewRepo(db *gorm.DB) *Repo
  • func (r *Repo) BatchCreate(data []EnsName) error
• type Service
  • func NewService(repo *Repo, cl enspb.EnsClient, pl Publisher) (*Service, error)
  • func (s *Service) AddRequests(list []string)
  • func (s *Service) Start(ctx context.Context) error

Types

type EnsName

type EnsName struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	Address   string
	Name      string
}

type Publisher

type Publisher interface {
	PublishJSON(ctx context.Context, subject string, obj any) error
}

type Repo

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

func NewRepo

func NewRepo(db *gorm.DB) *Repo

func (*Repo) BatchCreate

func (r *Repo) BatchCreate(data []EnsName) error

type Service

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

func NewService

func NewService(repo *Repo, cl enspb.EnsClient, pl Publisher) (*Service, error)

func (*Service) AddRequests

func (s *Service) AddRequests(list []string)

AddRequests add requests to resolve ens names. The results will be putted to the queue

func (*Service) Start

func (s *Service) Start(ctx context.Context) error