schemas

Documentation

Index

• Constants
• type API
  • func NewAPI(service ServiceInterface, logger logging.LoggerInterface) *API
  • func (a *API) RegisterEndpoints(mux *chi.Mux)
• type Config
• type DefaultSchema
• type IdentitySchemaData
• type KratosError
• type Service
  • func NewService(config *Config, tracer trace.Tracer, monitor monitoring.MonitorInterface, ...) *Service
  • func (s *Service) CreateSchema(ctx context.Context, data *kClient.IdentitySchemaContainer) (*IdentitySchemaData, error)
  • func (s *Service) DeleteSchema(ctx context.Context, ID string) error
  • func (s *Service) EditSchema(ctx context.Context, ID string, data *kClient.IdentitySchemaContainer) (*IdentitySchemaData, error)
  • func (s *Service) GetDefaultSchema(ctx context.Context) (*DefaultSchema, error)
  • func (s *Service) GetSchema(ctx context.Context, ID string) (*IdentitySchemaData, error)
  • func (s *Service) ListSchemas(ctx context.Context, page, size int64) (*IdentitySchemaData, error)
  • func (s *Service) UpdateDefaultSchema(ctx context.Context, schemaID *DefaultSchema) (*DefaultSchema, error)
• type ServiceInterface

Constants

const DEFAULT_SCHEMA = "default.schema"

Types

type API

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

func NewAPI

func NewAPI(service ServiceInterface, logger logging.LoggerInterface) *API

func (*API) RegisterEndpoints

func (a *API) RegisterEndpoints(mux *chi.Mux)

type Config

type Config struct {
	Name      string
	Namespace string
	K8s       coreV1.CoreV1Interface
	Kratos    kClient.IdentityApi
}

type DefaultSchema

type DefaultSchema struct {
	ID string `json:"schema_id"`
}

type IdentitySchemaData

type IdentitySchemaData struct {
	IdentitySchemas []kClient.IdentitySchemaContainer
	Error           *kClient.GenericError
}

type KratosError

type KratosError struct {
	Error *kClient.GenericError `json:"error,omitempty"`
}

TODO @shipperizer verify during integration test if this is actually the format

type Service

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

func NewService

func NewService(config *Config, tracer trace.Tracer, monitor monitoring.MonitorInterface, logger logging.LoggerInterface) *Service

TODO @shipperizer analyze if providers IDs need to be what we use for path or if filename is the right one

func (*Service) CreateSchema

func (s *Service) CreateSchema(ctx context.Context, data *kClient.IdentitySchemaContainer) (*IdentitySchemaData, error)

func (*Service) DeleteSchema

func (s *Service) DeleteSchema(ctx context.Context, ID string) error

func (*Service) EditSchema

func (s *Service) EditSchema(ctx context.Context, ID string, data *kClient.IdentitySchemaContainer) (*IdentitySchemaData, error)

func (*Service) GetDefaultSchema

func (s *Service) GetDefaultSchema(ctx context.Context) (*DefaultSchema, error)

func (*Service) GetSchema

func (s *Service) GetSchema(ctx context.Context, ID string) (*IdentitySchemaData, error)

func (*Service) ListSchemas

func (s *Service) ListSchemas(ctx context.Context, page, size int64) (*IdentitySchemaData, error)

func (*Service) UpdateDefaultSchema

func (s *Service) UpdateDefaultSchema(ctx context.Context, schemaID *DefaultSchema) (*DefaultSchema, error)

type ServiceInterface

type ServiceInterface interface {
	ListSchemas(context.Context, int64, int64) (*IdentitySchemaData, error)
	GetSchema(context.Context, string) (*IdentitySchemaData, error)
	EditSchema(context.Context, string, *kClient.IdentitySchemaContainer) (*IdentitySchemaData, error)
	CreateSchema(context.Context, *kClient.IdentitySchemaContainer) (*IdentitySchemaData, error)
	DeleteSchema(context.Context, string) error
	GetDefaultSchema(context.Context) (*DefaultSchema, error)
	UpdateDefaultSchema(context.Context, *DefaultSchema) (*DefaultSchema, error)
}