yorkie

Documentation

Index

• Constants
• type Config
  • func NewConfig() *Config
  • func NewConfigFromFile(path string) (*Config, error)
  • func (c *Config) RPCAddr() string
  • func (c *Config) Validate() error
• type Yorkie
  • func New(conf *Config) (*Yorkie, error)
  • func (r *Yorkie) Members() map[string]*sync.AgentInfo
  • func (r *Yorkie) RPCAddr() string
  • func (r *Yorkie) Shutdown(graceful bool) error
  • func (r *Yorkie) ShutdownCh() <-chan struct{}
  • func (r *Yorkie) Start() error

Constants

const (
	DefaultRPCPort             = 11101
	DefaultRPCMaxRequestsBytes = 4 * 1024 * 1024 // 4MiB

	DefaultProfilingPort = 11102

	DefaultHousekeepingInterval            = time.Minute
	DefaultHousekeepingDeactivateThreshold = 7 * 24 * time.Hour
	DefaultHousekeepingCandidateLimit      = 500

	DefaultMongoConnectionURI     = "mongodb://localhost:27017"
	DefaultMongoConnectionTimeout = 5 * time.Second
	DefaultMongoPingTimeout       = 5 * time.Second
	DefaultMongoYorkieDatabase    = "yorkie-meta"

	DefaultSnapshotThreshold = 500
	DefaultSnapshotInterval  = 1000

	DefaultAuthWebhookMaxRetries      = 10
	DefaultAuthWebhookMaxWaitInterval = 3000 * time.Millisecond
	DefaultAuthWebhookCacheSize       = 5000
	DefaultAuthWebhookCacheAuthTTL    = 10 * time.Second
	DefaultAuthWebhookCacheUnauthTTL  = 10 * time.Second
)

Below are the values of the default values of Yorkie config.

Types

type Config

type Config struct {
	RPC          *rpc.Config          `yaml:"RPC"`
	Profiling    *profiling.Config    `yaml:"Profiling"`
	Housekeeping *housekeeping.Config `yaml:"Housekeeping"`
	Backend      *backend.Config      `yaml:"Backend"`
	Mongo        *mongo.Config        `yaml:"Mongo"`
	ETCD         *etcd.Config         `yaml:"ETCD"`
}

Config is the configuration for creating a Yorkie instance.

func NewConfig

func NewConfig() *Config

NewConfig returns a Config struct that contains reasonable defaults for most of the configurations.

func NewConfigFromFile

func NewConfigFromFile(path string) (*Config, error)

NewConfigFromFile returns a Config struct for the given conf file.

func (*Config) RPCAddr

func (c *Config) RPCAddr() string

RPCAddr returns the RPC address.

func (*Config) Validate

func (c *Config) Validate() error

Validate returns an error if the provided Config is invalidated.

type Yorkie

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

Yorkie is an agent of Yorkie framework. The agent receives changes from the client, stores them in the repository, and propagates the changes to clients who subscribe to the document.

func New

func New(conf *Config) (*Yorkie, error)

New creates a new instance of Yorkie.

func (*Yorkie) Members

func (r *Yorkie) Members() map[string]*sync.AgentInfo

Members returns the members of this cluster.

func (*Yorkie) RPCAddr

func (r *Yorkie) RPCAddr() string

RPCAddr returns the address of the RPC.

func (*Yorkie) Shutdown

func (r *Yorkie) Shutdown(graceful bool) error

Shutdown shuts down this Yorkie agent.

func (*Yorkie) ShutdownCh

func (r *Yorkie) ShutdownCh() <-chan struct{}

ShutdownCh returns the shutdown channel.

func (*Yorkie) Start

func (r *Yorkie) Start() error

Start starts the agent by opening the rpc port.