discovery

Documentation

Index

• Variables
• type Config
• type Service
  • func NewService(cfg Config) *Service
  • func (svc *Service) EndpointsChan() <-chan endpoints.Announce
  • func (svc *Service) GetAllEndpoints() endpoints.Map
  • func (svc *Service) Run(ctx context.Context, wg *sync.WaitGroup)

Variables

var (
	ErrEndpointsList         = errors.New("unable to get endpoints")
	ErrEndpointsUnmarshal    = errors.New("unable to unmarshal endpoints")
	ErrOperationUnsuccessful = errors.New("operation unsuccessful")
)

Types

type Config

type Config struct {
	Logger     logger.Logger
	Transport  grpc.ClientConnInterface
	DB         string
	DoAnnounce bool
}

type Service

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

func NewService

func NewService(cfg Config) *Service

func (*Service) EndpointsChan

func (svc *Service) EndpointsChan() <-chan endpoints.Announce

func (*Service) GetAllEndpoints

func (svc *Service) GetAllEndpoints() endpoints.Map

func (*Service) Run

func (svc *Service) Run(ctx context.Context, wg *sync.WaitGroup)