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
Matt Keeler f74d0cef7a
Implement/Utilize secrets for Peering Replication Stream (#13977)
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 [OSS] Pull split ns/partition var out of testing file (#13337) 3 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 Remove incorrect usage of url.PathEscape (#12184) 3 years ago
catalog_test.go test: fix flaky test TestAPI_CatalogNodes (#13779) 2 years ago
config_entry.go feat: convert destination address to slice 2 years ago
config_entry_discoverychain.go Update api module and decoding tests 3 years ago
config_entry_discoverychain_test.go [OSS] Pull split ns/partition var out of testing file (#13337) 3 years ago
config_entry_exports.go [OSS] Pull split ns/partition var out of testing file (#13337) 3 years ago
config_entry_exports_test.go [OSS] Pull split ns/partition var out of testing file (#13337) 3 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 connect: intentions are now managed as a new config entry kind "service-intentions" (#8834) 4 years ago
config_entry_mesh.go Fixup missed config entry 3 years ago
config_entry_test.go feat: convert destination address to slice 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 [OSS] Pull split ns/partition var out of testing file (#13337) 3 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 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 UDP check for service stanza #12221 (#12722) 3 years ago
health_test.go [OSS] Pull split ns/partition var out of testing file (#13337) 3 years ago
kv.go KV refactoring, part 2 (#11512) 3 years ago
kv_test.go ci: Enabled SA2002 staticcheck check 5 years ago
lock.go Make LockDelay configurable in api locks (#8621) 4 years ago
lock_test.go ci: Enabled SA2002 staticcheck check 5 years ago
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.go [OSS] Pull split ns/partition var out of testing file (#13337) 3 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 Add Cluster Peering Failover Support to Prepared Queries (#13835) 2 years ago
prepared_query_test.go [OSS] Remove remaining references to master (#11827) 3 years ago
raw.go
semaphore.go
semaphore_test.go ci: enable SA4006 staticcheck check 5 years ago
session.go api: properly close the response body 4 years ago
session_test.go ci: enable SA4006 staticcheck check 5 years ago
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 replumbing a bunch of api and agent structs for partitions (#10681) 3 years ago
txn_test.go UDP check for service stanza #12221 (#12722) 3 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