sync

Documentation

Index

• Constants
• type DefaultEventType
• type Event
• type FilePathSync
  • func (fs *FilePathSync) Fetch(_ context.Context) (string, error)
  • func (fs *FilePathSync) Notify(ctx context.Context, w chan<- INotify)
• type HTTPSync
  • func (fs *HTTPSync) Fetch(ctx context.Context) (string, error)
  • func (fs *HTTPSync) Notify(ctx context.Context, w chan<- INotify)
• type INotify
• type ISync
• type Notifier
  • func (w *Notifier) GetEvent() Event[DefaultEventType]

Constants

const (
	DefaultEventTypeCreate = iota
	DefaultEventTypeModify = 1
	DefaultEventTypeDelete = 2
)

Types

type DefaultEventType

type DefaultEventType int32

type Event

type Event[T any] struct {
	EventType T
}

Event is a struct that represents a single event. It is a generic struct that can be cast to a more specific struct.

type FilePathSync

type FilePathSync struct {
	URI    string
	Logger *log.Entry
}

func (*FilePathSync) Fetch

func (fs *FilePathSync) Fetch(_ context.Context) (string, error)

func (*FilePathSync) Notify

func (fs *FilePathSync) Notify(ctx context.Context, w chan<- INotify)

type HTTPSync

type HTTPSync struct {
	URI         string
	Client      *http.Client
	BearerToken string
	LastBodySHA string
	Logger      *log.Entry
}

func (*HTTPSync) Fetch

func (fs *HTTPSync) Fetch(ctx context.Context) (string, error)

func (*HTTPSync) Notify

func (fs *HTTPSync) Notify(ctx context.Context, w chan<- INotify)

type INotify

type INotify interface {
	GetEvent() Event[DefaultEventType]
}

type ISync

type ISync interface {
	Fetch(ctx context.Context) (string, error)
	Notify(ctx context.Context, c chan<- INotify)
}

ISync implementations watch for changes in the flag source (HTTP backend, local file, s3 bucket), and fetch the latest values.

type Notifier

type Notifier struct {
	Event Event[DefaultEventType]
}

func (*Notifier) GetEvent

func (w *Notifier) GetEvent() Event[DefaultEventType]