postgres

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2025 License: Apache-2.0 Imports: 22 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	QueryTableExists = "SELECT EXISTS (SELECT FROM pg_tables where tablename = $1)"
)

Variables

This section is empty.

Functions

func NewPostgresConfigurationStore 

func NewPostgresConfigurationStore(logger logger.Logger) configuration.Store

func NewPostgresConfigurationStoreWithOptions added in v1.16.0 

func NewPostgresConfigurationStoreWithOptions(logger logger.Logger, opts Options) configuration.Store

NewPostgresConfigurationStoreWithOptions creates a new instance of PostgreSQL store with options.

Types

type ConfigurationStore 

type ConfigurationStore struct {
	ActiveSubscriptions map[string]*subscription
	// contains filtered or unexported fields
}

func (*ConfigurationStore) Close added in v1.15.0 

func (p *ConfigurationStore) Close() error

func (*ConfigurationStore) Get 

func (p *ConfigurationStore) Get(ctx context.Context, req *configuration.GetRequest) (*configuration.GetResponse, error)

func (*ConfigurationStore) GetComponentMetadata added in v1.11.0 

func (p *ConfigurationStore) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)

GetComponentMetadata returns the metadata of the component.

func (*ConfigurationStore) Init 

func (p *ConfigurationStore) Init(ctx context.Context, metadata configuration.Metadata) error

func (*ConfigurationStore) Subscribe 

func (p *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, handler configuration.UpdateHandler) (string, error)

func (*ConfigurationStore) Unsubscribe 

func (p *ConfigurationStore) Unsubscribe(ctx context.Context, req *configuration.UnsubscribeRequest) error

type Options added in v1.16.0 

type Options struct {
	// Disables support for authenticating with Azure AD
	NoAzureAD bool

	// Disables support for authenticating with AWS IAM
	NoAWSIAM bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.