component

Documentation

Index

• func ConfigComponentIsInitialized(path string) bool
• func DatastoreComponentIsInitialized(path string) bool
• func InitConfigComponent(path string, conf *config.Config) error
• func InitDatastoreComponent(path string, conf *config.Config) error
• type Component
• type ConfigComponent
  • func (c *ConfigComponent) Close() error
  • func (c *ConfigComponent) Config() *config.Config
  • func (c *ConfigComponent) GetConfigKey(key string) (interface{}, error)
  • func (c *ConfigComponent) Open() error
  • func (c *ConfigComponent) SetConfig(updated *config.Config) error
  • func (c *ConfigComponent) SetConfigKey(key string, value interface{}) error
  • func (c *ConfigComponent) SetPath(p string)
• type DatastoreComponent
  • func (dsc *DatastoreComponent) Close() error
  • func (dsc *DatastoreComponent) Datastore() datastore.ThreadSafeDatastore
  • func (dsc *DatastoreComponent) Open() error
  • func (dsc *DatastoreComponent) SetPath(p string)
• type InitializationChecker
• type Initializer

Functions

func ConfigComponentIsInitialized

func ConfigComponentIsInitialized(path string) bool

ConfigComponentIsInitialized returns true if the repo is initialized at provided |path|.

func DatastoreComponentIsInitialized

func DatastoreComponentIsInitialized(path string) bool

DatastoreComponentIsInitialized returns true if the datastore dir exists.

func InitConfigComponent

func InitConfigComponent(path string, conf *config.Config) error

fsrepoConfigInit initializes the FSRepo's ConfigComponent.

func InitDatastoreComponent

func InitDatastoreComponent(path string, conf *config.Config) error

Types

type Component

type Component interface {
	Open() error
	io.Closer
	SetPath(string)
}

type ConfigComponent

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

ConfigComponent abstracts the config component of the FSRepo. NB: create with makeConfigComponent function. NOT THREAD-SAFE

func (*ConfigComponent) Close

func (c *ConfigComponent) Close() error

Close satisfies the fsrepoComponent interface.

func (*ConfigComponent) Config

func (c *ConfigComponent) Config() *config.Config

func (*ConfigComponent) GetConfigKey

func (c *ConfigComponent) GetConfigKey(key string) (interface{}, error)

GetConfigKey retrieves only the value of a particular key.

func (*ConfigComponent) Open

func (c *ConfigComponent) Open() error

Open returns an error if the config file is not present.

func (*ConfigComponent) SetConfig

func (c *ConfigComponent) SetConfig(updated *config.Config) error

SetConfig updates the config file.

func (*ConfigComponent) SetConfigKey

func (c *ConfigComponent) SetConfigKey(key string, value interface{}) error

SetConfigKey writes the value of a particular key.

func (*ConfigComponent) SetPath

func (c *ConfigComponent) SetPath(p string)

type DatastoreComponent

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

DatastoreComponent abstracts the datastore component of the FSRepo.

func (*DatastoreComponent) Close

func (dsc *DatastoreComponent) Close() error

func (*DatastoreComponent) Datastore

func (dsc *DatastoreComponent) Datastore() datastore.ThreadSafeDatastore

func (*DatastoreComponent) Open

func (dsc *DatastoreComponent) Open() error

Open returns an error if the config file is not present.

func (*DatastoreComponent) SetPath

func (dsc *DatastoreComponent) SetPath(p string)

type InitializationChecker

type InitializationChecker func(path string) bool

type Initializer

type Initializer func(path string, conf *config.Config) error