embeddedetcd

README

embeddedetcd

An implementation to run etcd in-process in a Kube-based apiserver

Documentation

Index

• type CompletedConfig
• type Config
  • func NewConfig(o options.CompletedOptions, enableWatchCache bool) (*Config, error)
  • func (c *Config) Complete() CompletedConfig
• type Server
  • func NewServer(config CompletedConfig) *Server
  • func (s *Server) Run(ctx context.Context) error

Types

type CompletedConfig

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

type Config

type Config struct {
	*embed.Config
}

func NewConfig

func NewConfig(o options.CompletedOptions, enableWatchCache bool) (*Config, error)

func (*Config) Complete

func (c *Config) Complete() CompletedConfig

Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.

type Server

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

func NewServer

func NewServer(config CompletedConfig) *Server

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run starts the embedded etcd server. It blocks until it is ready for up to a minute.