cluster

Documentation

Index

• Constants
• func AuthorizedID(c *fiber.Ctx) string
• func AuthorizedKeys(c *fiber.Ctx) *keyring.SharedKeys
• 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 *fiber.Ctx) error
  • func (m *ClusterMiddleware) StreamServerInterceptor() grpc.StreamServerInterceptor
  • func (m *ClusterMiddleware) UnaryServerInterceptor() grpc.UnaryServerInterceptor
• 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 *fiber.Ctx) string

func AuthorizedKeys

func AuthorizedKeys(c *fiber.Ctx) *keyring.SharedKeys

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 *fiber.Ctx) error

func (*ClusterMiddleware) StreamServerInterceptor

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

func (*ClusterMiddleware) UnaryServerInterceptor

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

type ClusterMiddlewareOption

type ClusterMiddlewareOption func(*ClusterMiddlewareOptions)

func WithExcludeGRPCMethodsFromAuth

func WithExcludeGRPCMethodsFromAuth(methods ...string) ClusterMiddlewareOption

type ClusterMiddlewareOptions

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