dns

Documentation

Index

• func ParseSRVRecord(rec string) (srv, proto, name string, err error)
• type SRVResolver
  • func NewSRVResolver(service string, proto string, name string, resolveInterval time.Duration, ...) *SRVResolver
  • func (r *SRVResolver) Close()
  • func (r *SRVResolver) Resolve(ctx context.Context) error
  • func (r *SRVResolver) Targets() []string
  • func (r *SRVResolver) Update() <-chan SRVUpdate
• type SRVUpdate

Functions

func ParseSRVRecord

func ParseSRVRecord(rec string) (srv, proto, name string, err error)

ParseSRVRecord returns the different elements of SRV records by parsing rec string.

Types

type SRVResolver

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

SRVResolver performs SRV resolution and optionally runs those in background sending periodical updates.

func NewSRVResolver

func NewSRVResolver(
	service string,
	proto string,
	name string,
	resolveInterval time.Duration,
	logger log.Logger,
) *SRVResolver

NewSRVResolver creates and initializes a new SRVResolver instance.

func (*SRVResolver) Close

func (r *SRVResolver) Close()

Close stops running SRV resolution.

func (*SRVResolver) Resolve

func (r *SRVResolver) Resolve(ctx context.Context) error

Resolve performs SRV resolution and starts running background updates.

func (*SRVResolver) Targets

func (r *SRVResolver) Targets() []string

Targets returns last resolved SRV targets.

func (*SRVResolver) Update

func (r *SRVResolver) Update() <-chan SRVUpdate

Update returns the SRV record updates channel.

type SRVUpdate

type SRVUpdate struct {
	// NewTargets contains the set of new targets compared to previous resolution.
	NewTargets []string

	// OldTargets contains the set of removed targets compared to previous resolution.
	OldTargets []string
}

SRVUpdate represents an SRV resolution update.