config

Documentation

Index

• Constants
• type API
• type Checkpoint
• type CouchbaseMembership
• type CouchbaseMetadata
• type DCPGroup
• type DCPGroupMembership
• type DCPListener
• type Dcp
  • func (c *Dcp) ApplyDefaults()
  • func (c *Dcp) GetCouchbaseMembership() *CouchbaseMembership
  • func (c *Dcp) GetCouchbaseMetadata() *CouchbaseMetadata
  • func (c *Dcp) GetFileMetadata() string
  • func (c *Dcp) GetKubernetesLeaderElector() *KubernetesLeaderElector
  • func (c *Dcp) IsCouchbaseMetadata() bool
  • func (c *Dcp) IsFileMetadata() bool
• type ExternalDcp
• type ExternalDcpConfig
• type HealthCheck
• type KubernetesLeaderElector
• type LeaderElection
• type Logging
• type Metadata
• type Metric
• type RPC
• type RollbackMitigation

Constants

const (
	DefaultScopeName                                = "_default"
	DefaultCollectionName                           = "_default"
	FileMetadataFileNameConfig                      = "fileName"
	MetadataTypeCouchbase                           = "couchbase"
	MetadataTypeFile                                = "file"
	MembershipTypeCouchbase                         = "couchbase"
	CouchbaseMetadataBucketConfig                   = "bucket"
	CouchbaseMetadataScopeConfig                    = "scope"
	CouchbaseMetadataCollectionConfig               = "collection"
	CouchbaseMetadataConnectionBufferSizeConfig     = "connectionBufferSize"
	CouchbaseMetadataConnectionTimeoutConfig        = "connectionTimeout"
	CheckpointTypeAuto                              = "auto"
	CouchbaseMembershipExpirySecondsConfig          = "expirySeconds"
	CouchbaseMembershipHeartbeatIntervalConfig      = "heartbeatInterval"
	CouchbaseMembershipHeartbeatToleranceConfig     = "heartbeatToleranceDuration"
	CouchbaseMembershipMonitorIntervalConfig        = "monitorInterval"
	CouchbaseMembershipTimeoutConfig                = "timeout"
	KubernetesLeaderElectorLeaseLockNameConfig      = "leaseLockName"
	KubernetesLeaderElectorLeaseLockNamespaceConfig = "leaseLockNamespace"
	KubernetesLeaderElectorLeaseDurationConfig      = "leaseDuration"
	KubernetesLeaderElectorRenewDeadlineConfig      = "renewDeadline"
	KubernetesLeaderElectorRetryPeriodConfig        = "retryPeriod"
)

Types

type API

type API struct {
	Disabled bool `yaml:"disabled"`
	Port     int  `yaml:"port"`
}

type Checkpoint

type Checkpoint struct {
	Type      string        `yaml:"type"`
	AutoReset string        `yaml:"autoReset"`
	Interval  time.Duration `yaml:"interval"`
	Timeout   time.Duration `yaml:"timeout"`
}

type CouchbaseMembership

type CouchbaseMembership struct {
	ExpirySeconds              uint32        `yaml:"expirySeconds"`
	HeartbeatInterval          time.Duration `yaml:"heartbeatInterval"`
	HeartbeatToleranceDuration time.Duration `yaml:"heartbeatToleranceDuration"`
	MonitorInterval            time.Duration `yaml:"monitorInterval"`
	Timeout                    time.Duration `yaml:"timeout"`
}

type CouchbaseMetadata

type CouchbaseMetadata struct {
	Bucket               string        `yaml:"bucket"`
	Scope                string        `yaml:"scope"`
	Collection           string        `yaml:"collection"`
	ConnectionBufferSize uint          `yaml:"connectionBufferSize"`
	ConnectionTimeout    time.Duration `yaml:"connectionTimeout"`
}

type DCPGroup

type DCPGroup struct {
	Name       string             `yaml:"name"`
	Membership DCPGroupMembership `yaml:"membership"`
}

type DCPGroupMembership

type DCPGroupMembership struct {
	Config         map[string]string `yaml:"config"`
	Type           string            `yaml:"type"`
	MemberNumber   int               `yaml:"memberNumber"`
	TotalMembers   int               `yaml:"totalMembers"`
	RebalanceDelay time.Duration     `yaml:"rebalanceDelay"`
}

type DCPListener

type DCPListener struct {
	BufferSize uint `yaml:"bufferSize"`
}

type Dcp

type Dcp struct {
	ConnectionBufferSize any                `yaml:"connectionBufferSize"`
	BucketName           string             `yaml:"bucketName"`
	ScopeName            string             `yaml:"scopeName"`
	Password             string             `yaml:"password"`
	RootCAPath           string             `yaml:"rootCAPath"`
	Username             string             `yaml:"username"`
	Logging              Logging            `yaml:"logging"`
	Metadata             Metadata           `yaml:"metadata"`
	CollectionNames      []string           `yaml:"collectionNames"`
	Hosts                []string           `yaml:"hosts"`
	Metric               Metric             `yaml:"metric"`
	Checkpoint           Checkpoint         `yaml:"checkpoint"`
	LeaderElection       LeaderElection     `yaml:"leaderElection"`
	Dcp                  ExternalDcp        `yaml:"dcp"`
	HealthCheck          HealthCheck        `yaml:"healthCheck"`
	RollbackMitigation   RollbackMitigation `yaml:"rollbackMitigation"`
	API                  API                `yaml:"api"`
	ConnectionTimeout    time.Duration      `yaml:"connectionTimeout"`
	SecureConnection     bool               `yaml:"secureConnection"`
	Debug                bool               `yaml:"debug"`
}

func (*Dcp) ApplyDefaults

func (c *Dcp) ApplyDefaults()

func (*Dcp) GetCouchbaseMembership

func (c *Dcp) GetCouchbaseMembership() *CouchbaseMembership

func (*Dcp) GetCouchbaseMetadata

func (c *Dcp) GetCouchbaseMetadata() *CouchbaseMetadata

func (*Dcp) GetFileMetadata

func (c *Dcp) GetFileMetadata() string

func (*Dcp) GetKubernetesLeaderElector

func (c *Dcp) GetKubernetesLeaderElector() *KubernetesLeaderElector

func (*Dcp) IsCouchbaseMetadata

func (c *Dcp) IsCouchbaseMetadata() bool

func (*Dcp) IsFileMetadata

func (c *Dcp) IsFileMetadata() bool

type ExternalDcp

type ExternalDcp struct {
	BufferSize           any               `yaml:"bufferSize"`
	ConnectionBufferSize any               `yaml:"connectionBufferSize"`
	Group                DCPGroup          `yaml:"group"`
	ConnectionTimeout    time.Duration     `yaml:"connectionTimeout"`
	Listener             DCPListener       `yaml:"listener"`
	Config               ExternalDcpConfig `yaml:"config"`
}

type ExternalDcpConfig

type ExternalDcpConfig struct {
	DisableChangeStreams bool `yaml:"disableChangeStreams"`
}

type HealthCheck

type HealthCheck struct {
	Disabled bool          `yaml:"disabled"`
	Interval time.Duration `yaml:"interval"`
	Timeout  time.Duration `yaml:"timeout"`
}

type KubernetesLeaderElector

type KubernetesLeaderElector struct {
	LeaseLockName      string        `yaml:"leaseLockName"`
	LeaseLockNamespace string        `yaml:"leaseLockNamespace"`
	LeaseDuration      time.Duration `yaml:"leaseDuration"`
	RenewDeadline      time.Duration `yaml:"renewDeadline"`
	RetryPeriod        time.Duration `yaml:"retryPeriod"`
}

type LeaderElection

type LeaderElection struct {
	Config  map[string]string `yaml:"config"`
	Type    string            `yaml:"type"`
	RPC     RPC               `yaml:"rpc"`
	Enabled bool              `yaml:"enabled"`
}

type Logging

type Logging struct {
	Level string `yaml:"level"`
}

type Metadata

type Metadata struct {
	Config   map[string]string `yaml:"config"`
	Type     string            `yaml:"type"`
	ReadOnly bool              `yaml:"readOnly"`
}

type Metric

type Metric struct {
	Path string `yaml:"path"`
}

type RPC

type RPC struct {
	Port int `yaml:"port"`
}

type RollbackMitigation

type RollbackMitigation struct {
	Disabled            bool          `yaml:"disabled"`
	Interval            time.Duration `yaml:"interval"`
	ConfigWatchInterval time.Duration `yaml:"configWatchInterval"`
}