package coordination
import "github.com/ydb-platform/ydb-go-sdk/v3/coordination"
Example¶
Code:
{ ctx := context.TODO() db, err := ydb.Open(ctx, "grpc://localhost:2136/local") if err != nil { fmt.Printf("failed to connect: %v", err) return } defer db.Close(ctx) // cleanup resources // create node err = db.Coordination().CreateNode(ctx, "/local/test", coordination.NodeConfig{ Path: "", SelfCheckPeriodMillis: 1000, SessionGracePeriodMillis: 1000, ReadConsistencyMode: coordination.ConsistencyModeRelaxed, AttachConsistencyMode: coordination.ConsistencyModeRelaxed, RatelimiterCountersMode: coordination.RatelimiterCountersModeDetailed, }) if err != nil { fmt.Printf("failed to create node: %v", err) return } defer db.Coordination().DropNode(ctx, "/local/test") e, c, err := db.Coordination().DescribeNode(ctx, "/local/test") if err != nil { fmt.Printf("failed to describe node: %v", err) return } fmt.Printf("node description: %+v\nnode config: %+v\n", e, c) }
Index ¶
- type Client
- type ConsistencyMode
- func (t ConsistencyMode) String() string
- func (t ConsistencyMode) To() Ydb_Coordination.ConsistencyMode
- type NodeConfig
- type RatelimiterCountersMode
Examples ¶
Types ¶
type Client ¶
type Client interface { CreateNode(ctx context.Context, path string, config NodeConfig) (err error) AlterNode(ctx context.Context, path string, config NodeConfig) (err error) DropNode(ctx context.Context, path string) (err error) DescribeNode(ctx context.Context, path string) (_ *scheme.Entry, _ *NodeConfig, err error) }
type ConsistencyMode ¶
type ConsistencyMode uint
const ( ConsistencyModeUnset ConsistencyMode = iota ConsistencyModeStrict ConsistencyModeRelaxed )
func (ConsistencyMode) String ¶
func (t ConsistencyMode) String() string
func (ConsistencyMode) To ¶
func (t ConsistencyMode) To() Ydb_Coordination.ConsistencyMode
type NodeConfig ¶
type NodeConfig struct { Path string SelfCheckPeriodMillis uint32 SessionGracePeriodMillis uint32 ReadConsistencyMode ConsistencyMode AttachConsistencyMode ConsistencyMode RatelimiterCountersMode RatelimiterCountersMode }
type RatelimiterCountersMode ¶
type RatelimiterCountersMode uint
const ( RatelimiterCountersModeUnset RatelimiterCountersMode = iota RatelimiterCountersModeAggregated RatelimiterCountersModeDetailed )
func (RatelimiterCountersMode) String ¶
func (t RatelimiterCountersMode) String() string
func (RatelimiterCountersMode) To ¶
func (t RatelimiterCountersMode) To() Ydb_Coordination.RateLimiterCountersMode
Source Files ¶
- Version
- v3.48.8
- Published
- Jul 29, 2023
- Platform
- js/wasm
- Imports
- 3 packages
- Last checked
- 7 minutes ago –
Tools for package owners.