postgresql

package
v1.2.0 Latest Latest
Warning

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

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

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

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"`
	Username      string   `yaml:"username"`
	Password      string   `yaml:"password"`
	DBName        string   `yaml:"db_name"`
	NotifyChannel string   `yaml:"notify_channel"`
	ElectPath     string   `yaml:"elect_path"`
}

type Postgresql

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

func New

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

func (*Postgresql) Close

func (p *Postgresql) Close() error

func (*Postgresql) Delete

func (p *Postgresql) Delete(ctx context.Context, key string) error

func (*Postgresql) Exists

func (p *Postgresql) Exists(ctx context.Context, key string) (bool, error)

func (*Postgresql) Get

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

func (*Postgresql) ID

func (p *Postgresql) ID() string

func (*Postgresql) IsReady

func (p *Postgresql) IsReady(ctx context.Context) bool

func (*Postgresql) Leader

func (p *Postgresql) Leader() string

func (*Postgresql) LeaderChange

func (p *Postgresql) LeaderChange() <-chan bool

func (*Postgresql) List

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

func (*Postgresql) Set

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

Jump to

Keyboard shortcuts

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