grpc

package

v0.6.9 Latest Latest Go to latest Published: Jul 21, 2020 License: MIT Imports: 12 Imported by: 1

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/lukasjarosch/genki

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	PortConfigKey        = "grpc-port"
	GracePeriodConfigKey = "grpc-grace-period"
)

View Source

const (
	HealthUnknown    = 0
	HealthServing    = 1
	HealthNotServing = 2
)

View Source

const DefaultGracePeriod = 3 * time.Second

View Source

const DefaultHealthEnabled = true

View Source

const DefaultLoggingInterceptor = true

View Source

const DefaultPort = "50051"

View Source

const DefaultPrometheusInterceptor = true

View Source

const DefaultRequestIdInterceptor = true

Variables ¶

This section is empty.

Functions ¶

func Flags ¶

func Flags() *pflag.FlagSet

Flags is a convenience function to quickly add the gRPC server options as CLI flags Implements the cli.FlagProvider type

Types ¶

type Option ¶

type Option func(*Options)

func DisableHealthServer ¶

func DisableHealthServer() Option

func DisableLoggingInterceptor ¶

func DisableLoggingInterceptor() Option

func DisablePrometheusInterceptor ¶

func DisablePrometheusInterceptor() Option

func DisableRequestIdInterceptor ¶

func DisableRequestIdInterceptor() Option

func Name ¶

func Name(name string) Option

func Port ¶

func Port(addr string) Option

func ShutdownGracePeriod ¶

func ShutdownGracePeriod(duration time.Duration) Option

type Options ¶

type Options struct {
	Port                string
	Name                string
	ShutdownGracePeriod time.Duration
	HealthServerEnabled bool
	// contains filtered or unexported fields
}

type Server ¶

type Server interface {
	ListenAndServe(ctx context.Context, wg *sync.WaitGroup)
	Server() *grpc.Server
}

func NewServer ¶

func NewServer(opts ...Option) Server

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
interceptor

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