config

Documentation

Index

• Constants
• type API
• type Checkpoint
• type DCPGroup
• type DCPGroupMembership
• type DCPListener
• type Dcp
  • func (c *Dcp) ApplyDefaults()
  • func (c *Dcp) GetCouchbaseMetadata() (string, string, string, uint, time.Duration)
  • func (c *Dcp) GetFileMetadata() string
  • func (c *Dcp) IsCollectionModeEnabled() bool
  • func (c *Dcp) IsCouchbaseMetadata() bool
  • func (c *Dcp) IsFileMetadata() bool
• type ExternalDcp
• type HealthCheck
• type LeaderElection
• 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"
)

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 DCPGroup

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

type DCPGroupMembership

type DCPGroupMembership struct {
	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 {
	Username             string             `yaml:"username"`
	BucketName           string             `yaml:"bucketName"`
	ScopeName            string             `yaml:"scopeName"`
	Password             string             `yaml:"password"`
	RootCAPath           string             `yaml:"rootCAPath"`
	Metadata             Metadata           `yaml:"metadata"`
	Hosts                []string           `yaml:"hosts"`
	CollectionNames      []string           `yaml:"collectionNames"`
	Metric               Metric             `yaml:"metric"`
	Checkpoint           Checkpoint         `yaml:"checkpoint"`
	LeaderElection       LeaderElection     `yaml:"leaderElector"`
	Dcp                  ExternalDcp        `yaml:"dcp"`
	HealthCheck          HealthCheck        `yaml:"healthCheck"`
	API                  API                `yaml:"api"`
	RollbackMitigation   RollbackMitigation `yaml:"rollbackMitigation"`
	ConnectionTimeout    time.Duration      `yaml:"connectionTimeout"`
	ConnectionBufferSize uint               `yaml:"connectionBufferSize"`
	SecureConnection     bool               `yaml:"secureConnection"`
	Debug                bool               `yaml:"debug"`
}

func (*Dcp) ApplyDefaults

func (c *Dcp) ApplyDefaults()

func (*Dcp) GetCouchbaseMetadata

func (c *Dcp) GetCouchbaseMetadata() (string, string, string, uint, time.Duration)

func (*Dcp) GetFileMetadata

func (c *Dcp) GetFileMetadata() string

func (*Dcp) IsCollectionModeEnabled

func (c *Dcp) IsCollectionModeEnabled() bool

func (*Dcp) IsCouchbaseMetadata

func (c *Dcp) IsCouchbaseMetadata() bool

func (*Dcp) IsFileMetadata

func (c *Dcp) IsFileMetadata() bool

type ExternalDcp

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

type HealthCheck

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

type LeaderElection

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

type Metadata

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

type Metric

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

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"`
}