cluster

Documentation

Index

• Constants
• func AuthorizedID(c *gin.Context) string
• func AuthorizedIDFromIncomingContext(ctx context.Context) (string, bool)
• func AuthorizedKeys(c *gin.Context) *keyring.SharedKeys
• func AuthorizedOutgoingContext(ctx context.Context) context.Context
• 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) Handle(c *gin.Context)
  • func (m *ClusterMiddleware) StreamServerInterceptor() grpc.StreamServerInterceptor
  • func (m *ClusterMiddleware) UnaryServerInterceptor() grpc.UnaryServerInterceptor
  • func (m *ClusterMiddleware) VerifyKeyring(authHeader string, msgBody []byte) (int, string, *keyring.SharedKeys)
• type ClusterMiddlewareOption
  • func WithExcludeGRPCMethodsFromAuth(methods ...string) ClusterMiddlewareOption
• type ClusterMiddlewareOptions

Constants

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

Functions

func AuthorizedID

func AuthorizedID(c *gin.Context) string

func AuthorizedIDFromIncomingContext

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

func AuthorizedKeys

func AuthorizedKeys(c *gin.Context) *keyring.SharedKeys

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

Types

type ClusterMiddleware

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

func New

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

func (*ClusterMiddleware) Handle

func (m *ClusterMiddleware) Handle(c *gin.Context)

func (*ClusterMiddleware) StreamServerInterceptor

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

func (*ClusterMiddleware) UnaryServerInterceptor

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

func (*ClusterMiddleware) VerifyKeyring

func (m *ClusterMiddleware) VerifyKeyring(authHeader string, msgBody []byte) (int, string, *keyring.SharedKeys)

type ClusterMiddlewareOption

type ClusterMiddlewareOption func(*ClusterMiddlewareOptions)

func WithExcludeGRPCMethodsFromAuth

func WithExcludeGRPCMethodsFromAuth(methods ...string) ClusterMiddlewareOption

type ClusterMiddlewareOptions

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