You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
consul/api
Derek Menteer 02ae66bda8
Add kv txn get-not-exists operation.
2 years ago
..
watch
.golangci.yml
README.md
acl.go Fix namespace default field names in expanded token output 3 years ago
acl_test.go syncing changes back from enterprise (#12701) 3 years ago
agent.go UDP check for service stanza #12221 (#12722) 3 years ago
agent_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
api.go Add support for merge-central-config query param (#13001) 3 years ago
api_test.go api: add the ability to specify a path prefix (#12914) 3 years ago
catalog.go fix(txn api): missing proxy config in registering proxy service (#14471) 2 years ago
catalog_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
config_entry.go Add additional parameters to envoy passive health check config (#14238) 2 years ago
config_entry_discoverychain.go Update the structs and discovery chain for service resolver redirects to cluster peers. (#14366) 2 years ago
config_entry_discoverychain_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
config_entry_exports.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
config_entry_exports_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
config_entry_gateways.go ingress: allow setting TLS min version and cipher suites in ingress gateway config entries (#11576) 3 years ago
config_entry_gateways_test.go ingress: allow setting TLS min version and cipher suites in ingress gateway config entries (#11576) 3 years ago
config_entry_intentions.go Add SourcePeer fields to relevant Intentions types (#13390) 3 years ago
config_entry_intentions_test.go
config_entry_mesh.go Fixup missed config entry 3 years ago
config_entry_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
connect.go
connect_ca.go add root_cert_ttl option for consul connect, vault ca providers (#11428) 3 years ago
connect_ca_test.go bulk rewrite using this script 3 years ago
connect_intention.go Add SourcePeer fields to relevant Intentions types (#13390) 3 years ago
connect_intention_test.go Support partitions in connect expose cmd 3 years ago
coordinate.go Remove incorrect usage of url.PathEscape (#12184) 3 years ago
coordinate_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
debug.go
debug_test.go
discovery_chain.go xds: ensure that all connect timeout configs can apply equally to tproxy direct dial connections (#12711) 3 years ago
discovery_chain_test.go xds: ensure that all connect timeout configs can apply equally to tproxy direct dial connections (#12711) 3 years ago
event.go
event_test.go
go.mod update generate token endpoint to take external addresses (#13844) 2 years ago
go.sum update generate token endpoint to take external addresses (#13844) 2 years ago
health.go fix(txn api): missing proxy config in registering proxy service (#14471) 2 years ago
health_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
kv.go KV refactoring, part 2 (#11512) 3 years ago
kv_test.go
lock.go
lock_test.go
mock_api_test.go
namespace.go remove gogo from acl protobufs 3 years ago
namespace_test.go re-run gofmt on 1.17 (#11579) 3 years ago
operator.go
operator_area.go
operator_autopilot.go
operator_autopilot_test.go
operator_keyring.go partitions: various refactors to support partitioning the serf LAN pool (#11568) 3 years ago
operator_keyring_test.go
operator_license.go
operator_raft.go
operator_raft_test.go
operator_segment.go
oss_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago
partition.go Clarify feature name in partition docstring 3 years ago
peering.go Add ACL enforcement to peering endpoints 2 years ago
peering_test.go Implement/Utilize secrets for Peering Replication Stream (#13977) 2 years ago
prepared_query.go Fix a breaking change to the API package introduced in #13835 (#14378) 2 years ago
prepared_query_test.go [OSS] Remove remaining references to master (#11827) 3 years ago
raw.go
semaphore.go
semaphore_test.go
session.go
session_test.go
snapshot.go
snapshot_test.go
status.go
status_test.go bulk rewrite using this script 3 years ago
txn.go Add kv txn get-not-exists operation. 2 years ago
txn_test.go fix(api): OSS<->ENT exported service incompatibility 2 years ago

README.md

Consul API client

This package provides the api package which attempts to provide programmatic access to the full Consul API.

Currently, all of the Consul APIs included in version 0.6.0 are supported.

Documentation

The full documentation is available on Godoc

Usage

Below is an example of using the Consul client:

package main

import "github.com/hashicorp/consul/api"
import "fmt"

func main() {
	// Get a new client
	client, err := api.NewClient(api.DefaultConfig())
	if err != nil {
		panic(err)
	}

	// Get a handle to the KV API
	kv := client.KV()

	// PUT a new KV pair
	p := &api.KVPair{Key: "REDIS_MAXCLIENTS", Value: []byte("1000")}
	_, err = kv.Put(p, nil)
	if err != nil {
		panic(err)
	}

	// Lookup the pair
	pair, _, err := kv.Get("REDIS_MAXCLIENTS", nil)
	if err != nil {
		panic(err)
	}
	fmt.Printf("KV: %v %s\n", pair.Key, pair.Value)
}

To run this example, start a Consul server:

consul agent -dev

Copy the code above into a file such as main.go.

Install and run. You'll see a key (REDIS_MAXCLIENTS) and value (1000) printed.

$ go get
$ go run main.go
KV: REDIS_MAXCLIENTS 1000

After running the code, you can also view the values in the Consul UI on your local machine at http://localhost:8500/ui/dc1/kv