store

Documentation

Index

• func GetConfigEntry(node_type string) (interface{}, error)
• func GetSession(collection string) (*mgo.Session, *mgo.Collection, error)
• func MakeNodeID(length int) string
• func RemoveNodeEntry(node_type, id string) error
• func SetConfig(c *config.Server)
• func SetConfigEntry(node_type string, config interface{}) error
• func UpdateNodeEntry(node_type, id string, request NodeCreateRequest) error
• func UpdateNodeEntryLastSeen(node_type, id string) error
• type ConfigEntry
  • func (c ConfigEntry) FromMap(m bson.M) ConfigEntry
  • func (c ConfigEntry) ToMap() bson.M
• type NodeCreateRequest
• type NodeEntry
  • func CreateNodeEntry(node_type string, request NodeCreateRequest) (NodeEntry, error)
  • func GetNodeEntries(node_type string) ([]NodeEntry, error)
  • func GetNodeEntry(node_type, id string) (NodeEntry, error)
  • func (c NodeEntry) FromMap(m bson.M) NodeEntry
  • func (c NodeEntry) ToMap() bson.M
• type ValidationError
  • func (e ValidationError) Error() string

Functions

func GetConfigEntry

func GetConfigEntry(node_type string) (interface{}, error)

func GetSession

func GetSession(collection string) (*mgo.Session, *mgo.Collection, error)

func MakeNodeID

func MakeNodeID(length int) string

func RemoveNodeEntry

func RemoveNodeEntry(node_type, id string) error

func SetConfig

func SetConfig(c *config.Server)

func SetConfigEntry

func SetConfigEntry(node_type string, config interface{}) error

func UpdateNodeEntry

func UpdateNodeEntry(node_type, id string, request NodeCreateRequest) error

func UpdateNodeEntryLastSeen

func UpdateNodeEntryLastSeen(node_type, id string) error

Types

type ConfigEntry

type ConfigEntry struct {
	NodeType      string      `json:"node_type" bson:"_id"`
	LastUpdated   time.Time   `json:"lastUpdated" bson:"lastUpdated"`
	Configuration interface{} `json:"config" bson:"config"`
}

func (ConfigEntry) FromMap

func (c ConfigEntry) FromMap(m bson.M) ConfigEntry

func (ConfigEntry) ToMap

func (c ConfigEntry) ToMap() bson.M

type NodeCreateRequest

type NodeCreateRequest struct {
	Hostname string `json:"hostname"`
	Port     int    `json:"port"`
}

type NodeEntry

type NodeEntry struct {
	ID       string    `json:"id" bson:"_id"`
	NodeType string    `json:"node_type" bson:"node_type"`
	Hostname string    `json:"hostname" bson:"hostname"`
	Port     int       `json:"port" bson:"port"`
	LastSeen time.Time `json:"lastSeen" bson:"lastSeen"`
}

func CreateNodeEntry

func CreateNodeEntry(node_type string, request NodeCreateRequest) (NodeEntry, error)

func GetNodeEntries

func GetNodeEntries(node_type string) ([]NodeEntry, error)

func GetNodeEntry

func GetNodeEntry(node_type, id string) (NodeEntry, error)

func (NodeEntry) FromMap

func (c NodeEntry) FromMap(m bson.M) NodeEntry

func (NodeEntry) ToMap

func (c NodeEntry) ToMap() bson.M

type ValidationError

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

func (ValidationError) Error

func (e ValidationError) Error() string