consul

Documentation

Index

• Variables
• type Client
  • func NewClient(o *Options, logger *zap.Logger) (*Client, error)
  • func (c *Client) Deregister(_ context.Context, service *registry.ServiceInstance) error
  • func (c *Client) Register(_ context.Context, service *registry.ServiceInstance) (err error)
• type Options
  • func NewOptions(v *viper.Viper) (*Options, error)
• type Registry
  • func New(client *Client) *Registry
  • func (r *Registry) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) Register(ctx context.Context, service *registry.ServiceInstance) error

Variables

var ProviderSet = wire.NewSet(New, NewClient, NewOptions, wire.Bind(new(registry.Registrar), new(*Registry)))

Types

type Client

type Client struct {
	*Options
	// contains filtered or unexported fields
}

func NewClient

func NewClient(o *Options, logger *zap.Logger) (*Client, error)

func (*Client) Deregister

func (c *Client) Deregister(_ context.Context, service *registry.ServiceInstance) error

func (*Client) Register

func (c *Client) Register(_ context.Context, service *registry.ServiceInstance) (err error)

type Options

type Options struct {
	Addr                           string `mapstructure:"addr"`
	EnableHealthCheck              bool   `mapstructure:"enable_health_check"`
	HealthCheckInterval            int    `mapstructure:"health_check_interval"`
	DeregisterCriticalServiceAfter int    `mapstructure:"deregister_critical_service_after"`
	HeartBeat                      bool   `mapstructure:"heart_beat"`
}

func NewOptions

func NewOptions(v *viper.Viper) (*Options, error)

NewOptions creates a new set of o for the consul client.

type Registry

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

func New

func New(client *Client) *Registry

func (*Registry) Deregister

func (r *Registry) Deregister(ctx context.Context, service *registry.ServiceInstance) error

func (*Registry) Register

func (r *Registry) Register(ctx context.Context, service *registry.ServiceInstance) error