cluster

Documentation

Index

• Constants
• func AuthorizedIDFromIncomingContext(ctx context.Context) (string, bool)
• func AuthorizedOutgoingContext(ctx context.Context) context.Context
• func StreamAuthorizedID(ctx context.Context) string
• func StreamAuthorizedKeys(ctx context.Context) *keyring.SharedKeys
• func StreamClientInterceptor(challenge challenges.ChallengeHandler) grpc.StreamClientInterceptor
• func StreamServerInterceptor(challenge challenges.ChallengeHandler) grpc.StreamServerInterceptor
• type ClientMetadata

Constants

const (
	ClusterIDKey  clusterIDKeyType  = "cluster_auth_cluster_id"
	SharedKeysKey sharedKeysKeyType = "cluster_auth_shared_keys"
)

Functions

func AuthorizedIDFromIncomingContext

func AuthorizedIDFromIncomingContext(ctx context.Context) (string, bool)

func AuthorizedOutgoingContext

func AuthorizedOutgoingContext(ctx context.Context) context.Context

func StreamAuthorizedID

func StreamAuthorizedID(ctx context.Context) string

func StreamAuthorizedKeys

func StreamAuthorizedKeys(ctx context.Context) *keyring.SharedKeys

func StreamClientInterceptor

func StreamClientInterceptor(challenge challenges.ChallengeHandler) grpc.StreamClientInterceptor

func StreamServerInterceptor

func StreamServerInterceptor(challenge challenges.ChallengeHandler) grpc.StreamServerInterceptor

Types

type ClientMetadata

type ClientMetadata struct {
	IdAssertion string
	Random      []byte
}