connutils

Documentation

Index

• Variables
• type AuthManager
  • func NewAuthManager() *AuthManager
  • func (s *AuthManager) Deregister(token string)
  • func (s *AuthManager) GenerateNew(connectorID string) string
  • func (s *AuthManager) IsTokenValid(token string) error
• type SchemaService
  • func NewSchemaService(logger log.CtxLogger, registry schemaregistry.Registry, ...) *SchemaService
  • func (s *SchemaService) Check(ctx context.Context) error
  • func (s *SchemaService) CreateSchema(ctx context.Context, req pconnutils.CreateSchemaRequest) (pconnutils.CreateSchemaResponse, error)
  • func (s *SchemaService) GetSchema(ctx context.Context, req pconnutils.GetSchemaRequest) (pconnutils.GetSchemaResponse, error)

Variables

var ErrInvalidToken = cerrors.New("invalid token")

Types

type AuthManager

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

func NewAuthManager

func NewAuthManager() *AuthManager

func (*AuthManager) Deregister

func (s *AuthManager) Deregister(token string)

func (*AuthManager) GenerateNew

func (s *AuthManager) GenerateNew(connectorID string) string

func (*AuthManager) IsTokenValid

func (s *AuthManager) IsTokenValid(token string) error

type SchemaService

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

func NewSchemaService

func NewSchemaService(
	logger log.CtxLogger,
	registry schemaregistry.Registry,
	authManager *AuthManager,
) *SchemaService

func (*SchemaService) Check

func (s *SchemaService) Check(ctx context.Context) error

func (*SchemaService) CreateSchema

func (s *SchemaService) CreateSchema(ctx context.Context, req pconnutils.CreateSchemaRequest) (pconnutils.CreateSchemaResponse, error)

func (*SchemaService) GetSchema

func (s *SchemaService) GetSchema(ctx context.Context, req pconnutils.GetSchemaRequest) (pconnutils.GetSchemaResponse, error)