dialmanager

Documentation

Index

• Variables
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) AddUpstream(ctx context.Context, upstreams []RpcClientConf) error
  • func (m *Manager) DelUpstream(ctx context.Context, name string) error
  • func (m *Manager) MethodDetail(ctx context.Context, method string) (parser.MethodDesc, error)
  • func (m *Manager) Methods(ctx context.Context) (map[string][]string, error)
  • func (m *Manager) Upstream(ctx context.Context, name string) (RpcClientConf, error)
  • func (m *Manager) UpstreamClient(ctx context.Context, name string) (grpc.ClientConnInterface, error)
  • func (m *Manager) Upstreams(ctx context.Context) ([]RpcClientConf, error)
• type RpcClient
• type RpcClientConf

Variables

var ErrNotFound = errors.New("not found")

Types

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) AddUpstream

func (m *Manager) AddUpstream(ctx context.Context, upstreams []RpcClientConf) error

func (*Manager) DelUpstream

func (m *Manager) DelUpstream(ctx context.Context, name string) error

func (*Manager) MethodDetail

func (m *Manager) MethodDetail(ctx context.Context, method string) (parser.MethodDesc, error)

func (*Manager) Methods

func (m *Manager) Methods(ctx context.Context) (map[string][]string, error)

func (*Manager) Upstream

func (m *Manager) Upstream(ctx context.Context, name string) (RpcClientConf, error)

func (*Manager) UpstreamClient

func (m *Manager) UpstreamClient(ctx context.Context, name string) (grpc.ClientConnInterface, error)

func (*Manager) Upstreams

func (m *Manager) Upstreams(ctx context.Context) ([]RpcClientConf, error)

type RpcClient

type RpcClient struct {
	RpcClientConf
	zrpc.Client

	ServicesDesc []parser.ServiceDesc
}

type RpcClientConf

type RpcClientConf struct {
	Name string
	zrpc.RpcClientConf
}