services

README

Services

Services will talk to each other. Actors within the bloopyboi domain will use services as the interaction layer. Each service may have a client to communicate with an external service like authentik, k8s, overseerr, etc.

Documentation

Index

• Constants
• Variables
• func GetTLSTransport(insecure bool) http.RoundTripper
• type AuthentikClientGenerator
• type AuthentikService
  • func NewAuthentikService(clientgen *AuthentikClientGenerator) *AuthentikService
  • func (s *AuthentikService) GetClient() *api.APIClient
  • func (s *AuthentikService) Verify(ctx context.Context) bool
• type BlissfestService
  • func NewBlissfestService(config models.BlissfestConfig) *BlissfestService
  • func (bs *BlissfestService) GetEndTime() *time.Time
  • func (bs *BlissfestService) GetLineupImageURI() string
  • func (bs *BlissfestService) GetStartTime() *time.Time
  • func (bs *BlissfestService) GetTimeUntilEnd(fromDate *time.Time) time.Duration
  • func (bs *BlissfestService) GetTimeUntilStart(fromDate *time.Time) time.Duration
  • func (bs *BlissfestService) IsInProgress() bool
• type BotK8sMeta
• type InspiroClient
  • func NewInspiroClient() *InspiroClient
  • func NewInspiroHttpClient(inspiro *InspiroService) *InspiroClient
  • func (ic *InspiroClient) GetInspiroImageURL() string
  • func (ic *InspiroClient) GetService() *InspiroService
• type InspiroConfig
  • func GetInspiroConfig() InspiroConfig
• type InspiroService
  • func NewInspiroService() *InspiroService
  • func NewInspiroServiceWithConfig(myConfig InspiroConfig) *InspiroService
  • func (inspiroService *InspiroService) GetInspiro() string
• type K8sService
  • func NewK8sService() *K8sService
  • func (ks *K8sService) GetPodMetrics(ctx context.Context) []v1beta1.PodMetrics
  • func (ks *K8sService) GetPodNamespace(ctx context.Context) (string, error)
  • func (ks *K8sService) ListNamespaces(ctx context.Context) []coreV1.Namespace
• type OverseerrClientGenerator

Constants

const (
	ServiceLoggerFieldKey = "service_name"
	DefaultUUID           = ""
)

Variables

var (
	InspiroFeatureName  = "inspiro"
	InspiroAPIKey       = "api_url"
	InspiroBackupURLKey = "backup_image_link"
)

Functions

func GetTLSTransport

func GetTLSTransport(insecure bool) http.RoundTripper

GetTLSTransport Get a TLS transport instance, that skips verification if configured via environment variables.

Types

type AuthentikClientGenerator

type AuthentikClientGenerator struct {
	models.ClientGenerator
}

type AuthentikService

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

func NewAuthentikService

func NewAuthentikService(clientgen *AuthentikClientGenerator) *AuthentikService

func (*AuthentikService) GetClient

func (s *AuthentikService) GetClient() *api.APIClient

func (*AuthentikService) Verify

func (s *AuthentikService) Verify(ctx context.Context) bool

type BlissfestService

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

func NewBlissfestService

func NewBlissfestService(config models.BlissfestConfig) *BlissfestService

func (*BlissfestService) GetEndTime

func (bs *BlissfestService) GetEndTime() *time.Time

func (*BlissfestService) GetLineupImageURI

func (bs *BlissfestService) GetLineupImageURI() string

func (*BlissfestService) GetStartTime

func (bs *BlissfestService) GetStartTime() *time.Time

func (*BlissfestService) GetTimeUntilEnd

func (bs *BlissfestService) GetTimeUntilEnd(fromDate *time.Time) time.Duration

Gets time until end of event

func (*BlissfestService) GetTimeUntilStart

func (bs *BlissfestService) GetTimeUntilStart(fromDate *time.Time) time.Duration

Gets time until start of event

func (*BlissfestService) IsInProgress

func (bs *BlissfestService) IsInProgress() bool

Returns true if event inProgress

type BotK8sMeta

type BotK8sMeta struct {
}

type InspiroClient

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

func NewInspiroClient

func NewInspiroClient() *InspiroClient

Creates New InspiroClient with default service

func NewInspiroHttpClient

func NewInspiroHttpClient(inspiro *InspiroService) *InspiroClient

Creates New InspiroClient with specified Service

func (*InspiroClient) GetInspiroImageURL

func (ic *InspiroClient) GetInspiroImageURL() string

func (*InspiroClient) GetService

func (ic *InspiroClient) GetService() *InspiroService

type InspiroConfig

type InspiroConfig struct {
	API_url           string
	Logger            *zap.Logger
	Backup_image_link string
}

Basically a static var for this 'Object'

func GetInspiroConfig

func GetInspiroConfig() InspiroConfig

Unmarshal config from file

type InspiroService

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

should add uri validation

func NewInspiroService

func NewInspiroService() *InspiroService

Abstracted 'Constructor'

func NewInspiroServiceWithConfig

func NewInspiroServiceWithConfig(myConfig InspiroConfig) *InspiroService

'Constructs' InspiroService with declared Config

func (*InspiroService) GetInspiro

func (inspiroService *InspiroService) GetInspiro() string

returns raw uri as string without validation

type K8sService

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

func NewK8sService

func NewK8sService() *K8sService

func (*K8sService) GetPodMetrics

func (ks *K8sService) GetPodMetrics(ctx context.Context) []v1beta1.PodMetrics

func (*K8sService) GetPodNamespace

func (ks *K8sService) GetPodNamespace(ctx context.Context) (string, error)

func (*K8sService) ListNamespaces

func (ks *K8sService) ListNamespaces(ctx context.Context) []coreV1.Namespace

type OverseerrClientGenerator

type OverseerrClientGenerator struct {
	models.ClientGenerator
}