service

Documentation

Index

• type Config
• type Option
  • func WithDiscovery(discovery registry.Discovery) Option
  • func WithSelector(selector selector.Selector) Option
• type Service
  • func NewService(config *Config, opts ...Option) (*Service, error)
  • func (s *Service) All(ctx context.Context) (node []servicer.Node, err error)
  • func (s *Service) Done(ctx context.Context, node servicer.Node, err error) error
  • func (s *Service) GetCaCrt() []byte
  • func (s *Service) GetClientKey() []byte
  • func (s *Service) GetClientPem() []byte
  • func (s *Service) Name() string
  • func (s *Service) Pick(ctx context.Context) (node servicer.Node, err error)
  • func (s *Service) RegistryName() string

Types

type Config

type Config struct {
	ServiceName  string `validate:"required"`
	RegistryName string
	Type         uint8  `validate:"required,oneof=1 2"`
	Host         string `validate:"required"`
	Port         int    `validate:"required"`
	Selector     string `validate:"required,oneof=wr"` // TODO support others
	CaCrt        string
	ClientPem    string
	ClientKey    string
}

type Option

type Option func(*Service)

func WithDiscovery

func WithDiscovery(discovery registry.Discovery) Option

func WithSelector

func WithSelector(selector selector.Selector) Option

type Service

type Service struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewService

func NewService(config *Config, opts ...Option) (*Service, error)

func (*Service) All

func (s *Service) All(ctx context.Context) (node []servicer.Node, err error)

func (*Service) Done

func (s *Service) Done(ctx context.Context, node servicer.Node, err error) error

func (*Service) GetCaCrt

func (s *Service) GetCaCrt() []byte

func (*Service) GetClientKey

func (s *Service) GetClientKey() []byte

func (*Service) GetClientPem

func (s *Service) GetClientPem() []byte

func (*Service) Name

func (s *Service) Name() string

func (*Service) Pick

func (s *Service) Pick(ctx context.Context) (node servicer.Node, err error)

func (*Service) RegistryName

func (s *Service) RegistryName() string