Versions in this module Expand all Collapse all v0 v0.4.5 Apr 10, 2021 v0.4.4 Apr 10, 2021 Changes in this version + const Keyprefix + func GetChecksParams(serviceName string) map[string]interface + func GetKeyPrefixParams(keyPrefix string) map[string]interface + func GetKeysParams(key string) map[string]interface + func GetParams(kind watchKind) map[string]interface + func RegisterWatchHandler(wh WatchHandler) + type Config struct + Addr string + HealthURL string + ServiceName string + Token string + type ConsulService struct + Catalog *api.Catalog + Client *api.Client + Config *Config + KV *api.KV + ServiceIDs []string + func (ConsulService) CaddyModule() caddy.ModuleInfo + func (c *ConsulService) Cleanup() error + func (c *ConsulService) GetPeers() ([]string, error) + func (c *ConsulService) Provision(ctx caddy.Context) error + func (c *ConsulService) RegisterWatch(params map[string]interface{}, fn WatchCallback) error + func (c *ConsulService) RegisterWatches() error + func (c *ConsulService) UnmarshalCaddyfile(d *caddyfile.Dispenser) error + func (c *ConsulService) Validate() error + type DistributedLock struct + Session *api.Session + SessionID string + func NewDistributedLock(key string) (*DistributedLock, error) + func (d *DistributedLock) Destroy() + func (d *DistributedLock) Lock() (<-chan struct{}, error) + func (d *DistributedLock) Unlock() error + type WatchCallback func(data interface{}) error + type WatchHandler struct + Callback WatchCallback + Pg map[string]interface{}
Go to main page