connect

Documentation

Index

• func NewResolver(client HealthAPI, service string, opts ...ResolverOption) naming.Resolver
• type AgentAPI
• type HealthAPI
• type ResolverOption
  • func WithDebug(debugf func(format string, args ...interface{})) ResolverOption
  • func WithLogger(logf func(format string, args ...interface{})) ResolverOption
• type Service
  • func NewService(agent AgentAPI, service string, port int, opts ...ServiceOption) (*Service, error)
  • func (s *Service) Close() error
• type ServiceOption
  • func WithHealthCheckFunc(fn func() error) ServiceOption
  • func WithHealthCheckInterval(interval time.Duration) ServiceOption

Functions

func NewResolver

func NewResolver(client HealthAPI, service string, opts ...ResolverOption) naming.Resolver

Types

type AgentAPI

type AgentAPI interface {
	ServiceRegister(ctx context.Context, registration consulapi.AgentServiceRegistration) error
	ServiceDeregister(ctx context.Context, serviceID string) error
	UpdateTTL(ctx context.Context, status consulapi.Status, checkID, output string) error
}

type HealthAPI

type HealthAPI interface {
	Connect(ctx context.Context, service string, passing bool) ([]consulapi.HealthServiceEntry, error)
}

type ResolverOption

type ResolverOption func(*resolverOptions)

func WithDebug

func WithDebug(debugf func(format string, args ...interface{})) ResolverOption

func WithLogger

func WithLogger(logf func(format string, args ...interface{})) ResolverOption

type Service

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

func NewService

func NewService(agent AgentAPI, service string, port int, opts ...ServiceOption) (*Service, error)

func (*Service) Close

func (s *Service) Close() error

type ServiceOption

type ServiceOption func(*serviceOptions)

func WithHealthCheckFunc

func WithHealthCheckFunc(fn func() error) ServiceOption

func WithHealthCheckInterval

func WithHealthCheckInterval(interval time.Duration) ServiceOption