lb

package

v0.0.0-...-2aa8555 Latest Latest Go to latest Published: Jan 6, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/meitu/bifrost

Links

Open Source Insights

Documentation ¶

Index ¶

func RegisterTestServer(s *grpc.Server, srv TestServer)
type Node
- func NewNode(c clientv3.Config, srvName, addr string) (*Node, error)
- func (n *Node) Deregister() error
- func (n *Node) Register() error
type NodeData
type Resolver
- func NewResolver(c clientv3.Config, srvName string) *Resolver
- func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)
- func (r *Resolver) Close()
- func (r *Resolver) ResolveNow(o resolver.ResolveNowOption)
- func (r *Resolver) Scheme() string
- func (r *Resolver) ServerAddrs() []string
- func (r *Resolver) URL() string
type SayReq
- func (*SayReq) Descriptor() ([]byte, []int)
- func (m *SayReq) GetContent() string
- func (*SayReq) ProtoMessage()
- func (m *SayReq) Reset()
- func (m *SayReq) String() string
- func (m *SayReq) XXX_DiscardUnknown()
- func (m *SayReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SayReq) XXX_Merge(src proto.Message)
- func (m *SayReq) XXX_Size() int
- func (m *SayReq) XXX_Unmarshal(b []byte) error
type SayResp
- func (*SayResp) Descriptor() ([]byte, []int)
- func (m *SayResp) GetContent() string
- func (*SayResp) ProtoMessage()
- func (m *SayResp) Reset()
- func (m *SayResp) String() string
- func (m *SayResp) XXX_DiscardUnknown()
- func (m *SayResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SayResp) XXX_Merge(src proto.Message)
- func (m *SayResp) XXX_Size() int
- func (m *SayResp) XXX_Unmarshal(b []byte) error
type TestClient
- func NewTestClient(cc *grpc.ClientConn) TestClient
type TestServer
type UnimplementedTestServer
- func (*UnimplementedTestServer) Say(ctx context.Context, req *SayReq) (*SayResp, error)
type Watcher
- func NewWatcher(key string, cc clientv3.Config) (*Watcher, error)
- func (w *Watcher) Close()
- func (w *Watcher) GetAllNodes() (ret []resolver.Address)
- func (w *Watcher) Watch(addrs []resolver.Address, cc resolver.ClientConn)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RegisterTestServer ¶

func RegisterTestServer(s *grpc.Server, srv TestServer)

Types ¶

type Node ¶

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

func NewNode ¶

func NewNode(c clientv3.Config, srvName, addr string) (*Node, error)

func (*Node) Deregister ¶

func (n *Node) Deregister() error

func (*Node) Register ¶

func (n *Node) Register() error

type NodeData ¶

type NodeData struct {
	Key  string `json:"-"`
	Addr string `json:"addr"`
}

type Resolver ¶

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

func NewResolver ¶

func NewResolver(c clientv3.Config, srvName string) *Resolver

func (*Resolver) Build ¶

func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)

func (*Resolver) Close ¶

func (r *Resolver) Close()

Close closes the resolver.

func (*Resolver) ResolveNow ¶

func (r *Resolver) ResolveNow(o resolver.ResolveNowOption)

ResolveNow will be called by gRPC to try to resolve the target name again. It's just a hint, resolver can ignore this if it's not necessary.

func (*Resolver) Scheme ¶

func (r *Resolver) Scheme() string

func (*Resolver) ServerAddrs ¶

func (r *Resolver) ServerAddrs() []string

func (*Resolver) URL ¶

func (r *Resolver) URL() string

type SayReq ¶

type SayReq struct {
	Content              string   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SayReq) Descriptor ¶

func (*SayReq) Descriptor() ([]byte, []int)

func (*SayReq) GetContent ¶

func (m *SayReq) GetContent() string

func (*SayReq) ProtoMessage ¶

func (*SayReq) ProtoMessage()

func (*SayReq) Reset ¶

func (m *SayReq) Reset()

func (*SayReq) String ¶

func (m *SayReq) String() string

func (*SayReq) XXX_DiscardUnknown ¶

func (m *SayReq) XXX_DiscardUnknown()

func (*SayReq) XXX_Marshal ¶

func (m *SayReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SayReq) XXX_Merge ¶

func (m *SayReq) XXX_Merge(src proto.Message)

func (*SayReq) XXX_Size ¶

func (m *SayReq) XXX_Size() int

func (*SayReq) XXX_Unmarshal ¶

func (m *SayReq) XXX_Unmarshal(b []byte) error

type SayResp ¶

type SayResp struct {
	Content              string   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SayResp) Descriptor ¶

func (*SayResp) Descriptor() ([]byte, []int)

func (*SayResp) GetContent ¶

func (m *SayResp) GetContent() string

func (*SayResp) ProtoMessage ¶

func (*SayResp) ProtoMessage()

func (*SayResp) Reset ¶

func (m *SayResp) Reset()

func (*SayResp) String ¶

func (m *SayResp) String() string

func (*SayResp) XXX_DiscardUnknown ¶

func (m *SayResp) XXX_DiscardUnknown()

func (*SayResp) XXX_Marshal ¶

func (m *SayResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SayResp) XXX_Merge ¶

func (m *SayResp) XXX_Merge(src proto.Message)

func (*SayResp) XXX_Size ¶

func (m *SayResp) XXX_Size() int

func (*SayResp) XXX_Unmarshal ¶

func (m *SayResp) XXX_Unmarshal(b []byte) error

type TestClient ¶

type TestClient interface {
	Say(ctx context.Context, in *SayReq, opts ...grpc.CallOption) (*SayResp, error)
}

TestClient is the client API for Test service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTestClient ¶

func NewTestClient(cc *grpc.ClientConn) TestClient

type TestServer ¶

type TestServer interface {
	Say(context.Context, *SayReq) (*SayResp, error)
}

TestServer is the server API for Test service.

type UnimplementedTestServer ¶

type UnimplementedTestServer struct {
}

UnimplementedTestServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestServer) Say ¶

func (*UnimplementedTestServer) Say(ctx context.Context, req *SayReq) (*SayResp, error)

type Watcher ¶

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

func NewWatcher ¶

func NewWatcher(key string, cc clientv3.Config) (*Watcher, error)

func (*Watcher) Close ¶

func (w *Watcher) Close()

func (*Watcher) GetAllNodes ¶

func (w *Watcher) GetAllNodes() (ret []resolver.Address)

func (*Watcher) Watch ¶

func (w *Watcher) Watch(addrs []resolver.Address, cc resolver.ClientConn)

Source Files ¶

View all Source files

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