grpcserverutil

package

v0.0.4 Latest Latest Go to latest Published: Nov 19, 2022 License: Apache-2.0 Imports: 9 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/gonzojive/heatpump

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpcserverutil contains utilities for running gRPC servers.

TODO(reddaly): Rename package gcputil.

Index ¶

func DialSecure[T any](ctx context.Context, addr string, ...) (T, error)
func ServeUntilCancelled(ctx context.Context, server *grpc.Server, lis net.Listener) error
func SystemTLSCredentials() (credentials.TransportCredentials, error)
type Address
- func AddressFlag[ClientT any](name string, defaultVal string, usage string, ...) *Address[ClientT]
- func RegisterAddressFlag[ClientT any](fs *flag.FlagSet, name string, defaultVal string, usage string, ...) *Address[ClientT]
- func (a *Address[ClientT]) Dial(ctx context.Context, opts ...grpc.DialOption) (ClientT, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DialSecure ¶

func DialSecure[T any](ctx context.Context, addr string, factory func(conn *grpc.ClientConn) (T, error)) (T, error)

DialSecure dials a gRPC service securely using the system cert pool and calls the factory method to construct a client.

func ServeUntilCancelled ¶

func ServeUntilCancelled(ctx context.Context, server *grpc.Server, lis net.Listener) error

ServeUntilCancelled calls server.Serve until the provided context is cancelled. When cancellation occurs, server.GracefulStop is called.

func SystemTLSCredentials ¶

func SystemTLSCredentials() (credentials.TransportCredentials, error)

SystemTLSCredentials returns the standard transport credentials for connecting to a TLS server.

Types ¶

type Address ¶

type Address[ClientT any] struct {
	// contains filtered or unexported fields
}

Address is primarily used for defining flags that can be used to instantiate gRPC clients.

func AddressFlag ¶

func AddressFlag[ClientT any](
	name string,
	defaultVal string,
	usage string,
	factory func(ctx context.Context, conn *grpc.ClientConn) (ClientT, error)) *Address[ClientT]

AddressFlag defines a new flag of type Address[ClientT].

func RegisterAddressFlag ¶

func RegisterAddressFlag[ClientT any](
	fs *flag.FlagSet,
	name string,
	defaultVal string,
	usage string,
	factory func(ctx context.Context, conn *grpc.ClientConn) (ClientT, error)) *Address[ClientT]

RegisterAddressFlag defines a new flag of type Address[ClientT].

func (*Address[ClientT]) Dial ¶

func (a *Address[ClientT]) Dial(ctx context.Context, opts ...grpc.DialOption) (ClientT, error)

Dial creates a new connection to the provided address and returns a client that uses that connection.

Source Files ¶

View all Source files

grpcserverutil.go

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