seqlock

Documentation

Overview

Package seqlock implements a simple example of a seqlock which provides non-waiting reads on a data structure that is undergoing concurrent writes. See https://en.wikipedia.org/wiki/Seqlock

Index

• type Seqlock
  • func New() *Seqlock
  • func (s *Seqlock) Get() (ret [1024]byte)
  • func (s *Seqlock) Put(v [1024]byte)
  • func (s *Seqlock) Update(fn func(data []byte) error) error

Types

type Seqlock

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

func New

func New() *Seqlock

func (*Seqlock) Get

func (s *Seqlock) Get() (ret [1024]byte)

Get returns the data in the seqlock

func (*Seqlock) Put

func (s *Seqlock) Put(v [1024]byte)

Put replaces the data in the seqlock

func (*Seqlock) Update

func (s *Seqlock) Update(fn func(data []byte) error) error

Update applies the update function to the data in the seqlock. If the function returns an error then the update is aborted.