providers

package

v0.2.10 Latest Latest Go to latest Published: Jun 1, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/thomasbuchinger/timerec

Links

Open Source Insights

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 ¶

View Source

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-"
)

View Source

const ScopeGlobal string = "global"

Variables ¶

View Source

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 ¶ added in v0.2.9

type WebhookProvider struct {
	Sink string
}

func NewWebhookProvider ¶ added in v0.2.9

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

func (*WebhookProvider) NotifyUser ¶ added in v0.2.9

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL