commit

Documentation

Index

• type FailurePolicy
  • func (d FailurePolicy) MarshalYAML() (interface{}, error)
  • func (d *FailurePolicy) UnmarshalYAML(unmarshal func(interface{}) error) error
• type LogSync
  • func (c LogSync) MarshalYAML() (interface{}, error)
  • func (c *LogSync) UnmarshalYAML(unmarshal func(interface{}) error) error

Types

type FailurePolicy

type FailurePolicy int

FailurePolicy is the numeric representation for the commit failure policy name.

const (
	// Die is to shut down the node and kill the JVM, so the node can be replaced.
	Die FailurePolicy = iota
	// Stop is to shut down the node, leaving the node effectively dead,
	// but can still be inspected via JMX.
	Stop
	// StopCommit is to shut down the commit log, letting writes collect but
	// continuing to service reads, as in pre-2.0.5 Cassandra
	StopCommit
	// Ignore fatal errors and let the batches fail
	Ignore
)

func (FailurePolicy) MarshalYAML

func (d FailurePolicy) MarshalYAML() (interface{}, error)

MarshalYAML converts the enum to the string value for YAML.

func (*FailurePolicy) UnmarshalYAML

func (d *FailurePolicy) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML converts converts the YAML string to the enum integer.

type LogSync

type LogSync int

LogSync is how the commit log should be synced

const (
	// Periodic runs the sync in intervals
	Periodic LogSync = iota
	// Batch won’t ack writes until the commit log has been fsynced to disk.
	// It will wait commitlog_sync_batch_window_in_ms milliseconds between fsyncs.
	// This window should be kept short because the writer threads will be unable
	// to do extra work while waiting. (You may need to increase concurrent_writes
	// for the same reason.)
	Batch
)

func (LogSync) MarshalYAML

func (c LogSync) MarshalYAML() (interface{}, error)

MarshalYAML converts the enum to the string value for YAML.

func (*LogSync) UnmarshalYAML

func (c *LogSync) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML converts converts the YAML string to the enum integer.