dependency

package
v0.0.0-...-f393e77 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 8, 2016 License: MPL-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	HealthAny      = "any"
	HealthPassing  = "passing"
	HealthWarning  = "warning"
	HealthUnknown  = "unknown"
	HealthCritical = "critical"
	HealthMaint    = "maintenance"

	NodeMaint    = "_node_maintenance"
	ServiceMaint = "_service_maintenance:"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CatalogNode

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

func ParseCatalogNode

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

ParseCatalogNode parses a name name and optional datacenter value. If the name is empty or not provided then the current agent is used.

func (*CatalogNode) CanShare

func (d *CatalogNode) CanShare() bool

CanShare returns if this dependency is shareable.

func (*CatalogNode) Display

func (d *CatalogNode) Display() string

func (*CatalogNode) Fetch

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

Fetch queries the Consul API defined by the given client and returns a of NodeDetail object

func (*CatalogNode) HashCode

func (d *CatalogNode) HashCode() string

type CatalogNodes

type CatalogNodes struct {
	DataCenter string
	// contains filtered or unexported fields
}

func ParseCatalogNodes

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

ParseCatalogNodes parses a string of the format @dc.

func (*CatalogNodes) CanShare

func (d *CatalogNodes) CanShare() bool

CanShare returns if this dependency is shareable.

func (*CatalogNodes) Display

func (d *CatalogNodes) Display() string

func (*CatalogNodes) Fetch

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

Fetch queries the Consul API defined by the given client and returns a slice of Node objects

func (*CatalogNodes) HashCode

func (d *CatalogNodes) HashCode() string

type CatalogService

type CatalogService struct {
	Name string
	Tags ServiceTags
}

CatalogService is a catalog entry in Consul.

type CatalogServices

type CatalogServices struct {
	Name       string
	Tags       []string
	DataCenter string
	// contains filtered or unexported fields
}

CatalogServices is the representation of a requested catalog service dependency from inside a template.

func ParseCatalogServices

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

ParseCatalogServices parses a string of the format @dc.

func (*CatalogServices) CanShare

func (d *CatalogServices) CanShare() bool

CanShare returns if this dependency is shareable.

func (*CatalogServices) Display

func (d *CatalogServices) Display() string

Display returns a string that should be displayed to the user in output (for example).

func (*CatalogServices) Fetch

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

Fetch queries the Consul API defined by the given client and returns a slice of CatalogService objects.

func (*CatalogServices) HashCode

func (d *CatalogServices) HashCode() string

HashCode returns the hash code for this dependency.

type CatalogServicesList

type CatalogServicesList []*CatalogService

CatalogServicesList is a sortable slice of CatalogService structs.

func (CatalogServicesList) Len

func (s CatalogServicesList) Len() int

func (CatalogServicesList) Less

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

func (CatalogServicesList) Swap

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

type ClientSet

type ClientSet struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ClientSet is a collection of clients that dependencies use to communicate with remote services like Consul or Vault.

func NewClientSet

func NewClientSet() *ClientSet

NewClientSet creates a new client set that is ready to accept clients.

func (*ClientSet) Add

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

Add stores the given client.

func (*ClientSet) Consul

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

Consul returns the Consul client for this clientset, or an error if no Consul client has been set.

func (*ClientSet) Vault

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

Vault returns the Vault client for this clientset, or an error if no Vault client has been set.

type Datacenters

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

Datacenters is the dependency to query all datacenters

func ParseDatacenters

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

ParseDatacenters creates a new datacenter dependency.

func (*Datacenters) CanShare

func (d *Datacenters) CanShare() bool

CanShare returns if this dependency is shareable.

func (*Datacenters) Display

func (d *Datacenters) Display() string

Display returns a string that should be displayed to the user in output (for example).

func (*Datacenters) Fetch

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

Fetch queries the Consul API defined by the given client and returns a slice of strings representing the datacenters

func (*Datacenters) HashCode

func (d *Datacenters) HashCode() string

HashCode returns the hash code for this dependency.

type Dependency

type Dependency interface {
	Fetch(*ClientSet, *QueryOptions) (interface{}, *ResponseMetadata, error)
	CanShare() bool
	HashCode() string
	Display() string
}

Dependency is an interface for a dependency that Consul Template is capable of watching.

type File

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

func ParseFile

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

func (*File) CanShare

func (d *File) CanShare() bool

func (*File) Display

func (d *File) Display() string

func (*File) Fetch

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

func (*File) HashCode

func (d *File) HashCode() string

type HealthService

type HealthService struct {
	Node        string
	NodeAddress string
	Address     string
	ID          string
	Name        string
	Tags        ServiceTags
	Checks      []*api.HealthCheck
	Status      string
	Port        uint64
}

HealthService is a service entry in Consul.

type HealthServiceList

type HealthServiceList []*HealthService

HealthServiceList is a sortable slice of Service

func (HealthServiceList) Len

func (s HealthServiceList) Len() int

Len, Swap, and Less are used to implement the sort.Sort interface.

func (HealthServiceList) Less

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

func (HealthServiceList) Swap

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

type HealthServices

type HealthServices struct {
	Name         string
	Tag          string
	DataCenter   string
	StatusFilter ServiceStatusFilter
	// contains filtered or unexported fields
}

HealthServices is the struct that is formed from the dependency inside a template.

func ParseHealthServices

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

ParseHealthServices processes the incoming strings to build a service dependency.

Supported arguments

ParseHealthServices("service_id")
ParseHealthServices("service_id", "health_check")

Where service_id is in the format of service(.tag(@datacenter(:port))) and health_check is either "any" or "passing".

If no health_check is provided then its the same as "passing".

func (*HealthServices) CanShare

func (d *HealthServices) CanShare() bool

func (*HealthServices) Display

func (d *HealthServices) Display() string

func (*HealthServices) Fetch

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

Fetch queries the Consul API defined by the given client and returns a slice of HealthService objects.

func (*HealthServices) HashCode

func (d *HealthServices) HashCode() string

type KeyPair

type KeyPair struct {
	Path  string
	Key   string
	Value string

	// Lesser-used, but still valuable keys from api.KV
	CreateIndex uint64
	ModifyIndex uint64
	LockIndex   uint64
	Flags       uint64
	Session     string
}

KeyPair is a simple Key-Value pair

type Node

type Node struct {
	Node    string
	Address string
}

Node is a node entry in Consul

type NodeDetail

type NodeDetail struct {
	Node     *Node
	Services NodeServiceList
}

type NodeList

type NodeList []*Node

func (NodeList) Len

func (s NodeList) Len() int

func (NodeList) Less

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

func (NodeList) Swap

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

type NodeService

type NodeService struct {
	ID      string
	Service string
	Tags    ServiceTags
	Port    int
}

type NodeServiceList

type NodeServiceList []*NodeService

func (NodeServiceList) Len

func (s NodeServiceList) Len() int

func (NodeServiceList) Less

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

func (NodeServiceList) Swap

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

type QueryOptions

type QueryOptions struct {
	AllowStale bool
	WaitIndex  uint64
	WaitTime   time.Duration
}

QueryOptions is a list of options to send with the query. These options are client-agnostic, and the dependency determines which, if any, of the options to use.

type ResponseMetadata

type ResponseMetadata struct {
	LastIndex   uint64
	LastContact time.Duration
}

ResponseMetadata is a struct that contains metadata about the response. This is returned from a Fetch function call.

type Secret

type Secret struct {
	LeaseID       string
	LeaseDuration int
	Renewable     bool

	// Data is the actual contents of the secret. The format of the data
	// is arbitrary and up to the secret backend.
	Data map[string]interface{}
}

Secret is a vault secret.

type ServiceStatusFilter

type ServiceStatusFilter []string

ServiceStatusFilter is used to specify a list of service statuses that you want filter by.

func NewServiceStatusFilter

func NewServiceStatusFilter(s string) (ServiceStatusFilter, error)

NewServiceStatusFilter creates a status filter from the given string in the format `[key[,key[,key...]]]`. Each status is split on the comma character and must match one of the valid status names.

If the empty string is given, it is assumed only "passing" statuses are to be returned.

If the user specifies "any" with other keys, an error will be returned.

func (ServiceStatusFilter) Accept

func (f ServiceStatusFilter) Accept(s string) bool

Accept allows us to check if a slice of health checks pass this filter.

func (ServiceStatusFilter) String

func (f ServiceStatusFilter) String() string

String returns the string representation of this status filter

type ServiceTags

type ServiceTags []string

ServiceTags is a slice of tags assigned to a Service

func (ServiceTags) Contains

func (t ServiceTags) Contains(s string) bool

Contains returns true if the tags exists in the ServiceTags slice.

type StoreKey

type StoreKey struct {
	Path       string
	DataCenter string
	// contains filtered or unexported fields
}

from inside a template.

func ParseStoreKey

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

ParseStoreKey parses a string of the format a(/b(/c...))

func (*StoreKey) CanShare

func (d *StoreKey) CanShare() bool

func (*StoreKey) Display

func (d *StoreKey) Display() string

func (*StoreKey) Fetch

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

Fetch queries the Consul API defined by the given client and returns string of the value to Path.

func (*StoreKey) HashCode

func (d *StoreKey) HashCode() string

func (*StoreKey) SetDefault

func (d *StoreKey) SetDefault(s string)

type StoreKeyPrefix

type StoreKeyPrefix struct {
	Prefix     string
	DataCenter string
	// contains filtered or unexported fields
}

StoreKeyPrefix is the representation of a requested key dependency from inside a template.

func ParseStoreKeyPrefix

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

ParseStoreKeyPrefix parses a string of the format a(/b(/c...))

func (*StoreKeyPrefix) CanShare

func (d *StoreKeyPrefix) CanShare() bool

func (*StoreKeyPrefix) Display

func (d *StoreKeyPrefix) Display() string

func (*StoreKeyPrefix) Fetch

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

Fetch queries the Consul API defined by the given client and returns a slice of KeyPair objects

func (*StoreKeyPrefix) HashCode

func (d *StoreKeyPrefix) HashCode() string

type Test

type Test struct {
	Name string
}

Test is a special dependency that does not actually speaks to a server.

func (*Test) CanShare

func (d *Test) CanShare() bool

func (*Test) Display

func (d *Test) Display() string

func (*Test) Fetch

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

func (*Test) HashCode

func (d *Test) HashCode() string

type TestFetchError

type TestFetchError struct {
	Name string
}

TestFetchError is a special dependency that returns an error while fetching.

func (*TestFetchError) CanShare

func (d *TestFetchError) CanShare() bool

func (*TestFetchError) Display

func (d *TestFetchError) Display() string

func (*TestFetchError) Fetch

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

func (*TestFetchError) HashCode

func (d *TestFetchError) HashCode() string

type TestRetry

type TestRetry struct {
	sync.Mutex
	Name string
	// contains filtered or unexported fields
}

TestRetry is a special dependency that errors on the first fetch and succeeds on subsequent fetches.

func (*TestRetry) CanShare

func (d *TestRetry) CanShare() bool

func (*TestRetry) Display

func (d *TestRetry) Display() string

func (*TestRetry) Fetch

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

func (*TestRetry) HashCode

func (d *TestRetry) HashCode() string

type TestStale

type TestStale struct {
	Name string
}

TestStale is a special dependency that can be used to test what happens when stale data is permitted.

func (*TestStale) CanShare

func (d *TestStale) CanShare() bool

func (*TestStale) Display

func (d *TestStale) Display() string

func (*TestStale) Fetch

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

Fetch is used to implement the dependency interface.

func (*TestStale) HashCode

func (d *TestStale) HashCode() string

type VaultSecret

type VaultSecret struct {
	sync.Mutex

	Path string
	// contains filtered or unexported fields
}

VaultSecret is the dependency to Vault for a secret

func ParseVaultSecret

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

ParseVaultSecret creates a new datacenter dependency.

func (*VaultSecret) CanShare

func (d *VaultSecret) CanShare() bool

CanShare returns if this dependency is shareable.

func (*VaultSecret) Display

func (d *VaultSecret) Display() string

Display returns a string that should be displayed to the user in output (for example).

func (*VaultSecret) Fetch

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

Fetch queries the Vault API

func (*VaultSecret) HashCode

func (d *VaultSecret) HashCode() string

HashCode returns the hash code for this dependency.

type VaultToken

type VaultToken struct {
	sync.Mutex
	// contains filtered or unexported fields
}

VaultToken is the dependency to Vault for a secret

func (*VaultToken) CanShare

func (d *VaultToken) CanShare() bool

CanShare returns if this dependency is shareable.

func (*VaultToken) Display

func (d *VaultToken) Display() string

Display returns a string that should be displayed to the user in output (for example).

func (*VaultToken) Fetch

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

Fetch queries the Vault API

func (*VaultToken) HashCode

func (d *VaultToken) HashCode() string

HashCode returns the hash code for this dependency.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL