syncgateway

Documentation

Index

• Constants
• Variables
• type BuildVersion
  • func NewBuildVersion(version string) (BuildVersion, error)
  • func (pv BuildVersion) Equal(b BuildVersion) bool
  • func (pv BuildVersion) LessThan(b BuildVersion) bool
  • func (ver BuildVersion) String() string
• type GatewayRegistry
• type GatewayRegistryWrapper
• type RegistryConfigGroup
• type RegistryDatabase
• type RegistryScope
• type RegistryScopes
• type SourceBucketClient
  • func NewSourceBucketClient(caller, bucketName, restPort string, s common.EventingSuperSup) (*SourceBucketClient, error)
  • func (cl *SourceBucketClient) Close()
  • func (cl *SourceBucketClient) IsDeploymentProhibited(keySpace common.Keyspace) (bool, string, error)

Constants

const (
	SyncDocPrefix = "_sync:"
	SGRegistryKey = SyncDocPrefix + "registry"
	SGSeqKey      = SyncDocPrefix + "seq"
)

Variables

var (
	RegistryAwareNonMouSGW = BuildVersion{
							// contains filtered or unexported fields
	}

	RegistryAwareMouSGW = BuildVersion{
						// contains filtered or unexported fields
	}
)

Types

type BuildVersion

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

BuildVersion is an [epoch:]major.minor.patch[.other][@build][-edition] version that has methods to reliably extract information.

func NewBuildVersion

func NewBuildVersion(version string) (BuildVersion, error)

Expected format: `[epoch:]major.minor.patch[.other][@build][-edition]`

func (BuildVersion) Equal

func (pv BuildVersion) Equal(b BuildVersion) bool

func (BuildVersion) LessThan

func (pv BuildVersion) LessThan(b BuildVersion) bool

func (BuildVersion) String

func (ver BuildVersion) String() string

type GatewayRegistry

type GatewayRegistry struct {
	Version      string                          `json:"version"`       // Registry version
	ConfigGroups map[string]*RegistryConfigGroup `json:"config_groups"` // Map of config groups, keyed by config group ID
	SGVersionStr string                          `json:"sg_version"`    // Latest patch version of Sync Gateway that touched the registry
	SGVersion    BuildVersion
}

type GatewayRegistryWrapper

type GatewayRegistryWrapper struct {
	Registry GatewayRegistry `json:"config"`
}

type RegistryConfigGroup

type RegistryConfigGroup struct {
	Databases map[string]*RegistryDatabase `json:"databases"`
}

RegistryConfigGroup stores the set of databases for a given config group

type RegistryDatabase

type RegistryDatabase struct {
	Scopes RegistryScopes `json:"scopes,omitempty"`
}

DatabaseVersion stores the version and collection set for a database.

type RegistryScope

type RegistryScope struct {
	Collections []string `json:"collections,omitempty"`
}

RegistryScope stores the list of collections for the scope as a slice

type RegistryScopes

type RegistryScopes map[string]RegistryScope

type SourceBucketClient

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

func NewSourceBucketClient

func NewSourceBucketClient(caller, bucketName, restPort string, s common.EventingSuperSup) (*SourceBucketClient, error)

func (*SourceBucketClient) Close

func (cl *SourceBucketClient) Close()

func (*SourceBucketClient) IsDeploymentProhibited

func (cl *SourceBucketClient) IsDeploymentProhibited(keySpace common.Keyspace) (bool, string, error)