storage

package

v0.0.0-...-32a2d26 Latest Latest Go to latest Published: Dec 4, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

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

View Source

const (
	Add = iota
	Remove
)

View Source

const EventChanSize = 16

View Source

var ErrAlreadyExist = errors.New("already exist")

func RunExchanger(storage *Storage, listenAddr string, addrs []string, periodMs int)

type Event struct {
	Type int
	Key  ObjectKey
	Data string
}

type ObjectKey struct {
	Area, Node, Key string
	// contains filtered or unexported fields
}

func ReadKey(fullKey string) (k ObjectKey, err error)

func (k ObjectKey) FullKey() string

type Request struct {
	INeedFullKey string `json:"n"`
}

func (Request) Decode(buf []byte) (r Request, err error)

func (r Request) Encode() []byte

type Responce struct {
	IHaveFullKeys []string `json:"h"`
	YourKeyVal    string   `json:"v"`
}

func (Responce) Decode(buf []byte) (r Responce, err error)

func (r Responce) Encode() []byte

type Storage struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New(nodeName string, diskOpts diskv.Options, refreshFilesPeriod int) *Storage

func (s *Storage) Add(area, key string, val string) error

func (s *Storage) NextID() int

func (s *Storage) Remove(objectKey ObjectKey) error

func (s *Storage) SubscribeAndData(area string) (data map[ObjectKey]string, subscribe chan Event)

func (s *Storage) Unsubscribe(subscribe chan Event)