ensresolver

package

v0.1.11 Latest Latest Go to latest Published: Apr 11, 2024 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

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

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

func NewRepo(db *gorm.DB) *Repo

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

func (r *Repo) GetByAddresses(addresses []string) ([]EnsName, error)

type Server struct {
	storagepb.UnimplementedEnsServer
	// contains filtered or unexported fields
}

func NewServer(sp *Service) *Server

func (s *Server) GetEnsByAddresses(_ context.Context, req *storagepb.EnsByAddressesRequest) (*storagepb.EnsByAddressesResponse, error)

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

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

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

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

func (s *Service) GetByAddresses(addresses []string) ([]EnsName, error)

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