direct

README

warden/resolver/direct

项目简介

warden 的直连服务模块，用于通过IP地址列表直接连接后端服务 连接字符串格式：　direct://default/192.168.1.1:8080,192.168.1.2:8081

Documentation

Index

• Constants
• type Direct
  • func Build(id string) *Direct
  • func New() *Direct
  • func (d *Direct) Build(id string, opt ...naming.BuildOpt) naming.Resolver
  • func (d *Direct) Close() error
  • func (d *Direct) Fetch(ctx context.Context) (res *naming.InstancesInfo, found bool)
  • func (d *Direct) Scheme() string
  • func (d *Direct) Unwatch(id string)
  • func (d *Direct) Watch() <-chan struct{}

Constants

const (
	// Name is the name of direct resolver
	Name = "direct"
)

Types

type Direct

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

Direct is a resolver for conneting endpoints directly. example format: direct://default/192.168.1.1:8080,192.168.1.2:8081

func Build

func Build(id string) *Direct

Build build direct.

func New

func New() *Direct

New return Direct

func (*Direct) Build

func (d *Direct) Build(id string, opt ...naming.BuildOpt) naming.Resolver

Build direct build.

func (*Direct) Close

func (d *Direct) Close() error

Close close Direct

func (*Direct) Fetch

func (d *Direct) Fetch(ctx context.Context) (res *naming.InstancesInfo, found bool)

Fetch fetch isntances.

func (*Direct) Scheme

func (d *Direct) Scheme() string

Scheme return the Scheme of Direct

func (*Direct) Unwatch

func (d *Direct) Unwatch(id string)

Unwatch a tree.

func (*Direct) Watch

func (d *Direct) Watch() <-chan struct{}

Watch a tree.