providers

Documentation

Index

• Constants
• Variables
• func KubernetesConfigMapFromState(state StateV2) corev1.ConfigMap
• func KubernetesConfigMapToState(state *StateV2, cm corev1.ConfigMap) error
• func PartitionToName(partition string) string
• func PartitionToSelector(partition string) labels.Selector
• type Clockodo
• type FileDiskFormat
• type FileOrMemoryProvider
  • func NewFileProvider(path string) *FileOrMemoryProvider
  • func NewMemoryProvider() *FileOrMemoryProvider
  • func (store *FileOrMemoryProvider) NotifyUser(event cloudevents.Event) error
  • func (store *FileOrMemoryProvider) Refresh(partition string) (StateV2, error)
  • func (store *FileOrMemoryProvider) Save(partition string, state StateV2) error
  • func (store *FileOrMemoryProvider) SaveRecord(rec api.Record) (api.Record, error)
• type KubernetesProvider
  • func NewKubernetesProvider(logger zap.SugaredLogger, kubeconfig string) (*KubernetesProvider, error)
  • func (kube *KubernetesProvider) Refresh(partition string) (StateV2, error)
  • func (kube *KubernetesProvider) RefreshNamespace() error
  • func (kube *KubernetesProvider) Save(partition string, data StateV2) error
  • func (kube *KubernetesProvider) SaveRecord(rec api.Record) (api.Record, error)
• type ProviderReturnType
  • func CreateJob(data *StateV2, new api.Job) ProviderReturnType
  • func CreateUser(data *StateV2, new api.User) ProviderReturnType
  • func DeleteJob(data *StateV2, del api.Job) (api.Job, ProviderReturnType)
  • func GetJob(data *StateV2, j api.Job) (api.Job, ProviderReturnType)
  • func GetTemplate(data *StateV2, name string) (api.RecordTemplate, ProviderReturnType)
  • func GetUser(data *StateV2, u api.User) (api.User, ProviderReturnType)
  • func HasTemplate(data *StateV2, name string) (bool, ProviderReturnType)
  • func ListJobs(data *StateV2) ([]api.Job, ProviderReturnType)
  • func ListTemplates(data *StateV2) ([]api.RecordTemplate, ProviderReturnType)
  • func ListUsers(data *StateV2) ([]api.User, ProviderReturnType)
  • func SaveRecord(data *StateV2, rec api.Record) ProviderReturnType
  • func UpdateJob(data *StateV2, updated api.Job) ProviderReturnType
  • func UpdateUser(data *StateV2, updated api.User) ProviderReturnType
  • func (prov ProviderReturnType) Error() string
• type StateV2
• type WebhookProvider
  • func NewWebhookProvider(url string) (*WebhookProvider, error)
  • func (prov *WebhookProvider) NotifyUser(ev cloudevents.Event) error

Constants

const (
	KubernetesLabelScope        string = "timerec.buc.sh/scope"
	KubernetesLabelPause        string = "timerec.buc.sh/pause"
	KubernetesLabelType         string = "timerec.buc.sh/type"
	KubernetesLabelAppName      string = "app.kubernetes.io/name"
	KubernetesLabelAppManagedBy string = "app.kubernetes.io/managed-by"
	KubernetesAnnotationSchema  string = "timerec.buc.sh/schema"
	KubernetesDataTypeDatastore string = "datastore"
	KubernetesDataAppName       string = "timerec"
	ConfigMapNamePrefix         string = "timerec-"
)

const ScopeGlobal string = "global"

Variables

var KubernetesDataPauseValues []string = []string{"true", "yes", "t", "y"}

Functions

func KubernetesConfigMapFromState

func KubernetesConfigMapFromState(state StateV2) corev1.ConfigMap

func KubernetesConfigMapToState

func KubernetesConfigMapToState(state *StateV2, cm corev1.ConfigMap) error

func PartitionToName

func PartitionToName(partition string) string

func PartitionToSelector

func PartitionToSelector(partition string) labels.Selector

Types

type Clockodo

type Clockodo struct {
}

type FileDiskFormat

type FileDiskFormat map[string]StateV2

type FileOrMemoryProvider

type FileOrMemoryProvider struct {
	Path string
	Data StateV2
}

func NewFileProvider

func NewFileProvider(path string) *FileOrMemoryProvider

func NewMemoryProvider

func NewMemoryProvider() *FileOrMemoryProvider

func (*FileOrMemoryProvider) NotifyUser

func (store *FileOrMemoryProvider) NotifyUser(event cloudevents.Event) error

func (*FileOrMemoryProvider) Refresh

func (store *FileOrMemoryProvider) Refresh(partition string) (StateV2, error)

func (*FileOrMemoryProvider) Save

func (store *FileOrMemoryProvider) Save(partition string, state StateV2) error

func (*FileOrMemoryProvider) SaveRecord

func (store *FileOrMemoryProvider) SaveRecord(rec api.Record) (api.Record, error)

type KubernetesProvider

type KubernetesProvider struct {
	Namespace string
	// contains filtered or unexported fields
}

func NewKubernetesProvider

func NewKubernetesProvider(logger zap.SugaredLogger, kubeconfig string) (*KubernetesProvider, error)

func (*KubernetesProvider) Refresh

func (kube *KubernetesProvider) Refresh(partition string) (StateV2, error)

func (*KubernetesProvider) RefreshNamespace

func (kube *KubernetesProvider) RefreshNamespace() error

func (*KubernetesProvider) Save

func (kube *KubernetesProvider) Save(partition string, data StateV2) error

func (*KubernetesProvider) SaveRecord

func (kube *KubernetesProvider) SaveRecord(rec api.Record) (api.Record, error)

type ProviderReturnType

type ProviderReturnType string

const (
	ProviderOk          ProviderReturnType = "OK"
	ProviderNotFound    ProviderReturnType = "NOT_FOUND"
	ProviderConflict    ProviderReturnType = "CONFLICT"
	ProviderForbidden   ProviderReturnType = "FORBIDDEN"
	ProviderServerError ProviderReturnType = "SERVER_ERROR"
)

func CreateJob

func CreateJob(data *StateV2, new api.Job) ProviderReturnType

func CreateUser

func CreateUser(data *StateV2, new api.User) ProviderReturnType

func DeleteJob

func DeleteJob(data *StateV2, del api.Job) (api.Job, ProviderReturnType)

func GetJob

func GetJob(data *StateV2, j api.Job) (api.Job, ProviderReturnType)

func GetTemplate

func GetTemplate(data *StateV2, name string) (api.RecordTemplate, ProviderReturnType)

func GetUser

func GetUser(data *StateV2, u api.User) (api.User, ProviderReturnType)

func HasTemplate

func HasTemplate(data *StateV2, name string) (bool, ProviderReturnType)

func ListJobs

func ListJobs(data *StateV2) ([]api.Job, ProviderReturnType)

func ListTemplates

func ListTemplates(data *StateV2) ([]api.RecordTemplate, ProviderReturnType)

func ListUsers

func ListUsers(data *StateV2) ([]api.User, ProviderReturnType)

func SaveRecord

func SaveRecord(data *StateV2, rec api.Record) ProviderReturnType

func UpdateJob

func UpdateJob(data *StateV2, updated api.Job) ProviderReturnType

func UpdateUser

func UpdateUser(data *StateV2, updated api.User) ProviderReturnType

func (ProviderReturnType) Error

func (prov ProviderReturnType) Error() string

type StateV2

type StateV2 struct {
	Partition string
	Users     []api.User
	Jobs      []api.Job
	Templates []api.RecordTemplate
	Records   []api.Record
}

type WebhookProvider

type WebhookProvider struct {
	Sink string
}

func NewWebhookProvider

func NewWebhookProvider(url string) (*WebhookProvider, error)

func (*WebhookProvider) NotifyUser

func (prov *WebhookProvider) NotifyUser(ev cloudevents.Event) error