checker

Oct 23, 2019

Changes in this version

+ var Error = errs.Class("version control client error")

+ func CheckProcessVersion(ctx context.Context, log *zap.Logger, config Config, info version.Info, ...) (err error)

+ type Client struct

+ func New(config ClientConfig) *Client

+ func (client *Client) All(ctx context.Context) (ver version.AllowedVersions, err error)

+ func (client *Client) OldMinimum(ctx context.Context, serviceName string) (ver version.SemVer, err error)

+ func (client *Client) Process(ctx context.Context, processName string) (process version.Process, err error)

+ func (client *Client) ShouldUpdate(ctx context.Context, processName string, nodeID storj.NodeID) (_ bool, _ version.Version, err error)

+ type ClientConfig struct

+ RequestTimeout time.Duration

+ ServerAddress string

+ type Config struct

+ CheckInterval time.Duration

+ type DebugHandler struct

+ func NewDebugHandler(log *zap.Logger) *DebugHandler

+ func (server *DebugHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Service struct

+ Loop *sync2.Cycle

+ func NewService(log *zap.Logger, config Config, info version.Info, service string) (client *Service)

+ func (srv *Service) CheckVersion(ctx context.Context) (err error)

+ func (srv *Service) IsAllowed() bool

+ func (srv *Service) Run(ctx context.Context) (err error)