commons

Documentation

Index

• func NewAuthInfo(result *altsproto.HandshakerResult) credentials.AuthInfo
• func NewClientHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn, ...) (internal.Handshaker, error)
• func NewServerHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn, ...) (internal.Handshaker, error)
• func ResetConcurrentHandshakeSemaphoreForTesting(numberOfAllowedHandshakes int64)
• type ClientHandshakerOptions
  • func DefaultClientHandshakerOptions(serviceName string) *ClientHandshakerOptions
• type ServerHandshakerOptions
  • func DefaultServerHandshakerOptions(serviceName string) *ServerHandshakerOptions

Functions

func NewAuthInfo

func NewAuthInfo(result *altsproto.HandshakerResult) credentials.AuthInfo

New returns a new altsAuthInfo object given handshaker results.

func NewClientHandshaker

func NewClientHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn, opts *ClientHandshakerOptions) (internal.Handshaker, error)

func NewServerHandshaker

func NewServerHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn, opts *ServerHandshakerOptions) (internal.Handshaker, error)

func ResetConcurrentHandshakeSemaphoreForTesting

func ResetConcurrentHandshakeSemaphoreForTesting(numberOfAllowedHandshakes int64)

ResetConcurrentHandshakeSemaphoreForTesting resets the handshake semaphores to allow numberOfAllowedHandshakes concurrent handshakes each.

Types

type ClientHandshakerOptions

type ClientHandshakerOptions struct {
	ClientIdentity        *altsproto.Identity
	TargetName            string
	TargetServiceAccounts []string
	RPCVersions           *altsproto.RpcProtocolVersions
	ServiceName           string
}

ClientHandshakerOptions contains the client handshaker options that can provided by the caller.

func DefaultClientHandshakerOptions

func DefaultClientHandshakerOptions(serviceName string) *ClientHandshakerOptions

DefaultClientHandshakerOptions returns the default client handshaker options.

type ServerHandshakerOptions

type ServerHandshakerOptions struct {
	RPCVersions           *altsproto.RpcProtocolVersions
	TargetServiceAccounts []string
	ServiceName           string
}

ServerHandshakerOptions contains the server handshaker options that can provided by the caller.

func DefaultServerHandshakerOptions

func DefaultServerHandshakerOptions(serviceName string) *ServerHandshakerOptions

DefaultServerHandshakerOptions returns the default client handshaker options.