grpc

Documentation

Index

• func CreateServer(s *Settings) *grpc.Server
• func Dial(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func HostMetrics(ctx context.Context, port int) func() error
• func HostServer(ctx context.Context, server *grpc.Server, port int) func() error
• func WaitTillServiceIsAvailable(host string, port int, duration time.Duration) error
• func WithInsecure() grpc.DialOption
• type Settings

Functions

func CreateServer

func CreateServer(s *Settings) *grpc.Server

CreateServer will create a grpc server with tracing, prometheus stats, and logging

func Dial

func Dial(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

Dial creates a client connection to the given target

func HostMetrics

func HostMetrics(ctx context.Context, port int) func() error

HostMetrics will host the prometheus metrics

func HostServer

func HostServer(ctx context.Context, server *grpc.Server, port int) func() error

HostServer will host the grpc server and gracefully stop if the context is completed

func WaitTillServiceIsAvailable

func WaitTillServiceIsAvailable(host string, port int, duration time.Duration) error

WaitTillServiceIsAvailable uses the ping service to wait till a grpc server is available

func WithInsecure

func WithInsecure() grpc.DialOption

WithInsecure returns a DialOption which disables transport security for this ClientConn. Note that transport security is required unless WithInsecure is set.

Types

type Settings

type Settings struct {
	JaegerAgentHost            string
	DefaultUDPSpanServerPort   string
	ServerName                 string
	BiDirectionalStreamTimeout time.Duration
	Sampler                    jaegerClient.Sampler
}

Settings are the settings for the grpc service