dialmanager

package
v0.0.0-...-e246948 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 7, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL