policydata

Documentation

Index

• type DataConfig
• type Duration
  • func (d *Duration) UnmarshalJSON(b []byte) error
• type Refresher
  • func NewRefresher(storage Storage, pollInterval time.Duration, httpClient *http.Client, ...) *Refresher
  • func (e *Refresher) Execute(ctx context.Context, p *storage.Policy)
  • func (e *Refresher) Start(ctx context.Context) error
• type Storage

Types

type DataConfig

type DataConfig struct {
	URL    string
	Method string
	Period Duration
	Body   interface{}
}

type Duration

type Duration time.Duration

func (*Duration) UnmarshalJSON

func (d *Duration) UnmarshalJSON(b []byte) error

type Refresher

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

func NewRefresher

func NewRefresher(
	storage Storage,
	pollInterval time.Duration,
	httpClient *http.Client,
	logger *zap.Logger,
) *Refresher

func (*Refresher) Execute

func (e *Refresher) Execute(ctx context.Context, p *storage.Policy)

func (*Refresher) Start

func (e *Refresher) Start(ctx context.Context) error

type Storage

type Storage interface {
	GetRefreshPolicies(ctx context.Context) ([]*storage.Policy, error)
	UpdateNextRefreshTime(ctx context.Context, p *storage.Policy, nextDataRefreshTime time.Time) error
}