store

Documentation

Index

• type FakeStore
  • func (s *FakeStore) Delete(id string) error
  • func (s *FakeStore) Error(id string, message string) error
  • func (s *FakeStore) MarkForRetry(id string) error
  • func (s *FakeStore) StoreHook(forwardURL string, body []byte, header map[string][]string) (string, error)
  • func (s *FakeStore) Success(id string) error
• type Store
  • func NewKubernetesStore() Store

Types

type FakeStore

type FakeStore struct {
	MessageIDs        []string
	SuccessMessageIDs []string
	ErroredMessageIDs []string
	DeletedMessageIDs []string
	RetryMessageIDs   []string
}

func (*FakeStore) Delete

func (s *FakeStore) Delete(id string) error

func (*FakeStore) Error

func (s *FakeStore) Error(id string, message string) error

func (*FakeStore) MarkForRetry

func (s *FakeStore) MarkForRetry(id string) error

func (*FakeStore) StoreHook

func (s *FakeStore) StoreHook(forwardURL string, body []byte, header map[string][]string) (string, error)

func (*FakeStore) Success

func (s *FakeStore) Success(id string) error

type Store

type Store interface {
	// StoreHook stores a webhook in the store.
	StoreHook(forwardURL string, body []byte, headers map[string][]string) (string, error)

	// Success marks a hook as successful.
	Success(id string) error

	// Marks a hook as error, with the error message.
	Error(id string, message string) error

	// Deletes a hook from the store.
	Delete(id string) error

	// Updates a hook to state it has been reattempted.
	MarkForRetry(id string) error
}

Store interface to implement a storage strategy.

func NewKubernetesStore

func NewKubernetesStore() Store