service

Documentation

Index

• func GetAppFromSelectors(selectors []string) string
• func GetHostFromSelectors(selectors []string) string
• func GetInstanceFromSelectors(selectors []string) string
• func GetNamespaceFromSelectors(selectors []string) string
• func GetSubDomainFromSelectors(selectors []string) string
• type ApplicationService
  • func NewApplicationService(client client.Client) *ApplicationService
  • func (s *ApplicationService) App(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)
  • func (s ApplicationService) GenerateDiscourseManifests(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)
  • func (s ApplicationService) GenerateHedgedocManifests(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)
  • func (s ApplicationService) GenerateNextcloudManifests(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)
  • func (s *ApplicationService) ListApps(ctx context.Context, selectors []string) (apps map[string][]string, err error)
• type DumpService
  • func NewDumpService(client client.Client) *DumpService
  • func (s DumpService) GetDumpCmd(ctx context.Context, selectors []string) (*exec.Cmd, error)
• type NetworkService
  • func NewNetworkService(client client.Client) *NetworkService
  • func (s *NetworkService) GetCert(ctx context.Context, selectors []string) (crt, key, ca []byte, err error)
  • func (s *NetworkService) Name() string
  • func (s *NetworkService) OwnedConditions() []string
  • func (s *NetworkService) ProxyTraffic(ctx context.Context, selectors []string, dest string) error
  • func (s *NetworkService) ResumeTraffic(ctx context.Context, selectors []string) error
• type ObjectsService
  • func NewObjectsService(client client.Client, madminClient *madmin.AdminClient) *ObjectsService
  • func (s *ObjectsService) GetSyncStatus(ctx context.Context, selectors []string, name string) (portabilityv1alpha1.SyncStatus, error)
  • func (s *ObjectsService) StartSync(ctx context.Context, selectors []string, name string, ...) error
  • func (s *ObjectsService) StopSync(ctx context.Context, selectors []string, name string) error
• type TenantService
  • func NewTenantService(client client.Client, config configv1alpha1.KeycloakConfig) *TenantService
  • func (s TenantService) GenerateRealmManifest(ctx context.Context, provider configv1alpha1.KeycloakProvider, ...) ([]byte, error)
  • func (s *TenantService) ListTenants(ctx context.Context) (selectors [][]string, err error)
  • func (s *TenantService) Tenant(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)

Functions

func GetAppFromSelectors

func GetAppFromSelectors(selectors []string) string

func GetHostFromSelectors

func GetHostFromSelectors(selectors []string) string

func GetInstanceFromSelectors

func GetInstanceFromSelectors(selectors []string) string

func GetNamespaceFromSelectors

func GetNamespaceFromSelectors(selectors []string) string

func GetSubDomainFromSelectors

func GetSubDomainFromSelectors(selectors []string) string

Types

type ApplicationService

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

func NewApplicationService

func NewApplicationService(client client.Client) *ApplicationService

func (*ApplicationService) App

func (s *ApplicationService) App(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)

func (ApplicationService) GenerateDiscourseManifests

func (s ApplicationService) GenerateDiscourseManifests(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)

func (ApplicationService) GenerateHedgedocManifests

func (s ApplicationService) GenerateHedgedocManifests(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)

func (ApplicationService) GenerateNextcloudManifests

func (s ApplicationService) GenerateNextcloudManifests(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)

func (*ApplicationService) ListApps

func (s *ApplicationService) ListApps(ctx context.Context, selectors []string) (apps map[string][]string, err error)

type DumpService

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

func NewDumpService

func NewDumpService(client client.Client) *DumpService

func (DumpService) GetDumpCmd

func (s DumpService) GetDumpCmd(ctx context.Context, selectors []string) (*exec.Cmd, error)

type NetworkService

type NetworkService struct {
	client.Client
}

func NewNetworkService

func NewNetworkService(client client.Client) *NetworkService

func (*NetworkService) GetCert

func (s *NetworkService) GetCert(ctx context.Context, selectors []string) (crt, key, ca []byte, err error)

func (*NetworkService) Name

func (s *NetworkService) Name() string

func (*NetworkService) OwnedConditions

func (s *NetworkService) OwnedConditions() []string

func (*NetworkService) ProxyTraffic

func (s *NetworkService) ProxyTraffic(ctx context.Context, selectors []string, dest string) error

func (*NetworkService) ResumeTraffic

func (s *NetworkService) ResumeTraffic(ctx context.Context, selectors []string) error

type ObjectsService

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

func NewObjectsService

func NewObjectsService(client client.Client, madminClient *madmin.AdminClient) *ObjectsService

func (*ObjectsService) GetSyncStatus

func (s *ObjectsService) GetSyncStatus(ctx context.Context, selectors []string, name string) (portabilityv1alpha1.SyncStatus, error)

func (*ObjectsService) StartSync

func (s *ObjectsService) StartSync(ctx context.Context, selectors []string, name string, s3client *portabilityv1alpha1.S3Client) error

func (*ObjectsService) StopSync

func (s *ObjectsService) StopSync(ctx context.Context, selectors []string, name string) error

type TenantService

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

func NewTenantService

func NewTenantService(client client.Client, config configv1alpha1.KeycloakConfig) *TenantService

func (TenantService) GenerateRealmManifest

func (s TenantService) GenerateRealmManifest(ctx context.Context, provider configv1alpha1.KeycloakProvider, tenantName, realmName string) ([]byte, error)

func (*TenantService) ListTenants

func (s *TenantService) ListTenants(ctx context.Context) (selectors [][]string, err error)

func (*TenantService) Tenant

func (s *TenantService) Tenant(ctx context.Context, selectors []string) (manifest []byte, extra [][]byte, err error)