cluster

Documentation

Index

• Constants
• func AuthorizedIDFromIncomingContext(ctx context.Context) (string, bool)
• func AuthorizedOutgoingContext(ctx context.Context) context.Context
• func NewClientStreamInterceptor(id string, sharedKeys *keyring.SharedKeys) grpc.StreamClientInterceptor
• func StreamAuthorizedID(ctx context.Context) string
• func StreamAuthorizedKeys(ctx context.Context) *keyring.SharedKeys
• type ClusterMiddleware
  • func New(ctx context.Context, keyringStore storage.KeyringStoreBroker, headerKey string) (*ClusterMiddleware, error)
  • func (m *ClusterMiddleware) StreamServerInterceptor() grpc.StreamServerInterceptor
  • func (m *ClusterMiddleware) VerifyKeyring(authHeader string, expectedNonce uuid.UUID, msgBody []byte) (string, *keyring.SharedKeys, error)

Constants

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

	ChallengeKey = "X-Challenge"
)

Functions

func AuthorizedIDFromIncomingContext

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

func AuthorizedOutgoingContext

func AuthorizedOutgoingContext(ctx context.Context) context.Context

func NewClientStreamInterceptor

func NewClientStreamInterceptor(id string, sharedKeys *keyring.SharedKeys) grpc.StreamClientInterceptor

func StreamAuthorizedID

func StreamAuthorizedID(ctx context.Context) string

func StreamAuthorizedKeys

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

Types

type ClusterMiddleware

type ClusterMiddleware struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, keyringStore storage.KeyringStoreBroker, headerKey string) (*ClusterMiddleware, error)

func (*ClusterMiddleware) StreamServerInterceptor

func (m *ClusterMiddleware) StreamServerInterceptor() grpc.StreamServerInterceptor

func (*ClusterMiddleware) VerifyKeyring

func (m *ClusterMiddleware) VerifyKeyring(authHeader string, expectedNonce uuid.UUID, msgBody []byte) (string, *keyring.SharedKeys, error)