scyllaclient

Nov 7, 2023

Changes in this version

type Client

+ func (c *Client) GetSnitchDatacenter(ctx context.Context, host string) (string, error)

+ func (c *Client) StopCleanup(ctx context.Context, host string) error

+ type CompactionType string

+ const CleanupCompactionType

+ const CompactionCompactionType

+ const ReshapeCompactionType

+ const ScrubCompactionType

+ const UpgradeCompactionType

type ConfigClient

+ func (c *ConfigClient) BroadcastRPCAddress(ctx context.Context) (string, error)

Aug 17, 2023

Changes in this version

type Client

+ func (c *Client) Cleanup(ctx context.Context, host string, keyspace string) error

+ func (c *Client) GetIPToHostIDMap(ctx context.Context, host string) (map[string]string, error)

+ func (c *Client) GetNodeTokens(ctx context.Context, host, endpoint string) ([]string, error)

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

+ type ConfigClient struct

+ func NewConfigClient(host, authToken string) *ConfigClient

+ func (c *ConfigClient) BroadcastAddress(ctx context.Context) (string, error)

+ func (c *ConfigClient) ReplaceAddressFirstBoot(ctx context.Context) (string, error)

+ func (c *ConfigClient) ReplaceNodeFirstBoot(ctx context.Context) (string, error)

Jan 2, 2023

Changes in this version

type Client

+ func (c *Client) Close()

+ func (c *Client) GetLocalHostId(ctx context.Context, host string, retry bool) (string, error)

Jun 17, 2021

Changes in this version

type Client

+ func (c *Client) HasSchemaAgreement(ctx context.Context) (bool, error)

Jan 5, 2021

Changes in this version

type Client

+ func (c *Client) DeleteSnapshot(ctx context.Context, host, tag string) error

+ func (c *Client) Drain(ctx context.Context, host string) error

+ func (c *Client) IsNativeTransportEnabled(ctx context.Context, host string) (bool, error)

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

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

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

+ func (c *Client) TakeSnapshot(ctx context.Context, host, tag, keyspace string, tables ...string) error

type OperationalMode

+ const OperationalModeDecommissioning

+ const OperationalModeDrained

+ const OperationalModeDraining

+ func (o OperationalMode) IsDecommissioned() bool

+ func (o OperationalMode) IsDecommissioning() bool

+ func (o OperationalMode) IsDrained() bool

+ func (o OperationalMode) IsDraining() bool

+ func (o OperationalMode) IsJoining() bool

+ func (o OperationalMode) IsLeaving() bool

+ func (o OperationalMode) IsNormal() bool

Sep 10, 2020

Changes in this version

+ var ErrTimeout = errors.New("timeout")

type Client

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

+ func (c *Client) ClosestDC(ctx context.Context, dcs map[string][]string) ([]string, error)

+ func (c *Client) Ping(ctx context.Context, host string) (time.Duration, error)

+ func (c *Client) PingN(ctx context.Context, host string, n int, timeout time.Duration) (time.Duration, error)

Apr 14, 2020

Changes in this version

+ func DefaultTransport() *http.Transport

+ func Interactive(ctx context.Context) context.Context

+ func StatusCodeOf(err error) int

+ type BackoffConfig struct

+ Jitter float64

+ MaxRetries uint64

+ Multiplier float64

+ WaitMax time.Duration

+ WaitMin time.Duration

type Client

+ func NewClient(config Config, logger log.Logger) (*Client, error)

+ func (c *Client) Decommission(ctx context.Context, host string) error

+ func (c *Client) OperationMode(ctx context.Context, host string) (OperationalMode, error)

+ type Config struct

+ AuthToken string

+ Backoff BackoffConfig

+ Hosts []string

+ InteractiveBackoff BackoffConfig

+ LongPollingSeconds int64

+ PoolDecayDuration time.Duration

+ Port string

+ Scheme string

+ Timeout time.Duration

+ Transport http.RoundTripper

+ func DefaultConfig() Config

+ func (c Config) Validate() error

type NodeStatusInfo

+ func (s NodeStatusInfo) String() string

+ type OperationalMode string

+ const OperationalModeClient

+ const OperationalModeDecommissioned

+ const OperationalModeJoining

+ const OperationalModeLeaving

+ const OperationalModeNormal

+ const OperationalModeUnknown

+ func (o OperationalMode) IsDecommisioned() bool

+ func (o OperationalMode) String() string

Mar 17, 2020

Changes in this version

+ const LocalStrategy

+ const Murmur3Partitioner

+ const NetworkTopologyStrategy

+ const SimpleStrategy

+ type Client struct

+ func (c *Client) HostDatacenter(ctx context.Context, host string) (dc string, err error)

+ func (c *Client) Status(ctx context.Context) (NodeStatusInfoSlice, error)

+ type CommandStatus string

+ const CommandFailed

+ const CommandRunning

+ const CommandSuccessful

+ type NodeState string

+ const NodeStateJoining

+ const NodeStateLeaving

+ const NodeStateMoving

+ const NodeStateNormal

+ func (s NodeState) String() string

+ type NodeStatus bool

+ const NodeStatusDown

+ const NodeStatusUp

+ func (s NodeStatus) String() string

+ type NodeStatusInfo struct

+ Addr string

+ Datacenter string

+ HostID string

+ State NodeState

+ Status NodeStatus

+ func (s NodeStatusInfo) IsUN() bool

+ type NodeStatusInfoSlice []NodeStatusInfo

+ func (s NodeStatusInfoSlice) Datacenter(dcs []string) NodeStatusInfoSlice

+ func (s NodeStatusInfoSlice) DownHosts() []string

+ func (s NodeStatusInfoSlice) Hosts() []string

+ func (s NodeStatusInfoSlice) LiveHosts() []string

+ type ReplicationStrategy string

+ type Ring struct

+ HostDC map[string]string

+ Replication ReplicationStrategy

+ Tokens []TokenRange

+ func (r Ring) Datacenters() []string

+ type ScyllaFeatures struct

+ RowLevelRepair bool

+ type TokenRange struct

+ EndToken int64

+ Replicas []string

+ StartToken int64

+ type Unit struct

+ Keyspace string

+ Tables []string