manager

package
v0.2.2 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 2019 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ClientOptions = []grpc.DialOption{
	grpc.WithInsecure(),
	grpc.WithKeepaliveParams(keepalive.ClientParameters{
		Time:                30 * time.Second,
		Timeout:             10 * time.Second,
		PermitWithoutStream: true,
	}),
}

Functions

func NewChecker

func NewChecker(ctx context.Context, req nfdb.Request) *checker

func NewClient

func NewClient(host string, port int) (*grpc.ClientConn, error)

func NewTLSClient

func NewTLSClient(host string, port int, tlsConfig *tls.Config) (*grpc.ClientConn, error)

Types

type GrpcServer

type GrpcServer struct {
	ServiceName string
	Port        int
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(serviceName string, port int) *GrpcServer

func (*GrpcServer) Serve

func (g *GrpcServer) Serve(callback RegisterCallback, opt ...grpc.ServerOption)

func (*GrpcServer) ShowErrorCause

func (g *GrpcServer) ShowErrorCause(b bool) *GrpcServer

func (*GrpcServer) WithBuilder

func (g *GrpcServer) WithBuilder(b builderT) *GrpcServer

func (*GrpcServer) WithChecker

func (g *GrpcServer) WithChecker(c checkerT) *GrpcServer

type RegisterCallback

type RegisterCallback func(*grpc.Server)

Jump to

Keyboard shortcuts

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