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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.