consul

package

v0.0.0-...-f4dd3ec Latest Latest Go to latest Published: Apr 3, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewConsul(consulURL, name, address string, grpcPort int, logger *zap.Logger, options ...Option) (*Consul, error)

func (c *Consul) Consul() *api.Client

func (c *Consul) RegisterService() error

func (c *Consul) Stop() error

func (c *Consul) WatchService(serviceAddr string) <-chan []*api.ServiceEntry

type Option interface {
	// contains filtered or unexported methods
}

func WithCheckDeregisterTimeout(timeout string) Option

func WithCheckInterval(interval string) Option

func WithCheckTLL(timeout string) Option

func WithCheckTimeout(timeout string) Option

func WithSelfCheckTimeout(timeout time.Duration) Option

func WithServiceCheck(addr string, port int) Option

func WithTag(tag string) Option

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

func NewPlan(consulURL string, serviceName string, input chan<- []*api.ServiceEntry) *Plan

func (p *Plan) Run(errCh chan<- error)

func (p *Plan) Stop()

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