grpc

Documentation

Index

• func JWTStreamTokenInterceptor(token string) grpc.StreamServerInterceptor
• func JWTUnaryTokenInterceptor(token string) grpc.UnaryServerInterceptor
• func NewBearerAuth(key string) *jwtAuth
• func NewClientTLSCredentials(caCertPem []byte) (credentials.TransportCredentials, error)
• func NewServerTLSCredentials(serverCertPem, serverKeyPem []byte) (credentials.TransportCredentials, error)
• func StreamCertInterceptor() grpc.StreamServerInterceptor
• func UnaryCertInterceptor() grpc.UnaryServerInterceptor
• type RegisterService
• type ResolverData
• type ResolverEntity
• type ShutdownService
  • func Startup(addr string, token string, serverCertPEM, serverKeyPEM []byte, ...) (ShutdownService, error)
• type UBResolverBuilder
  • func NewUBResolver(addrs ResolverData) *UBResolverBuilder
  • func (r *UBResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *UBResolverBuilder) Dial(name string) (*grpc.ClientConn, error)
  • func (r *UBResolverBuilder) Scheme() string

Functions

func JWTStreamTokenInterceptor

func JWTStreamTokenInterceptor(token string) grpc.StreamServerInterceptor

func JWTUnaryTokenInterceptor

func JWTUnaryTokenInterceptor(token string) grpc.UnaryServerInterceptor

func NewBearerAuth

func NewBearerAuth(key string) *jwtAuth

func NewClientTLSCredentials

func NewClientTLSCredentials(caCertPem []byte) (credentials.TransportCredentials, error)

func NewServerTLSCredentials

func NewServerTLSCredentials(serverCertPem, serverKeyPem []byte) (credentials.TransportCredentials, error)

func StreamCertInterceptor

func StreamCertInterceptor() grpc.StreamServerInterceptor

func UnaryCertInterceptor

func UnaryCertInterceptor() grpc.UnaryServerInterceptor

Types

type RegisterService

type RegisterService func(srv *grpc.Server)

type ResolverData

type ResolverData map[string]ResolverEntity

type ResolverEntity

type ResolverEntity struct {
	Addr  []string
	Token string
	Ca    []byte
}

type ShutdownService

type ShutdownService interface {
	Stop()
	GracefulStop()
}

func Startup

func Startup(addr string, token string, serverCertPEM, serverKeyPEM []byte, opts []grpc.ServerOption, register RegisterService, wg *sync.WaitGroup) (ShutdownService, error)

type UBResolverBuilder

type UBResolverBuilder struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewUBResolver

func NewUBResolver(addrs ResolverData) *UBResolverBuilder

func (*UBResolverBuilder) Build

func (r *UBResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*UBResolverBuilder) Dial

func (r *UBResolverBuilder) Dial(name string) (*grpc.ClientConn, error)

func (*UBResolverBuilder) Scheme

func (r *UBResolverBuilder) Scheme() string