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
Chris S. Kim b0a4c5c563
Include stream-related information in peering endpoints
2 years ago
..
watch tests: skip cases that depend on test server when -short flag set (#10576) 3 years ago
.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 fix(api): missing peer name in query option (#14835) 2 years ago
api_test.go Use internal server certificate for peering TLS 2 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 envoy connection balancing. (#14616) 2 years ago
config_entry_discoverychain.go Add the ability to retry on reset connection to service-routers (#12890) 2 years ago
config_entry_discoverychain_test.go Add the ability to retry on reset connection to service-routers (#12890) 2 years ago
config_entry_exports.go Rename `PeerName` to `Peer` on prepared queries and exported services (#14854) 2 years ago
config_entry_exports_test.go Rename `PeerName` to `Peer` on prepared queries and exported services (#14854) 2 years ago
config_entry_gateways.go feat(ingress gateway: support configuring limits in ingress-gateway c… (#14749) 2 years ago
config_entry_gateways_test.go feat(ingress gateway: support configuring limits in ingress-gateway c… (#14749) 2 years ago
config_entry_intentions.go Add SourcePeer fields to relevant Intentions types (#13390) 3 years ago
config_entry_intentions_test.go connect: intentions are now managed as a new config entry kind "service-intentions" (#8834) 4 years ago
config_entry_mesh.go feat: add PeerThroughMeshGateways to mesh config 2 years ago
config_entry_test.go Add envoy connection balancing. (#14616) 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 Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
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 Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
event_test.go
go.mod Upgrade serf to v0.10.1 and memberlist to v0.5.0 to get memberlist size metrics and broadcast queue depth metric (#14873) 2 years ago
go.sum Upgrade serf to v0.10.1 and memberlist to v0.5.0 to get memberlist size metrics and broadcast queue depth metric (#14873) 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 AutopilotServerHealth now handles the 429 status code (#8599) 4 years ago
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 Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
operator_autopilot.go Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
operator_autopilot_test.go add StatusError to api package (#11054) 3 years ago
operator_keyring.go partitions: various refactors to support partitioning the serf LAN pool (#11568) 3 years ago
operator_keyring_test.go
operator_license.go Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
operator_raft.go Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
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 Include stream-related information in peering endpoints 2 years ago
peering_test.go Include stream-related information in peering endpoints 2 years ago
prepared_query.go Rename `PeerName` to `Peer` on prepared queries and exported services (#14854) 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 api: properly close the response body 4 years ago
session_test.go
snapshot.go Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
snapshot_test.go
status.go Refactor requireHttpCodes for segregated error handling (#11287) 3 years ago
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