Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

datakit

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 12, 2019

v0

v0.12.4

Apr 14, 2019

v0.12.3

Mar 11, 2019

Changes in this version

+ var InitialVersion = Version(0)

+ func Head(ctx context.Context, client *Client, fromBranch string) (string, error)

+ func NewTransaction(ctx context.Context, client *Client, fromBranch string) (*transaction, error)

+ type BoolField struct

+ func (f *BoolField) Get() (bool, Version)

+ func (f *BoolField) HasChanged(version Version) bool

+ type Client struct

+ func Dial(ctx context.Context, network, address string) (*Client, error)

+ func NewClient(ctx context.Context, conn net.Conn) (*Client, error)

+ func (c *Client) Close(ctx context.Context)

+ func (c *Client) Create(ctx context.Context, path ...string) (*File, error)

+ func (c *Client) List(ctx context.Context, path []string) ([]string, error)

+ func (c *Client) Mkdir(ctx context.Context, path ...string) error

+ func (c *Client) Open(ctx context.Context, mode p9p.Flag, path ...string) (*File, error)

+ func (c *Client) Remove(ctx context.Context, path ...string) error

+ type File struct

+ func (f *File) Close(ctx context.Context)

+ func (f *File) NewFileReader(ctx context.Context) *FileReader

+ func (f *File) NewIOReader(ctx context.Context, offset int64) io.Reader

+ func (f *File) NewIOWriter(ctx context.Context, offset int64) io.Writer

+ func (f *File) Read(ctx context.Context, p []byte, offset int64) (int, error)

+ func (f *File) Write(ctx context.Context, p []byte, offset int64) (int, error)

+ type FileReader struct

+ func (f *FileReader) Read(p []byte) (int, error)

+ type IntField struct

+ func (f *IntField) Get() (int, Version)

+ func (f *IntField) HasChanged(version Version) bool

+ type Record struct

+ func NewRecord(ctx context.Context, client *Client, lookupB []string, defaultsB string, ...) (*Record, error)

+ func (f *Record) BoolField(key string, value bool) *BoolField

+ func (f *Record) IntField(key string, value int) *IntField

+ func (f *Record) StringField(key string, value string) *StringField

+ func (f *Record) StringRefField(key string, value *string) *StringRefField

+ func (r *Record) Seal(ctx context.Context) error

+ func (r *Record) SetMultiple(description string, fields []*StringField, values []string) error

+ func (r *Record) Upgrade(ctx context.Context, schemaVersion int) error

+ func (r *Record) Wait(ctx context.Context) error

+ type Snapshot struct

+ func NewSnapshot(ctx context.Context, client *Client, kind SnapshotKind, thing string) *Snapshot

+ func (s *Snapshot) List(ctx context.Context, path []string) ([]string, error)

+ func (s *Snapshot) Read(ctx context.Context, path []string) (string, error)

+ type SnapshotKind uint8

+ const COMMIT

+ const OBJECT

+ type StringField struct

+ func (f *StringField) Get() (string, Version)

+ func (f *StringField) HasChanged(version Version) bool

+ func (f *StringField) Set(description string, value string) error

+ type StringRefField struct

+ func (f *StringRefField) Get() (*string, Version)

+ func (f *StringRefField) HasChanged(version Version) bool

+ func (f *StringRefField) Set(description string, value *string) error

+ type Version int

+ type Watch struct

+ func NewWatch(ctx context.Context, client *Client, fromBranch string, path []string) (*Watch, error)

+ func (w *Watch) Close(ctx context.Context)

+ func (w *Watch) Next(ctx context.Context) (*Snapshot, error)