framework

package

v0.0.0-...-cfbcac4 Latest Latest Go to latest Published: Apr 18, 2022 License: MIT Imports: 4 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

Repository

github.com/anttsov/curator

Links

Open Source Insights

Documentation ¶

Index ¶

func AddCreateToTransaction(transaction curator.Transaction) curator.TransactionFinal
func AddDeleteToTransaction(transaction curator.Transaction) curator.TransactionFinal
func CheckExists(client curator.CuratorFramework, path string) (*zk.Stat, error)
func CommitTransaction(transaction curator.TransactionFinal) ([]curator.TransactionResult, error)
func Create(client curator.CuratorFramework, path string, payload []byte) (string, error)
func CreateEphemeral(client curator.CuratorFramework, path string, payload []byte) (string, error)
func CreateSimple(connString string) curator.CuratorFramework
func CreateTransaction(client curator.CuratorFramework) error
func CreateWithOptions(connString string, retryPolicy curator.RetryPolicy, ...) curator.CuratorFramework
func Delete(client curator.CuratorFramework, path string, version int32) error
func GetData(client curator.CuratorFramework, path string) ([]byte, error)
func SetData(client curator.CuratorFramework, path string, payload []byte) (*zk.Stat, error)
func SetDataAsync(client curator.CuratorFramework, path string, payload []byte) (*zk.Stat, error)
func SetDataAsyncWithCallback(client curator.CuratorFramework, callback curator.BackgroundCallback, ...) (*zk.Stat, error)
func StartTransaction(client curator.CuratorFramework) curator.Transaction
func UsingWatcherGetChildren(client curator.CuratorFramework, path string, watcher curator.Watcher) ([]string, error)
func WatchedGetChildren(client curator.CuratorFramework, path string) ([]string, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddCreateToTransaction ¶

func AddCreateToTransaction(transaction curator.Transaction) curator.TransactionFinal

func AddDeleteToTransaction ¶

func AddDeleteToTransaction(transaction curator.Transaction) curator.TransactionFinal

func CheckExists ¶

func CheckExists(client curator.CuratorFramework, path string) (*zk.Stat, error)

func CommitTransaction ¶

func CommitTransaction(transaction curator.TransactionFinal) ([]curator.TransactionResult, error)

func Create ¶

func Create(client curator.CuratorFramework, path string, payload []byte) (string, error)

func CreateEphemeral ¶

func CreateEphemeral(client curator.CuratorFramework, path string, payload []byte) (string, error)

func CreateSimple ¶

func CreateSimple(connString string) curator.CuratorFramework

func CreateTransaction ¶

func CreateTransaction(client curator.CuratorFramework) error

func CreateWithOptions ¶

func CreateWithOptions(connString string, retryPolicy curator.RetryPolicy, connectionTimeout, sessionTimeout time.Duration) curator.CuratorFramework

func Delete ¶

func Delete(client curator.CuratorFramework, path string, version int32) error

func GetData ¶

func GetData(client curator.CuratorFramework, path string) ([]byte, error)

func SetData ¶

func SetData(client curator.CuratorFramework, path string, payload []byte) (*zk.Stat, error)

func SetDataAsync ¶

func SetDataAsync(client curator.CuratorFramework, path string, payload []byte) (*zk.Stat, error)

func SetDataAsyncWithCallback ¶

func SetDataAsyncWithCallback(client curator.CuratorFramework, callback curator.BackgroundCallback, path string, payload []byte) (*zk.Stat, error)

func StartTransaction ¶

func StartTransaction(client curator.CuratorFramework) curator.Transaction

func UsingWatcherGetChildren ¶

func UsingWatcherGetChildren(client curator.CuratorFramework, path string, watcher curator.Watcher) ([]string, error)

func WatchedGetChildren ¶

func WatchedGetChildren(client curator.CuratorFramework, path string) ([]string, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

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