postgres

package

v1.19.0 Latest Latest Go to latest Published: Oct 22, 2026 License: Apache-2.0 Imports: 24 Imported by: 1

Details

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

Repository

github.com/dapr/components-contrib

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewPostgresConfigurationStore(logger logger.Logger) configuration.Store
func NewPostgresConfigurationStoreWithOptions(logger logger.Logger, opts Options) configuration.Store
type ConfigurationStore
type Options

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 (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

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