orcas

package
v0.0.0-...-b29f263 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2016 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

	// Batch L1L2 get metrics
	MetricCmdGetSetL1       = metrics.AddCounter("cmd_get_set_l1")
	MetricCmdGetSetErrorsL1 = metrics.AddCounter("cmd_get_set_errors_l1")
	MetricCmdGetSetSucessL1 = metrics.AddCounter("cmd_get_set_success_l1")

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

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

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

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

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

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

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

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

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

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

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

	// 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")
	MetricCmdGatAddErrorsL1    = metrics.AddCounter("cmd_gat_add_errors_l1")
	MetricCmdGatAddStoredL1    = metrics.AddCounter("cmd_gat_add_stored_l1")
	MetricCmdGatAddNotStoredL1 = metrics.AddCounter("cmd_gat_add_not_stored_l1")
	MetricCmdGatSetL2          = metrics.AddCounter("cmd_gat_set_l2")
	MetricCmdGatSetErrorsL2    = metrics.AddCounter("cmd_gat_set_errors_l2")
	MetricCmdGatSetSuccessL2   = metrics.AddCounter("cmd_gat_set_success_l2")

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

	MetricCmdUnknown = metrics.AddCounter("cmd_unknown")
	MetricCmdNoop    = metrics.AddCounter("cmd_noop")
	MetricCmdQuit    = metrics.AddCounter("cmd_quit")
	MetricCmdVersion = metrics.AddCounter("cmd_version")
)

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) 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) 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) 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) 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) 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) 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) 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) 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
	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 common.Responder) Orca

func L1L2Batch 

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

func L1Only 

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

type OrcaConst 

type OrcaConst func(l1, l2 handlers.Handler, res common.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.