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
Constants ¶
View Source
const ( ClusterIDKey clusterIDKeyType = "cluster_auth_cluster_id" ChallengeKey = "X-Challenge" )
Variables ¶
This section is empty.
Functions ¶
func AuthorizedIDFromIncomingContext ¶ added in v0.6.0
func AuthorizedOutgoingContext ¶ added in v0.6.0
func NewClientStreamInterceptor ¶ added in v0.6.2
func NewClientStreamInterceptor(id string, sharedKeys *keyring.SharedKeys) grpc.StreamClientInterceptor
func StreamAuthorizedID ¶ added in v0.5.4
func StreamAuthorizedKeys ¶ added in v0.5.4
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 ¶ added in v0.5.4
func (m *ClusterMiddleware) StreamServerInterceptor() grpc.StreamServerInterceptor
func (*ClusterMiddleware) VerifyKeyring ¶ added in v0.5.4
func (m *ClusterMiddleware) VerifyKeyring(authHeader string, expectedNonce uuid.UUID, msgBody []byte) (string, *keyring.SharedKeys, error)
Click to show internal directories.
Click to hide internal directories.