Documentation
¶
Index ¶
- Variables
- func NewControllerServer(d *ConsulDriver, consul consul.IConsul) *controllerServer
- func NewIdentityServer(d *ConsulDriver) *identityServer
- func ParseEndpoint(ep string) (string, string, error)
- func RunServer(cancel context.CancelFunc, listen string)
- func RunServers(endpoint, metricIP, metricPath string, metricPort int, ...)
- type ConsulDriver
- type NonBlockingGRPCServer
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Version = "1.0.1"
)
Functions ¶
func NewControllerServer ¶
func NewControllerServer(d *ConsulDriver, consul consul.IConsul) *controllerServer
func NewIdentityServer ¶
func NewIdentityServer(d *ConsulDriver) *identityServer
func RunServer ¶
func RunServer(cancel context.CancelFunc, listen string)
func RunServers ¶
func RunServers(endpoint, metricIP, metricPath string, metricPort int, ids gslbi.IdentityServer, cs gslbi.ControllerServer)
Types ¶
type ConsulDriver ¶
type ConsulDriver struct {
// contains filtered or unexported fields
}
func NewDriver ¶
func NewDriver(endpoint, metricIP, metricPath string, metricPort int) *ConsulDriver
func (*ConsulDriver) Run ¶
func (d *ConsulDriver) Run()
func (*ConsulDriver) SetupDriver ¶
func (d *ConsulDriver) SetupDriver(consul consul.IConsul)
type NonBlockingGRPCServer ¶
type NonBlockingGRPCServer interface {
// Start services at the endpoint
Start(endpoint, metricIP, metricPath string, metricPort int, ids gslbi.IdentityServer, cs gslbi.ControllerServer)
// Waits for the service to stop
Wait()
// Stops the service gracefully
Stop()
// Stops the service forcefully
ForceStop()
}
NonBlockingGRPCServer defines Non blocking GRPC server interfaces
func NewNonBlockingGRPCServer ¶
func NewNonBlockingGRPCServer() NonBlockingGRPCServer
Source Files
Click to show internal directories.
Click to hide internal directories.