orcas

package
v0.0.0-...-d3db570 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 21, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MetricCmdGetL1       = metrics.AddCounter("cmd_get_l1", nil)
	MetricCmdGetL2       = metrics.AddCounter("cmd_get_l2", nil)
	MetricCmdGetHits     = metrics.AddCounter("cmd_get_hits", nil)
	MetricCmdGetHitsL1   = metrics.AddCounter("cmd_get_hits_l1", nil)
	MetricCmdGetHitsL2   = metrics.AddCounter("cmd_get_hits_l2", nil)
	MetricCmdGetMisses   = metrics.AddCounter("cmd_get_misses", nil)
	MetricCmdGetMissesL1 = metrics.AddCounter("cmd_get_misses_l1", nil)
	MetricCmdGetMissesL2 = metrics.AddCounter("cmd_get_misses_l2", nil)
	MetricCmdGetErrors   = metrics.AddCounter("cmd_get_errors", nil)
	MetricCmdGetErrorsL1 = metrics.AddCounter("cmd_get_errors_l1", nil)
	MetricCmdGetErrorsL2 = metrics.AddCounter("cmd_get_errors_l2", nil)
	MetricCmdGetKeys     = metrics.AddCounter("cmd_get_keys", nil)
	MetricCmdGetKeysL1   = metrics.AddCounter("cmd_get_keys_l1", nil)
	MetricCmdGetKeysL2   = metrics.AddCounter("cmd_get_keys_l2", nil)

	MetricCmdGetSetL1       = metrics.AddCounter("cmd_get_set_l1", nil)
	MetricCmdGetSetErrorsL1 = metrics.AddCounter("cmd_get_set_errors_l1", nil)
	MetricCmdGetSetSucessL1 = metrics.AddCounter("cmd_get_set_success_l1", nil)

	MetricCmdGetSetErrorL1DeleteL1       = metrics.AddCounter("cmd_get_set_l1_error_delete_l1", nil)
	MetricCmdGetSetErrorL1DeleteHitsL1   = metrics.AddCounter("cmd_get_set_l1_error_delete_hits_l1", nil)
	MetricCmdGetSetErrorL1DeleteMissesL1 = metrics.AddCounter("cmd_get_set_l1_error_delete_misses_l1", nil)
	MetricCmdGetSetErrorL1DeleteErrorsL1 = metrics.AddCounter("cmd_get_set_l1_error_delete_errors_l1", nil)

	MetricCmdGetEL1       = metrics.AddCounter("cmd_gete_l1", nil)
	MetricCmdGetEL2       = metrics.AddCounter("cmd_gete_l2", nil)
	MetricCmdGetEHits     = metrics.AddCounter("cmd_gete_hits", nil)
	MetricCmdGetEHitsL1   = metrics.AddCounter("cmd_gete_hits_l1", nil)
	MetricCmdGetEHitsL2   = metrics.AddCounter("cmd_gete_hits_l2", nil)
	MetricCmdGetEMisses   = metrics.AddCounter("cmd_gete_misses", nil)
	MetricCmdGetEMissesL1 = metrics.AddCounter("cmd_gete_misses_l1", nil)
	MetricCmdGetEMissesL2 = metrics.AddCounter("cmd_gete_misses_l2", nil)
	MetricCmdGetEErrors   = metrics.AddCounter("cmd_gete_errors", nil)
	MetricCmdGetEErrorsL1 = metrics.AddCounter("cmd_gete_errors_l1", nil)
	MetricCmdGetEErrorsL2 = metrics.AddCounter("cmd_gete_errors_l2", nil)
	MetricCmdGetEKeys     = metrics.AddCounter("cmd_gete_keys", nil)
	MetricCmdGetEKeysL1   = metrics.AddCounter("cmd_gete_keys_l1", nil)
	MetricCmdGetEKeysL2   = metrics.AddCounter("cmd_gete_keys_l2", nil)

	MetricCmdSetL1        = metrics.AddCounter("cmd_set_l1", nil)
	MetricCmdSetL2        = metrics.AddCounter("cmd_set_l2", nil)
	MetricCmdSetSuccess   = metrics.AddCounter("cmd_set_success", nil)
	MetricCmdSetSuccessL1 = metrics.AddCounter("cmd_set_success_l1", nil)
	MetricCmdSetSuccessL2 = metrics.AddCounter("cmd_set_success_l2", nil)
	MetricCmdSetErrors    = metrics.AddCounter("cmd_set_errors", nil)
	MetricCmdSetErrorsL1  = metrics.AddCounter("cmd_set_errors_l1", nil)
	MetricCmdSetErrorsL2  = metrics.AddCounter("cmd_set_errors_l2", nil)

	// L1L2 delete after failed L1 set metrics
	MetricCmdSetL1ErrorDeleteL1       = metrics.AddCounter("cmd_set_l1_error_delete_l1", nil)
	MetricCmdSetL1ErrorDeleteHitsL1   = metrics.AddCounter("cmd_set_l1_error_delete_hits_l1", nil)
	MetricCmdSetL1ErrorDeleteMissesL1 = metrics.AddCounter("cmd_set_l1_error_delete_misses_l1", nil)
	MetricCmdSetL1ErrorDeleteErrorsL1 = metrics.AddCounter("cmd_set_l1_error_delete_errors_l1", nil)

	// Batch L1L2 set metrics
	MetricCmdSetReplaceL1          = metrics.AddCounter("cmd_set_replace_l1", nil)
	MetricCmdSetReplaceNotStoredL1 = metrics.AddCounter("cmd_set_replace_not_stored_l1", nil)
	MetricCmdSetReplaceErrorsL1    = metrics.AddCounter("cmd_set_replace_errors_l1", nil)
	MetricCmdSetReplaceStoredL1    = metrics.AddCounter("cmd_set_replace_stored_l1", nil)

	// Batch L1L2 delete after failed set metrics
	MetricsCmdSetReplaceL1ErrorDeleteL1       = metrics.AddCounter("cmd_set_replace_l1_error_delete_l1", nil)
	MetricsCmdSetReplaceL1ErrorDeleteHitsL1   = metrics.AddCounter("cmd_set_replace_l1_error_delete_hits_l1", nil)
	MetricsCmdSetReplaceL1ErrorDeleteMissesL1 = metrics.AddCounter("cmd_set_replace_l1_error_delete_misses_l1", nil)
	MetricsCmdSetReplaceL1ErrorDeleteErrorsL1 = metrics.AddCounter("cmd_set_replace_l1_error_delete_errors_l1", nil)

	MetricCmdAddL1          = metrics.AddCounter("cmd_add_l1", nil)
	MetricCmdAddL2          = metrics.AddCounter("cmd_add_l2", nil)
	MetricCmdAddStored      = metrics.AddCounter("cmd_add_stored", nil)
	MetricCmdAddStoredL1    = metrics.AddCounter("cmd_add_stored_l1", nil)
	MetricCmdAddStoredL2    = metrics.AddCounter("cmd_add_stored_l2", nil)
	MetricCmdAddNotStored   = metrics.AddCounter("cmd_add_not_stored", nil)
	MetricCmdAddNotStoredL1 = metrics.AddCounter("cmd_add_not_stored_l1", nil)
	MetricCmdAddNotStoredL2 = metrics.AddCounter("cmd_add_not_stored_l2", nil)
	MetricCmdAddErrors      = metrics.AddCounter("cmd_add_errors", nil)
	MetricCmdAddErrorsL1    = metrics.AddCounter("cmd_add_errors_l1", nil)
	MetricCmdAddErrorsL2    = metrics.AddCounter("cmd_add_errors_l2", nil)

	// Batch L1L2 add metrics
	MetricCmdAddReplaceL1          = metrics.AddCounter("cmd_add_replace_l1", nil)
	MetricCmdAddReplaceNotStoredL1 = metrics.AddCounter("cmd_add_replace_not_stored_l1", nil)
	MetricCmdAddReplaceErrorsL1    = metrics.AddCounter("cmd_add_replace_errors_l1", nil)
	MetricCmdAddReplaceStoredL1    = metrics.AddCounter("cmd_add_replace_stored_l1", nil)

	MetricCmdReplaceL1          = metrics.AddCounter("cmd_replace_l1", nil)
	MetricCmdReplaceL2          = metrics.AddCounter("cmd_replace_l2", nil)
	MetricCmdReplaceStored      = metrics.AddCounter("cmd_replace_stored", nil)
	MetricCmdReplaceStoredL1    = metrics.AddCounter("cmd_replace_stored_l1", nil)
	MetricCmdReplaceStoredL2    = metrics.AddCounter("cmd_replace_stored_l2", nil)
	MetricCmdReplaceNotStored   = metrics.AddCounter("cmd_replace_not_stored", nil)
	MetricCmdReplaceNotStoredL1 = metrics.AddCounter("cmd_replace_not_stored_l1", nil)
	MetricCmdReplaceNotStoredL2 = metrics.AddCounter("cmd_replace_not_stored_l2", nil)
	MetricCmdReplaceErrors      = metrics.AddCounter("cmd_replace_errors", nil)
	MetricCmdReplaceErrorsL1    = metrics.AddCounter("cmd_replace_errors_l1", nil)
	MetricCmdReplaceErrorsL2    = metrics.AddCounter("cmd_replace_errors_l2", nil)

	// Batch L1L2 replace metrics
	MetricCmdReplaceReplaceL1          = metrics.AddCounter("cmd_replace_replace_l1", nil)
	MetricCmdReplaceReplaceNotStoredL1 = metrics.AddCounter("cmd_replace_replace_not_stored_l1", nil)
	MetricCmdReplaceReplaceErrorsL1    = metrics.AddCounter("cmd_replace_replace_errors_l1", nil)
	MetricCmdReplaceReplaceStoredL1    = metrics.AddCounter("cmd_replace_replace_stored_l1", nil)

	MetricCmdAppendL1          = metrics.AddCounter("cmd_append_l1", nil)
	MetricCmdAppendL2          = metrics.AddCounter("cmd_append_l2", nil)
	MetricCmdAppendStored      = metrics.AddCounter("cmd_append_stored", nil)
	MetricCmdAppendStoredL1    = metrics.AddCounter("cmd_append_stored_l1", nil)
	MetricCmdAppendStoredL2    = metrics.AddCounter("cmd_append_stored_l2", nil)
	MetricCmdAppendNotStored   = metrics.AddCounter("cmd_append_not_stored", nil)
	MetricCmdAppendNotStoredL1 = metrics.AddCounter("cmd_append_not_stored_l1", nil)
	MetricCmdAppendNotStoredL2 = metrics.AddCounter("cmd_append_not_stored_l2", nil)
	MetricCmdAppendErrors      = metrics.AddCounter("cmd_append_errors", nil)
	MetricCmdAppendErrorsL1    = metrics.AddCounter("cmd_append_errors_l1", nil)
	MetricCmdAppendErrorsL2    = metrics.AddCounter("cmd_append_errors_l2", nil)

	MetricCmdPrependL1          = metrics.AddCounter("cmd_prepend_l1", nil)
	MetricCmdPrependL2          = metrics.AddCounter("cmd_prepend_l2", nil)
	MetricCmdPrependStored      = metrics.AddCounter("cmd_prepend_stored", nil)
	MetricCmdPrependStoredL1    = metrics.AddCounter("cmd_prepend_stored_l1", nil)
	MetricCmdPrependStoredL2    = metrics.AddCounter("cmd_prepend_stored_l2", nil)
	MetricCmdPrependNotStored   = metrics.AddCounter("cmd_prepend_not_stored", nil)
	MetricCmdPrependNotStoredL1 = metrics.AddCounter("cmd_prepend_not_stored_l1", nil)
	MetricCmdPrependNotStoredL2 = metrics.AddCounter("cmd_prepend_not_stored_l2", nil)
	MetricCmdPrependErrors      = metrics.AddCounter("cmd_prepend_errors", nil)
	MetricCmdPrependErrorsL1    = metrics.AddCounter("cmd_prepend_errors_l1", nil)
	MetricCmdPrependErrorsL2    = metrics.AddCounter("cmd_prepend_errors_l2", nil)

	MetricCmdDeleteL1       = metrics.AddCounter("cmd_delete_l1", nil)
	MetricCmdDeleteL2       = metrics.AddCounter("cmd_delete_l2", nil)
	MetricCmdDeleteHits     = metrics.AddCounter("cmd_delete_hits", nil)
	MetricCmdDeleteHitsL1   = metrics.AddCounter("cmd_delete_hits_l1", nil)
	MetricCmdDeleteHitsL2   = metrics.AddCounter("cmd_delete_hits_l2", nil)
	MetricCmdDeleteMisses   = metrics.AddCounter("cmd_delete_misses", nil)
	MetricCmdDeleteMissesL1 = metrics.AddCounter("cmd_delete_misses_l1", nil)
	MetricCmdDeleteMissesL2 = metrics.AddCounter("cmd_delete_misses_l2", nil)
	MetricCmdDeleteErrors   = metrics.AddCounter("cmd_delete_errors", nil)
	MetricCmdDeleteErrorsL1 = metrics.AddCounter("cmd_delete_errors_l1", nil)
	MetricCmdDeleteErrorsL2 = metrics.AddCounter("cmd_delete_errors_l2", nil)

	MetricCmdTouchL1       = metrics.AddCounter("cmd_touch_l1", nil)
	MetricCmdTouchL2       = metrics.AddCounter("cmd_touch_l2", nil)
	MetricCmdTouchHits     = metrics.AddCounter("cmd_touch_hits", nil)
	MetricCmdTouchHitsL1   = metrics.AddCounter("cmd_touch_hits_l1", nil)
	MetricCmdTouchHitsL2   = metrics.AddCounter("cmd_touch_hits_l2", nil)
	MetricCmdTouchMisses   = metrics.AddCounter("cmd_touch_misses", nil)
	MetricCmdTouchMissesL1 = metrics.AddCounter("cmd_touch_misses_l1", nil)
	MetricCmdTouchMissesL2 = metrics.AddCounter("cmd_touch_misses_l2", nil)
	MetricCmdTouchErrors   = metrics.AddCounter("cmd_touch_errors", nil)
	MetricCmdTouchErrorsL1 = metrics.AddCounter("cmd_touch_errors_l1", nil)
	MetricCmdTouchErrorsL2 = metrics.AddCounter("cmd_touch_errors_l2", nil)

	// Batch L1L2 touch metrics
	MetricCmdTouchTouchL1       = metrics.AddCounter("cmd_touch_touch_l1", nil)
	MetricCmdTouchTouchMissesL1 = metrics.AddCounter("cmd_touch_touch_misses_l1", nil)
	MetricCmdTouchTouchErrorsL1 = metrics.AddCounter("cmd_touch_touch_errors_l1", nil)
	MetricCmdTouchTouchHitsL1   = metrics.AddCounter("cmd_touch_touch_hits_l1", nil)

	MetricCmdGatL1       = metrics.AddCounter("cmd_gat_l1", nil)
	MetricCmdGatL2       = metrics.AddCounter("cmd_gat_l2", nil)
	MetricCmdGatHits     = metrics.AddCounter("cmd_gat_hits", nil)
	MetricCmdGatHitsL1   = metrics.AddCounter("cmd_gat_hits_l1", nil)
	MetricCmdGatHitsL2   = metrics.AddCounter("cmd_gat_hits_l2", nil)
	MetricCmdGatMisses   = metrics.AddCounter("cmd_gat_misses", nil)
	MetricCmdGatMissesL1 = metrics.AddCounter("cmd_gat_misses_l1", nil)
	MetricCmdGatMissesL2 = metrics.AddCounter("cmd_gat_misses_l2", nil)
	MetricCmdGatErrors   = metrics.AddCounter("cmd_gat_errors", nil)
	MetricCmdGatErrorsL1 = metrics.AddCounter("cmd_gat_errors_l1", nil)
	MetricCmdGatErrorsL2 = metrics.AddCounter("cmd_gat_errors_l2", nil)

	// Secondary metrics under GAT that refer to other kinds of operations to
	// backing datastores as a part of the overall request
	MetricCmdGatAddL1          = metrics.AddCounter("cmd_gat_add_l1", nil)
	MetricCmdGatAddErrorsL1    = metrics.AddCounter("cmd_gat_add_errors_l1", nil)
	MetricCmdGatAddStoredL1    = metrics.AddCounter("cmd_gat_add_stored_l1", nil)
	MetricCmdGatAddNotStoredL1 = metrics.AddCounter("cmd_gat_add_not_stored_l1", nil)
	MetricCmdGatTouchL2        = metrics.AddCounter("cmd_gat_touch_l2", nil)
	MetricCmdGatTouchHitsL2    = metrics.AddCounter("cmd_gat_touch_hits_l2", nil)
	MetricCmdGatTouchMissesL2  = metrics.AddCounter("cmd_gat_touch_misses_l2", nil)
	MetricCmdGatTouchErrorsL2  = metrics.AddCounter("cmd_gat_touch_errors_l2", nil)

	// Batch L1L2 gat metrics
	MetricCmdGatTouchL1       = metrics.AddCounter("cmd_gat_touch_l1", nil)
	MetricCmdGatTouchMissesL1 = metrics.AddCounter("cmd_gat_touch_misses_l1", nil)
	MetricCmdGatTouchErrorsL1 = metrics.AddCounter("cmd_gat_touch_errors_l1", nil)
	MetricCmdGatTouchHitsL1   = metrics.AddCounter("cmd_gat_touch_hits_l1", nil)

	// Special metrics
	MetricInconsistencyDetected = metrics.AddCounter("inconsistency_detected", nil)

	// Histograms for sub-operations
	HistSetL1     = metrics.AddHistogram("set_l1", false, nil)
	HistSetL2     = metrics.AddHistogram("set_l2", false, nil)
	HistAddL1     = metrics.AddHistogram("add_l1", false, nil)
	HistAddL2     = metrics.AddHistogram("add_l2", false, nil)
	HistReplaceL1 = metrics.AddHistogram("replace_l1", false, nil)
	HistReplaceL2 = metrics.AddHistogram("replace_l2", false, nil)
	HistAppendL1  = metrics.AddHistogram("append_l1", false, nil)
	HistAppendL2  = metrics.AddHistogram("append_l2", false, nil)
	HistPrependL1 = metrics.AddHistogram("prepend_l1", false, nil)
	HistPrependL2 = metrics.AddHistogram("prepend_l2", false, nil)
	HistDeleteL1  = metrics.AddHistogram("delete_l1", false, nil)
	HistDeleteL2  = metrics.AddHistogram("delete_l2", false, nil)
	HistTouchL1   = metrics.AddHistogram("touch_l1", false, nil)
	HistTouchL2   = metrics.AddHistogram("touch_l2", false, nil)

	HistGetL1 = metrics.AddHistogram("get_l1", false, nil) // not sampled until configurable
	HistGetL2 = metrics.AddHistogram("get_l2", false, nil) // not sampled until configurable

	HistGetEL1 = metrics.AddHistogram("gete_l1", false, nil) // not sampled until configurable
	HistGetEL2 = metrics.AddHistogram("gete_l2", false, nil) // not sampled until configurable

	HistGatL1 = metrics.AddHistogram("gat_l1", false, nil) // not sampled until configurable
	HistGatL2 = metrics.AddHistogram("gat_l2", false, nil) // not sampled until configurable

)

Functions

This section is empty.

Types

type L1L2BatchOrca

type L1L2BatchOrca struct {
	// contains filtered or unexported fields
}

func (*L1L2BatchOrca) Add

func (l *L1L2BatchOrca) Add(req common.SetRequest) error

func (*L1L2BatchOrca) Append

func (l *L1L2BatchOrca) Append(req common.SetRequest) error

func (*L1L2BatchOrca) Delete

func (l *L1L2BatchOrca) Delete(req common.DeleteRequest) error

func (*L1L2BatchOrca) Error

func (l *L1L2BatchOrca) Error(req common.Request, reqType common.RequestType, err error)

func (*L1L2BatchOrca) Gat

func (l *L1L2BatchOrca) Gat(req common.GATRequest) error

func (*L1L2BatchOrca) Get

func (l *L1L2BatchOrca) Get(req common.GetRequest) error

func (*L1L2BatchOrca) GetE

func (l *L1L2BatchOrca) GetE(req common.GetRequest) error

func (*L1L2BatchOrca) Noop

func (l *L1L2BatchOrca) Noop(req common.NoopRequest) error

func (*L1L2BatchOrca) Prepend

func (l *L1L2BatchOrca) Prepend(req common.SetRequest) error

func (*L1L2BatchOrca) Quit

func (l *L1L2BatchOrca) Quit(req common.QuitRequest) error

func (*L1L2BatchOrca) Replace

func (l *L1L2BatchOrca) Replace(req common.SetRequest) error

func (*L1L2BatchOrca) Set

func (l *L1L2BatchOrca) Set(req common.SetRequest) error

func (*L1L2BatchOrca) Touch

func (l *L1L2BatchOrca) Touch(req common.TouchRequest) error

func (*L1L2BatchOrca) Unknown

func (l *L1L2BatchOrca) Unknown(req common.Request) error

func (*L1L2BatchOrca) Version

func (l *L1L2BatchOrca) Version(req common.VersionRequest) error

type L1L2Orca

type L1L2Orca struct {
	// contains filtered or unexported fields
}

func (*L1L2Orca) Add

func (l *L1L2Orca) Add(req common.SetRequest) error

func (*L1L2Orca) Append

func (l *L1L2Orca) Append(req common.SetRequest) error

func (*L1L2Orca) Delete

func (l *L1L2Orca) Delete(req common.DeleteRequest) error

func (*L1L2Orca) Error

func (l *L1L2Orca) Error(req common.Request, reqType common.RequestType, err error)

func (*L1L2Orca) Gat

func (l *L1L2Orca) Gat(req common.GATRequest) error

func (*L1L2Orca) Get

func (l *L1L2Orca) Get(req common.GetRequest) error

func (*L1L2Orca) GetE

func (l *L1L2Orca) GetE(req common.GetRequest) error

func (*L1L2Orca) Noop

func (l *L1L2Orca) Noop(req common.NoopRequest) error

func (*L1L2Orca) Prepend

func (l *L1L2Orca) Prepend(req common.SetRequest) error

func (*L1L2Orca) Quit

func (l *L1L2Orca) Quit(req common.QuitRequest) error

func (*L1L2Orca) Replace

func (l *L1L2Orca) Replace(req common.SetRequest) error

func (*L1L2Orca) Set

func (l *L1L2Orca) Set(req common.SetRequest) error

func (*L1L2Orca) Touch

func (l *L1L2Orca) Touch(req common.TouchRequest) error

func (*L1L2Orca) Unknown

func (l *L1L2Orca) Unknown(req common.Request) error

func (*L1L2Orca) Version

func (l *L1L2Orca) Version(req common.VersionRequest) error

type L1OnlyOrca

type L1OnlyOrca struct {
	// contains filtered or unexported fields
}

func (*L1OnlyOrca) Add

func (l *L1OnlyOrca) Add(req common.SetRequest) error

func (*L1OnlyOrca) Append

func (l *L1OnlyOrca) Append(req common.SetRequest) error

func (*L1OnlyOrca) Delete

func (l *L1OnlyOrca) Delete(req common.DeleteRequest) error

func (*L1OnlyOrca) Error

func (l *L1OnlyOrca) Error(req common.Request, reqType common.RequestType, err error)

func (*L1OnlyOrca) Gat

func (l *L1OnlyOrca) Gat(req common.GATRequest) error

func (*L1OnlyOrca) Get

func (l *L1OnlyOrca) Get(req common.GetRequest) error

func (*L1OnlyOrca) GetE

func (l *L1OnlyOrca) GetE(req common.GetRequest) error

func (*L1OnlyOrca) Noop

func (l *L1OnlyOrca) Noop(req common.NoopRequest) error

func (*L1OnlyOrca) Prepend

func (l *L1OnlyOrca) Prepend(req common.SetRequest) error

func (*L1OnlyOrca) Quit

func (l *L1OnlyOrca) Quit(req common.QuitRequest) error

func (*L1OnlyOrca) Replace

func (l *L1OnlyOrca) Replace(req common.SetRequest) error

func (*L1OnlyOrca) Set

func (l *L1OnlyOrca) Set(req common.SetRequest) error

func (*L1OnlyOrca) Touch

func (l *L1OnlyOrca) Touch(req common.TouchRequest) error

func (*L1OnlyOrca) Unknown

func (l *L1OnlyOrca) Unknown(req common.Request) error

func (*L1OnlyOrca) Version

func (l *L1OnlyOrca) Version(req common.VersionRequest) error

type LockedOrca

type LockedOrca struct {
	// contains filtered or unexported fields
}

func (*LockedOrca) Add

func (l *LockedOrca) Add(req common.SetRequest) error

func (*LockedOrca) Append

func (l *LockedOrca) Append(req common.SetRequest) error

func (*LockedOrca) Delete

func (l *LockedOrca) Delete(req common.DeleteRequest) error

func (*LockedOrca) Error

func (l *LockedOrca) Error(req common.Request, reqType common.RequestType, err error)

func (*LockedOrca) Gat

func (l *LockedOrca) Gat(req common.GATRequest) error

func (*LockedOrca) Get

func (l *LockedOrca) Get(req common.GetRequest) error

func (*LockedOrca) GetE

func (l *LockedOrca) GetE(req common.GetRequest) error

func (*LockedOrca) Noop

func (l *LockedOrca) Noop(req common.NoopRequest) error

func (*LockedOrca) Prepend

func (l *LockedOrca) Prepend(req common.SetRequest) error

func (*LockedOrca) Quit

func (l *LockedOrca) Quit(req common.QuitRequest) error

func (*LockedOrca) Replace

func (l *LockedOrca) Replace(req common.SetRequest) error

func (*LockedOrca) Set

func (l *LockedOrca) Set(req common.SetRequest) error

func (*LockedOrca) Touch

func (l *LockedOrca) Touch(req common.TouchRequest) error

func (*LockedOrca) Unknown

func (l *LockedOrca) Unknown(req common.Request) error

func (*LockedOrca) Version

func (l *LockedOrca) Version(req common.VersionRequest) error

type Orca

type Orca interface {
	Set(req common.SetRequest) error
	Add(req common.SetRequest) error
	Replace(req common.SetRequest) error
	Append(req common.SetRequest) error
	Prepend(req common.SetRequest) error
	Delete(req common.DeleteRequest) error
	Touch(req common.TouchRequest) error
	Get(req common.GetRequest) error
	GetE(req common.GetRequest) error
	Gat(req common.GATRequest) error
	Noop(req common.NoopRequest) error
	Quit(req common.QuitRequest) error
	Version(req common.VersionRequest) error
	Unknown(req common.Request) error
	Error(req common.Request, reqType common.RequestType, err error)
}

func L1L2

func L1L2(l1, l2 handlers.Handler, res protocol.Responder) Orca

func L1L2Batch

func L1L2Batch(l1, l2 handlers.Handler, res protocol.Responder) Orca

func L1Only

func L1Only(l1, l2 handlers.Handler, res protocol.Responder) Orca

type OrcaConst

type OrcaConst func(l1, l2 handlers.Handler, res protocol.Responder) Orca

func Locked

func Locked(oc OrcaConst, multipleReaders bool, concurrency uint8) (OrcaConst, uint32)

Locking wraps an orcas.Orca to provide locking around operations on the same key. When multipleReaders is true, operations will allow many readers and only a single writer at a time. When false, only a single reader is allowed. The concurrency param allows 2^(concurrency) operations to happen in parallel. E.g. concurrency of 1 would allow 2 parallel operations, while a concurrency of 4 allows 2^4 = 16 parallel operations.

func LockedWithExisting

func LockedWithExisting(oc OrcaConst, locksetID uint32) OrcaConst

Jump to

Keyboard shortcuts

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