store

package

v0.1.1 Latest Latest Go to latest Published: May 20, 2016 License: Apache-2.0 Imports: 9 Imported by: 25

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/leveros/leveros

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func DeleteEnv(as *aerospike.Client, env string) error
func EnvExists(as *aerospike.Client, env string) (exists bool, err error)
func InitServiceTable(as *aerospike.Client) error
func NewAerospike() (as *aerospike.Client, err error)
func NewEnv(as *aerospike.Client, env string, description string) error
func NewService(as *aerospike.Client, env string, service string, description string, ...) error
func NewServiceCodeVersion(as *aerospike.Client, env string, service string) (newVersion int64, err error)
func ServiceExists(as *aerospike.Client, env string, service string) (exists bool, err error)
func ServiceServingData(as *aerospike.Client, env string, service string) (servingID string, liveVersion int64, isPublic bool, err error)
func SetServiceLiveCodeVersion(as *aerospike.Client, env string, service string, version int64) (err error)
func UpdateService(as *aerospike.Client, env string, service string, description string, ...) (err error)
type EnvData
type ServiceData

Constants ¶

View Source

const PackageName = "store"

PackageName is the name of this package.

Variables ¶

View Source

var (
	// AerospikeFromConsulFlag indicates whether Consul should be used to get
	// an Aerospike client.
	AerospikeFromConsulFlag = config.DeclareBool(
		PackageName, "aerospikeFromConsul")
	// AerospikeFixedAddrFlag indicates a fixed address which is used if
	// AerospikeFromConsulFlag is false.
	AerospikeFixedAddrFlag = config.DeclareString(
		PackageName, "aerospikeFixedAddr", "leverosaerospike:3000")
)

Functions ¶

func DeleteEnv ¶

func DeleteEnv(as *aerospike.Client, env string) error

DeleteEnv removes an env.

func EnvExists ¶

func EnvExists(as *aerospike.Client, env string) (exists bool, err error)

EnvExists returns true iff the env exists.

func InitServiceTable ¶

func InitServiceTable(as *aerospike.Client) error

InitServiceTable initializes the indices for the service table.

func NewAerospike ¶

func NewAerospike() (as *aerospike.Client, err error)

NewAerospike returns a new Aerospike client.

func NewEnv ¶

func NewEnv(as *aerospike.Client, env string, description string) error

NewEnv stores a new env.

func NewService ¶

func NewService(
	as *aerospike.Client, env string, service string,
	description string, isPublic bool) error

NewService stores a new service.

func NewServiceCodeVersion ¶

func NewServiceCodeVersion(
	as *aerospike.Client, env string, service string) (
	newVersion int64, err error)

NewServiceCodeVersion generates a version number of the code and returns it.

func ServiceExists ¶

func ServiceExists(
	as *aerospike.Client, env string, service string) (
	exists bool, err error)

ServiceExists returns true iff the service exists.

func ServiceServingData ¶

func ServiceServingData(
	as *aerospike.Client, env string, service string) (
	servingID string, liveVersion int64, isPublic bool, err error)

ServiceServingData retrieves information about how to serve the code for this service.

Note: This function is used on the hot path of RPC serving.

func SetServiceLiveCodeVersion ¶

func SetServiceLiveCodeVersion(
	as *aerospike.Client, env string, service string, version int64) (
	err error)

SetServiceLiveCodeVersion sets the provided version of the code as the live one.

func UpdateService ¶

func UpdateService(
	as *aerospike.Client, env string, service string, description string,
	isPublic bool, liveCodeVersion int64) (
	err error)

UpdateService updates the data associated with a service.

Types ¶

type EnvData ¶

type EnvData struct {
	Description string `as:"Description"`
}

EnvData is the data associated with the env and stored in the database.

type ServiceData ¶

type ServiceData struct {
	Env             string `as:"Env"`
	UniqueID        string `as:"ID"`
	Description     string `as:"Desc"`
	NextCodeVersion int64  `as:"NextVer"`
	LiveCodeVersion int64  `as:"LiveVer"`
	IsPublic        bool   `as:"IsPub"`
}

ServiceData is the data associated with the service and stored in the database.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL