consul

package

v1.2.0 Latest Latest Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apache/kvrocks-controller

Links

Open Source Insights

Documentation ¶

Overview ¶

* Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. *

Index ¶

type Config
type Consul
- func New(id string, cfg *Config) (*Consul, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Addrs []string `yaml:"addrs"`
	TLS   struct {
		Enable   bool   `yaml:"enable"`
		CertFile string `yaml:"cert_file"`
		KeyFile  string `yaml:"key_file"`
		CAFile   string `yaml:"ca_file"`
	} `yaml:"tls"`
	ElectPath string `yaml:"elect_path"`
}

type Consul ¶

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

func New ¶

func New(id string, cfg *Config) (*Consul, error)

func (*Consul) Close ¶

func (c *Consul) Close() error

func (*Consul) Delete ¶

func (c *Consul) Delete(ctx context.Context, key string) error

func (*Consul) Exists ¶

func (c *Consul) Exists(ctx context.Context, key string) (bool, error)

func (*Consul) Get ¶

func (c *Consul) Get(ctx context.Context, key string) ([]byte, error)

func (*Consul) ID ¶

func (c *Consul) ID() string

func (*Consul) IsReady ¶

func (c *Consul) IsReady(ctx context.Context) bool

func (*Consul) Leader ¶

func (c *Consul) Leader() string

func (*Consul) LeaderChange ¶

func (c *Consul) LeaderChange() <-chan bool

func (*Consul) List ¶

func (c *Consul) List(ctx context.Context, prefix string) ([]engine.Entry, error)

func (*Consul) Set ¶

func (c *Consul) Set(ctx context.Context, key string, value []byte) error

Source Files ¶

View all Source files

consul.go

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