Documentation
¶
Index ¶
- type BaseServer
- func (bs *BaseServer) AddStartCallback(callbacks ...func())
- func (bs *BaseServer) CloseClientConns()
- func (bs *BaseServer) Context() context.Context
- func (bs *BaseServer) GetClient() *clientv3.Client
- func (bs *BaseServer) GetClientConns() *sync.Map
- func (bs *BaseServer) GetDelegateClient(ctx context.Context, tlsCfg *grpcutil.TLSConfig, forwardedHost string) (*grpc.ClientConn, error)
- func (bs *BaseServer) GetEtcdClient() *clientv3.Client
- func (bs *BaseServer) GetGRPCServer() *grpc.Server
- func (bs *BaseServer) GetHTTPClient() *http.Client
- func (bs *BaseServer) GetHTTPServer() *http.Server
- func (bs *BaseServer) GetListener() net.Listener
- func (bs *BaseServer) GetStartCallbacks() []func()
- func (bs *BaseServer) InitListener(tlsCfg *grpcutil.TLSConfig, listenAddr string) error
- func (bs *BaseServer) IsSecure() bool
- func (bs *BaseServer) SetEtcdClient(etcdClient *clientv3.Client)
- func (bs *BaseServer) SetGRPCServer(grpcServer *grpc.Server)
- func (bs *BaseServer) SetHTTPClient(httpClient *http.Client)
- func (bs *BaseServer) SetHTTPServer(httpServer *http.Server)
- func (bs *BaseServer) StartTimestamp() int64
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseServer ¶
type BaseServer struct {
// contains filtered or unexported fields
}
BaseServer is a basic server that provides some common functionality.
func NewBaseServer ¶
func NewBaseServer(ctx context.Context) *BaseServer
NewBaseServer creates a new BaseServer.
func (*BaseServer) AddStartCallback ¶
func (bs *BaseServer) AddStartCallback(callbacks ...func())
AddStartCallback adds a callback in the startServer phase.
func (*BaseServer) CloseClientConns ¶
func (bs *BaseServer) CloseClientConns()
CloseClientConns closes all client connections.
func (*BaseServer) Context ¶
func (bs *BaseServer) Context() context.Context
Context returns the context of server.
func (*BaseServer) GetClient ¶
func (bs *BaseServer) GetClient() *clientv3.Client
GetClient returns builtin etcd client.
func (*BaseServer) GetClientConns ¶
func (bs *BaseServer) GetClientConns() *sync.Map
GetClientConns returns the client connections.
func (*BaseServer) GetDelegateClient ¶
func (bs *BaseServer) GetDelegateClient(ctx context.Context, tlsCfg *grpcutil.TLSConfig, forwardedHost string) (*grpc.ClientConn, error)
GetDelegateClient returns grpc client connection talking to the forwarded host.
func (*BaseServer) GetEtcdClient ¶
func (bs *BaseServer) GetEtcdClient() *clientv3.Client
GetEtcdClient returns the etcd client.
func (*BaseServer) GetGRPCServer ¶
func (bs *BaseServer) GetGRPCServer() *grpc.Server
GetGRPCServer returns the grpc server.
func (*BaseServer) GetHTTPClient ¶
func (bs *BaseServer) GetHTTPClient() *http.Client
GetHTTPClient returns builtin http client.
func (*BaseServer) GetHTTPServer ¶
func (bs *BaseServer) GetHTTPServer() *http.Server
GetHTTPServer returns the http server.
func (*BaseServer) GetListener ¶
func (bs *BaseServer) GetListener() net.Listener
GetListener returns the listener.
func (*BaseServer) GetStartCallbacks ¶
func (bs *BaseServer) GetStartCallbacks() []func()
GetStartCallbacks returns the start callbacks.
func (*BaseServer) InitListener ¶
func (bs *BaseServer) InitListener(tlsCfg *grpcutil.TLSConfig, listenAddr string) error
InitListener initializes the listener.
func (*BaseServer) IsSecure ¶
func (bs *BaseServer) IsSecure() bool
IsSecure checks if the server enable TLS.
func (*BaseServer) SetEtcdClient ¶
func (bs *BaseServer) SetEtcdClient(etcdClient *clientv3.Client)
SetEtcdClient sets the etcd client.
func (*BaseServer) SetGRPCServer ¶
func (bs *BaseServer) SetGRPCServer(grpcServer *grpc.Server)
SetGRPCServer sets the grpc server.
func (*BaseServer) SetHTTPClient ¶
func (bs *BaseServer) SetHTTPClient(httpClient *http.Client)
SetHTTPClient sets the http client.
func (*BaseServer) SetHTTPServer ¶
func (bs *BaseServer) SetHTTPServer(httpServer *http.Server)
SetHTTPServer sets the http server.
func (*BaseServer) StartTimestamp ¶
func (bs *BaseServer) StartTimestamp() int64
StartTimestamp returns the start timestamp of this server
Source Files