dependency

Feb 20, 2019

Changes in this version

+ const VaultAgentTokenSleepTime

type CatalogNodeService

+ Meta map[string]string

type CatalogService

+ ServiceMeta map[string]string

type CreateVaultClientInput

+ Namespace string

type HealthService

+ ServiceMeta map[string]string

+ type VaultAgentTokenQuery struct

+ func NewVaultAgentTokenQuery(path string) (*VaultAgentTokenQuery, error)

+ func (d *VaultAgentTokenQuery) CanShare() bool

+ func (d *VaultAgentTokenQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultAgentTokenQuery) Stop()

+ func (d *VaultAgentTokenQuery) String() string

+ func (d *VaultAgentTokenQuery) Type() Type

Aug 25, 2017

Changes in this version

+ var ErrLeaseExpired = errors.New("lease expired or is not renewable")

type Secret

+ Auth *SecretAuth

+ Warnings []string

+ WrapInfo *SecretWrapInfo

+ type SecretAuth struct

+ Accessor string

+ ClientToken string

+ LeaseDuration int

+ Metadata map[string]string

+ Policies []string

+ Renewable bool

+ type SecretWrapInfo struct

+ CreationTime time.Time

+ TTL int

+ Token string

+ WrappedAccessor string

Jun 29, 2017

Changes in this version

type QueryOptions

+ VaultGrace time.Duration

May 9, 2017

Changes in this version

type CatalogService

+ Datacenter string

type Node

+ Datacenter string

Mar 28, 2017

Changes in this version

type CreateConsulClientInput

+ TransportIdleConnTimeout time.Duration

+ TransportMaxIdleConns int

type CreateVaultClientInput

+ TransportIdleConnTimeout time.Duration

+ TransportMaxIdleConns int

Feb 7, 2017

Changes in this version

type CatalogService

+ ID string

+ NodeMeta map[string]string

type CreateConsulClientInput

+ TransportDialKeepAlive time.Duration

+ TransportDialTimeout time.Duration

+ TransportDisableKeepAlives bool

+ TransportMaxIdleConnsPerHost int

+ TransportTLSHandshakeTimeout time.Duration

type CreateVaultClientInput

+ TransportDialKeepAlive time.Duration

+ TransportDialTimeout time.Duration

+ TransportDisableKeepAlives bool

+ TransportMaxIdleConnsPerHost int

+ TransportTLSHandshakeTimeout time.Duration

type HealthService

+ NodeID string

+ NodeMeta map[string]string

+ NodeTaggedAddresses map[string]string

type Node

+ ID string

+ Meta map[string]string

Jan 20, 2017

Changes in this version

+ var CatalogDatacentersQuerySleepTime = 15 * time.Second

+ var CatalogNodeQueryRe = regexp.MustCompile(`\A` + nameRe + dcRe + `\z`)

+ var CatalogNodesQueryRe = regexp.MustCompile(`\A` + dcRe + nearRe + `\z`)

+ var CatalogServiceQueryRe = regexp.MustCompile(`\A` + tagRe + nameRe + dcRe + nearRe + `\z`)

+ var CatalogServicesQueryRe = regexp.MustCompile(`\A` + dcRe + `\z`)

+ var EnvQuerySleepTime = 5 * time.Minute

+ var ErrContinue = errors.New("dependency continue")

+ var FileQuerySleepTime = 2 * time.Second

+ var HealthServiceQueryRe = regexp.MustCompile(`\A` + tagRe + nameRe + dcRe + nearRe + filterRe + `\z`)

+ var KVGetQueryRe = regexp.MustCompile(`\A` + keyRe + dcRe + `\z`)

+ var KVKeysQueryRe = regexp.MustCompile(`\A` + prefixRe + dcRe + `\z`)

+ var KVListQueryRe = regexp.MustCompile(`\A` + prefixRe + dcRe + `\z`)

+ var VaultDefaultLeaseDuration = 5 * time.Minute

+ type ByName []*CatalogSnippet

+ func (s ByName) Len() int

+ func (s ByName) Less(i, j int) bool

+ func (s ByName) Swap(i, j int)

+ type ByNode []*Node

+ func (s ByNode) Len() int

+ func (s ByNode) Less(i, j int) bool

+ func (s ByNode) Swap(i, j int)

+ type ByNodeThenID []*HealthService

+ func (s ByNodeThenID) Len() int

+ func (s ByNodeThenID) Less(i, j int) bool

+ func (s ByNodeThenID) Swap(i, j int)

+ type ByService []*CatalogNodeService

+ func (s ByService) Len() int

+ func (s ByService) Less(i, j int) bool

+ func (s ByService) Swap(i, j int)

+ type CatalogDatacentersQuery struct

+ func NewCatalogDatacentersQuery() (*CatalogDatacentersQuery, error)

+ func (d *CatalogDatacentersQuery) CanShare() bool

+ func (d *CatalogDatacentersQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *CatalogDatacentersQuery) Stop()

+ func (d *CatalogDatacentersQuery) String() string

+ func (d *CatalogDatacentersQuery) Type() Type

type CatalogNode

+ Node *Node

+ Services []*CatalogNodeService

+ type CatalogNodeQuery struct

+ func NewCatalogNodeQuery(s string) (*CatalogNodeQuery, error)

+ func (d *CatalogNodeQuery) CanShare() bool

+ func (d *CatalogNodeQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *CatalogNodeQuery) Stop()

+ func (d *CatalogNodeQuery) String() string

+ func (d *CatalogNodeQuery) Type() Type

+ type CatalogNodeService struct

+ Address string

+ EnableTagOverride bool

+ ID string

+ Port int

+ Service string

+ Tags ServiceTags

+ type CatalogNodesQuery struct

+ func NewCatalogNodesQuery(s string) (*CatalogNodesQuery, error)

+ func (d *CatalogNodesQuery) CanShare() bool

+ func (d *CatalogNodesQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *CatalogNodesQuery) Stop()

+ func (d *CatalogNodesQuery) String() string

+ func (d *CatalogNodesQuery) Type() Type

type CatalogService

+ Address string

+ Node string

+ ServiceAddress string

+ ServiceID string

+ ServiceName string

+ ServicePort int

+ ServiceTags ServiceTags

+ TaggedAddresses map[string]string

+ type CatalogServiceQuery struct

+ func NewCatalogServiceQuery(s string) (*CatalogServiceQuery, error)

+ func (d *CatalogServiceQuery) CanShare() bool

+ func (d *CatalogServiceQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *CatalogServiceQuery) Stop()

+ func (d *CatalogServiceQuery) String() string

+ func (d *CatalogServiceQuery) Type() Type

+ type CatalogServicesQuery struct

+ func NewCatalogServicesQuery(s string) (*CatalogServicesQuery, error)

+ func (d *CatalogServicesQuery) CanShare() bool

+ func (d *CatalogServicesQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *CatalogServicesQuery) Stop()

+ func (d *CatalogServicesQuery) String() string

+ func (d *CatalogServicesQuery) Type() Type

+ type CatalogSnippet struct

+ Name string

+ Tags ServiceTags

type CreateConsulClientInput

+ SSLCAPath string

+ ServerName string

type CreateVaultClientInput

+ SSLCAPath string

+ ServerName string

type Dependency

+ String func() string

+ Type func() Type

+ type EnvQuery struct

+ func NewEnvQuery(s string) (*EnvQuery, error)

+ func (d *EnvQuery) CanShare() bool

+ func (d *EnvQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *EnvQuery) Stop()

+ func (d *EnvQuery) String() string

+ func (d *EnvQuery) Type() Type

+ type FileQuery struct

+ func NewFileQuery(s string) (*FileQuery, error)

+ func (d *FileQuery) CanShare() bool

+ func (d *FileQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *FileQuery) Stop()

+ func (d *FileQuery) String() string

+ func (d *FileQuery) Type() Type

+ type HealthServiceQuery struct

+ func NewHealthServiceQuery(s string) (*HealthServiceQuery, error)

+ func (d *HealthServiceQuery) CanShare() bool

+ func (d *HealthServiceQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *HealthServiceQuery) Stop()

+ func (d *HealthServiceQuery) String() string

+ func (d *HealthServiceQuery) Type() Type

+ type KVGetQuery struct

+ func NewKVGetQuery(s string) (*KVGetQuery, error)

+ func (d *KVGetQuery) CanShare() bool

+ func (d *KVGetQuery) EnableBlocking()

+ func (d *KVGetQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *KVGetQuery) Stop()

+ func (d *KVGetQuery) String() string

+ func (d *KVGetQuery) Type() Type

+ type KVKeysQuery struct

+ func NewKVKeysQuery(s string) (*KVKeysQuery, error)

+ func (d *KVKeysQuery) CanShare() bool

+ func (d *KVKeysQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *KVKeysQuery) Stop()

+ func (d *KVKeysQuery) String() string

+ func (d *KVKeysQuery) Type() Type

+ type KVListQuery struct

+ func NewKVListQuery(s string) (*KVListQuery, error)

+ func (d *KVListQuery) CanShare() bool

+ func (d *KVListQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *KVListQuery) Stop()

+ func (d *KVListQuery) String() string

+ func (d *KVListQuery) Type() Type

type Node

+ TaggedAddresses map[string]string

type QueryOptions

+ Datacenter string

+ Near string

+ RequireConsistent bool

+ func (q *QueryOptions) Merge(o *QueryOptions) *QueryOptions

+ func (q *QueryOptions) String() string

+ func (q *QueryOptions) ToConsulOpts() *consulapi.QueryOptions

type ResponseMetadata

+ Block bool

type Secret

+ RequestID string

+ type Set struct

+ func (s *Set) Add(d Dependency) bool

+ func (s *Set) Get(v string) Dependency

+ func (s *Set) Len() int

+ func (s *Set) List() []Dependency

+ func (s *Set) String() string

+ type Type int

+ const TypeConsul

+ const TypeLocal

+ const TypeVault

+ type VaultListQuery struct

+ func NewVaultListQuery(s string) (*VaultListQuery, error)

+ func (d *VaultListQuery) CanShare() bool

+ func (d *VaultListQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultListQuery) Stop()

+ func (d *VaultListQuery) String() string

+ func (d *VaultListQuery) Type() Type

+ type VaultReadQuery struct

+ func NewVaultReadQuery(s string) (*VaultReadQuery, error)

+ func (d *VaultReadQuery) CanShare() bool

+ func (d *VaultReadQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultReadQuery) Stop()

+ func (d *VaultReadQuery) String() string

+ func (d *VaultReadQuery) Type() Type

+ type VaultTokenQuery struct

+ func NewVaultTokenQuery() (*VaultTokenQuery, error)

+ func (d *VaultTokenQuery) CanShare() bool

+ func (d *VaultTokenQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultTokenQuery) Stop()

+ func (d *VaultTokenQuery) String() string

+ func (d *VaultTokenQuery) Type() Type

+ type VaultWriteQuery struct

+ func NewVaultWriteQuery(s string, d map[string]interface{}) (*VaultWriteQuery, error)

+ func (d *VaultWriteQuery) CanShare() bool

+ func (d *VaultWriteQuery) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultWriteQuery) Stop()

+ func (d *VaultWriteQuery) String() string

+ func (d *VaultWriteQuery) Type() Type

Sep 22, 2016

Changes in this version

type CreateVaultClientInput

+ UnwrapToken bool

+ type FetchError struct

+ func ErrWithExit(err error) *FetchError

+ func ErrWithExitf(s string, i ...interface{}) *FetchError

+ func (e *FetchError) Error() string

+ func (e *FetchError) OriginalError() error

+ func (e *FetchError) ShouldExit() bool

type NodeService

+ Address string

Jun 9, 2016

Changes in this version

type ClientSet

+ func (c *ClientSet) CreateConsulClient(i *CreateConsulClientInput) error

+ func (c *ClientSet) CreateVaultClient(i *CreateVaultClientInput) error

+ func (c *ClientSet) Stop()

+ type CreateConsulClientInput struct

+ Address string

+ AuthEnabled bool

+ AuthPassword string

+ AuthUsername string

+ SSLCACert string

+ SSLCert string

+ SSLEnabled bool

+ SSLKey string

+ SSLVerify bool

+ Token string

+ type CreateVaultClientInput struct

+ Address string

+ SSLCACert string

+ SSLCert string

+ SSLEnabled bool

+ SSLKey string

+ SSLVerify bool

+ Token string

Mar 7, 2016

Changes in this version

+ var ErrStopped = errors.New("dependency stopped")

type CatalogNode

+ func (d *CatalogNode) Stop()

type CatalogNodes

+ func (d *CatalogNodes) Stop()

type CatalogServices

+ func (d *CatalogServices) Stop()

type Datacenters

+ func (d *Datacenters) Stop()

type Dependency

+ Stop func()

type File

+ func (d *File) Stop()

type HealthServices

+ func (d *HealthServices) Stop()

type StoreKey

+ func (d *StoreKey) Stop()

type StoreKeyPrefix

+ func (d *StoreKeyPrefix) Stop()

type Test

+ func (d *Test) Stop()

type TestFetchError

+ func (d *TestFetchError) Stop()

type TestRetry

+ func (d *TestRetry) Stop()

type TestStale

+ func (d *TestStale) Stop()

type VaultSecret

+ func (d *VaultSecret) Stop()

+ type VaultSecrets struct

+ Path string

+ func ParseVaultSecrets(s string) (*VaultSecrets, error)

+ func (d *VaultSecrets) CanShare() bool

+ func (d *VaultSecrets) Display() string

+ func (d *VaultSecrets) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultSecrets) HashCode() string

+ func (d *VaultSecrets) Stop()

type VaultToken

+ func ParseVaultToken() (*VaultToken, error)

+ func (d *VaultToken) Stop()

Jan 7, 2016

Changes in this version

type HealthService

+ Checks []*api.HealthCheck

Dec 10, 2015

Changes in this version

+ const HealthMaint

+ const NodeMaint

+ const ServiceMaint

type CatalogNode

+ func (d *CatalogNode) CanShare() bool

type CatalogNodes

+ func (d *CatalogNodes) CanShare() bool

type CatalogServices

+ func (d *CatalogServices) CanShare() bool

type Datacenters

+ func (d *Datacenters) CanShare() bool

type Dependency

+ CanShare func() bool

type File

+ func (d *File) CanShare() bool

type HealthServices

+ func (d *HealthServices) CanShare() bool

type StoreKey

+ func (d *StoreKey) CanShare() bool

type StoreKeyPrefix

+ func (d *StoreKeyPrefix) CanShare() bool

type Test

+ func (d *Test) CanShare() bool

type TestFetchError

+ func (d *TestFetchError) CanShare() bool

type TestRetry

+ func (d *TestRetry) CanShare() bool

type TestStale

+ func (d *TestStale) CanShare() bool

type VaultSecret

+ func (d *VaultSecret) CanShare() bool

type VaultToken

+ func (d *VaultToken) CanShare() bool

Oct 26, 2015

Changes in this version

type VaultSecret

+ Path string

Oct 9, 2015

Changes in this version

type NodeService

+ ID string

type StoreKey

+ func (d *StoreKey) SetDefault(s string)

+ type VaultToken struct

+ func (d *VaultToken) Display() string

+ func (d *VaultToken) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultToken) HashCode() string

Jun 9, 2015

Changes in this version

+ type CatalogNode struct

+ func ParseCatalogNode(s ...string) (*CatalogNode, error)

+ func (d *CatalogNode) Display() string

+ func (d *CatalogNode) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *CatalogNode) HashCode() string

+ type NodeDetail struct

+ Node *Node

+ Services NodeServiceList

+ type NodeList []*Node

+ func (s NodeList) Len() int

+ func (s NodeList) Less(i, j int) bool

+ func (s NodeList) Swap(i, j int)

+ type NodeService struct

+ Port int

+ Service string

+ Tags ServiceTags

+ type NodeServiceList []*NodeService

+ func (s NodeServiceList) Len() int

+ func (s NodeServiceList) Less(i, j int) bool

+ func (s NodeServiceList) Swap(i, j int)

Apr 29, 2015

Changes in this version

+ type ClientSet struct

+ func NewClientSet() *ClientSet

+ func (c *ClientSet) Add(client interface{}) error

+ func (c *ClientSet) Consul() (*consulapi.Client, error)

+ func (c *ClientSet) Vault() (*vaultapi.Client, error)

+ type QueryOptions struct

+ AllowStale bool

+ WaitIndex uint64

+ WaitTime time.Duration

+ type ResponseMetadata struct

+ LastContact time.Duration

+ LastIndex uint64

+ type Secret struct

+ Data map[string]interface{}

+ LeaseDuration int

+ LeaseID string

+ Renewable bool

+ type Test struct

+ Name string

+ func (d *Test) Display() string

+ func (d *Test) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *Test) HashCode() string

+ type TestFetchError struct

+ Name string

+ func (d *TestFetchError) Display() string

+ func (d *TestFetchError) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *TestFetchError) HashCode() string

+ type TestRetry struct

+ Name string

+ func (d *TestRetry) Display() string

+ func (d *TestRetry) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *TestRetry) HashCode() string

+ type TestStale struct

+ Name string

+ func (d *TestStale) Display() string

+ func (d *TestStale) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *TestStale) HashCode() string

+ type VaultSecret struct

+ func ParseVaultSecret(s string) (*VaultSecret, error)

+ func (d *VaultSecret) Display() string

+ func (d *VaultSecret) Fetch(clients *ClientSet, opts *QueryOptions) (interface{}, *ResponseMetadata, error)

+ func (d *VaultSecret) HashCode() string

Mar 30, 2015

Changes in this version

type HealthService

+ Status string

type HealthServices

+ StatusFilter ServiceStatusFilter

type KeyPair

+ CreateIndex uint64

+ Flags uint64

+ LockIndex uint64

+ ModifyIndex uint64

+ Session string

type ServiceStatusFilter

+ func NewServiceStatusFilter(s string) (ServiceStatusFilter, error)

+ func (f ServiceStatusFilter) Accept(s string) bool

Feb 19, 2015

Changes in this version

type HealthService

+ NodeAddress string

Jan 20, 2015

Changes in this version

+ type Datacenters struct

+ func ParseDatacenters(s ...string) (*Datacenters, error)

+ func (d *Datacenters) Display() string

+ func (d *Datacenters) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *Datacenters) HashCode() string

Dec 25, 2014

Changes in this version

+ const HealthAny

+ const HealthCritical

+ const HealthPassing

+ const HealthUnknown

+ const HealthWarning

+ type CatalogNodes struct

+ DataCenter string

+ func ParseCatalogNodes(s ...string) (*CatalogNodes, error)

+ func (d *CatalogNodes) Display() string

+ func (d *CatalogNodes) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *CatalogNodes) HashCode() string

+ func (d *CatalogNodes) Key() string

+ type CatalogService struct

+ Name string

+ Tags []string

+ type CatalogServices struct

+ DataCenter string

+ Name string

+ Tags []string

+ func ParseCatalogServices(s ...string) (*CatalogServices, error)

+ func (d *CatalogServices) Display() string

+ func (d *CatalogServices) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *CatalogServices) HashCode() string

+ func (d *CatalogServices) Key() string

+ type CatalogServicesList []*CatalogService

+ func (s CatalogServicesList) Len() int

+ func (s CatalogServicesList) Less(i, j int) bool

+ func (s CatalogServicesList) Swap(i, j int)

+ type Dependency interface

+ Display func() string

+ Fetch func(*api.Client, *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ HashCode func() string

+ Key func() string

+ type File struct

+ func ParseFile(s string) (*File, error)

+ func (d *File) Display() string

+ func (d *File) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *File) HashCode() string

+ func (d *File) Key() string

+ type HealthService struct

+ Address string

+ ID string

+ Name string

+ Node string

+ Port uint64

+ Tags ServiceTags

+ type HealthServiceList []*HealthService

+ func (s HealthServiceList) Len() int

+ func (s HealthServiceList) Less(i, j int) bool

+ func (s HealthServiceList) Swap(i, j int)

+ type HealthServices struct

+ DataCenter string

+ Name string

+ Port uint64

+ Status ServiceStatusFilter

+ Tag string

+ func ParseHealthServices(s ...string) (*HealthServices, error)

+ func (d *HealthServices) Display() string

+ func (d *HealthServices) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *HealthServices) HashCode() string

+ func (d *HealthServices) Key() string

+ type KeyPair struct

+ Key string

+ Path string

+ Value string

+ type Node struct

+ Address string

+ Node string

+ type ServiceStatusFilter []string

+ func (f ServiceStatusFilter) String() string

+ type ServiceTags []string

+ func (t ServiceTags) Contains(s string) bool

+ type StoreKey struct

+ DataCenter string

+ Path string

+ func ParseStoreKey(s string) (*StoreKey, error)

+ func (d *StoreKey) Display() string

+ func (d *StoreKey) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *StoreKey) HashCode() string

+ func (d *StoreKey) Key() string

+ type StoreKeyPrefix struct

+ DataCenter string

+ Prefix string

+ func ParseStoreKeyPrefix(s string) (*StoreKeyPrefix, error)

+ func (d *StoreKeyPrefix) Display() string

+ func (d *StoreKeyPrefix) Fetch(client *api.Client, options *api.QueryOptions) (interface{}, *api.QueryMeta, error)

+ func (d *StoreKeyPrefix) HashCode() string

+ func (d *StoreKeyPrefix) Key() string