persist

Documentation

Index

• type ConfigMapPersist
  • func (cmp *ConfigMapPersist) Get(key string) (*Event, error)
  • func (cmp *ConfigMapPersist) IsEnabled() bool
  • func (cmp *ConfigMapPersist) Save(event *Event) error
• type Event
• type EventPersist
  • func NewConfigMapPersist(ctx context.Context, client kubernetes.Interface, ...) (EventPersist, error)
• type NullPersistence
  • func (n *NullPersistence) Get(key string) (*Event, error)
  • func (cmp *NullPersistence) IsEnabled() bool
  • func (n *NullPersistence) Save(event *Event) error

Types

type ConfigMapPersist

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

func (*ConfigMapPersist) Get

func (cmp *ConfigMapPersist) Get(key string) (*Event, error)

func (*ConfigMapPersist) IsEnabled

func (cmp *ConfigMapPersist) IsEnabled() bool

func (*ConfigMapPersist) Save

func (cmp *ConfigMapPersist) Save(event *Event) error

type Event

type Event struct {
	EventKey     string
	EventPayload string
}

type EventPersist

type EventPersist interface {
	Save(event *Event) error
	Get(key string) (*Event, error)
	IsEnabled() bool
}

func NewConfigMapPersist

func NewConfigMapPersist(ctx context.Context, client kubernetes.Interface, configmap *v1alpha1.ConfigMapPersistence, namespace string) (EventPersist, error)

type NullPersistence

type NullPersistence struct {
}

func (*NullPersistence) Get

func (n *NullPersistence) Get(key string) (*Event, error)

func (*NullPersistence) IsEnabled

func (cmp *NullPersistence) IsEnabled() bool

func (*NullPersistence) Save

func (n *NullPersistence) Save(event *Event) error