common

package

Go to main page

Versions in this module

v1

v1.19.0-rc1

Apr 19, 2017

v1.19.0-rc0

Apr 17, 2017

v1.18.0-rc3

Apr 5, 2017

v1.17.0-rc1

Mar 20, 2017

v1.16.0-rc1

Mar 6, 2017

v0

v0.2.0

Feb 6, 2017

Changes in this version

+ const FlushThreshold

+ const FlushTimeout

+ func NewTestMetricsReporter() metrics.Reporter

type MockRingpopMonitor

+ func (rpm *MockRingpopMonitor) FindRandomHost(service string) (*HostInfo, error)

type RingpopMonitor

+ FindRandomHost func(service string) (*HostInfo, error)

v0.2.0-rc2

Feb 21, 2017

v0.2.0-rc1

Feb 20, 2017

v0.1.0

Jan 25, 2017

Changes in this version

+ const CallerHostName

+ const CallerServiceName

+ const CallerUserName

+ const ControllerServiceName

+ const DLQMaxMergeAge

+ const FrontendServiceName

+ const HostMaxConnPerDestination

+ const HostOverallConnLimit

+ const HostPerConnMsgsLimitPerSecond

+ const HostPerExtentMsgsLimitPerSecond

+ const HostPerSecondConnLimit

+ const InputHostForRemoteExtent

+ const InputServiceName

+ const MaxDuration

+ const MaxHostMaxConnPerDestination

+ const MaxHostOverallConn

+ const MaxHostPerConnMsgsLimitPerSecond

+ const MaxHostPerExtentMsgsLimitPerSecond

+ const MaxHostPerSecondConn

+ const OutputServiceName

+ const ReplicatorServiceName

+ const SequenceBegin

+ const SequenceEnd

+ const StoreServiceName

+ const TagAckID

+ const TagAddr

+ const TagCnsPth

+ const TagCnsm

+ const TagCnsmID

+ const TagCtrl

+ const TagDLQID

+ const TagDbPath

+ const TagDeploymentName

+ const TagDplName

+ const TagDst

+ const TagDstPth

+ const TagErr

+ const TagEvent

+ const TagExt

+ const TagExtentCacheSize

+ const TagFrnt

+ const TagHostConnLimit

+ const TagHostIP

+ const TagHostName

+ const TagHostPort

+ const TagIn

+ const TagInPubConnID

+ const TagInPutAckID

+ const TagInReplicaHost

+ const TagModule

+ const TagMsgID

+ const TagOut

+ const TagReconfigureID

+ const TagReconfigureType

+ const TagReplicator

+ const TagRunnerName

+ const TagSeq

+ const TagService

+ const TagSlowDownSeconds

+ const TagState

+ const TagStor

+ const TagTbSleep

+ const TagTenancy

+ const TagUnknowPth

+ const TagUpdateUUID

+ const TagZoneName

+ const TenancyProd

+ const UUIDStringLength

+ var ConsumerGroupRegex = PathRegex

+ var ErrInsufficientHosts = errors.New("Not enough hosts to serve the request")

+ var ErrListenerAlreadyExist = errors.New("Listener already exist for the service")

+ var ErrLoadReportThrottled = errors.New("Too many load reports from the host.")

+ var ErrNoClient = &cherami.InternalServiceError

+ var ErrUUIDLookupFailed = errors.New("Cannot find ip:port corresponding to uuid")

+ var ErrUnknownService = errors.New("Service not tracked by RingpopMonitor")

+ var PathDLQRegex = regexp.MustCompile(`^/[\w.]*[a-zA-Z][\w.]*/[\w.]*[a-zA-Z][\w.]*.dlq$`)

+ var PathRegex = regexp.MustCompile(`^/[\w.]*[a-zA-Z][\w.]*/[\w.]*[a-zA-Z][\w.]*$`)

+ var PathRegexAllowUUID = regexp.Compile(...)

+ var ServiceToPort = map[string]string

+ var UUIDRegex = regexp.Compile(...)

+ func AdminNotificationTypePtr(notificationType admin.NotificationType) *admin.NotificationType

+ func AwaitWaitGroup(wg *sync.WaitGroup, timeout time.Duration) bool

+ func BoolPtr(v bool) *bool

+ func BootstrapRingpop(rp *ringpop.Ringpop, ipaddr string, port int, ...) error

+ func CQLTimestampToUnixNano(milliseconds int64) int64

+ func CalculateRate(last, curr SequenceNumber, lastTime, currTime UnixNanoTime) float64

+ func CheramiChecksumOptionPtr(checksumOption cherami.ChecksumOption) *cherami.ChecksumOption

+ func CheramiConsumerGroupExtentStatusPtr(status metadata.ConsumerGroupExtentStatus) *metadata.ConsumerGroupExtentStatus

+ func CheramiConsumerGroupStatusPtr(status cherami.ConsumerGroupStatus) *cherami.ConsumerGroupStatus

+ func CheramiDestinationStatusPtr(status cherami.DestinationStatus) *cherami.DestinationStatus

+ func CheramiDestinationType(internalDestinationType shared.DestinationType) (cheramiDestinationType cherami.DestinationType, err error)

+ func CheramiDestinationTypePtr(destType cherami.DestinationType) *cherami.DestinationType

+ func CheramiInputHostCommandTypePtr(cmdType cherami.InputHostCommandType) *cherami.InputHostCommandType

+ func CheramiOutputHostCommandTypePtr(cmdType cherami.OutputHostCommandType) *cherami.OutputHostCommandType

+ func CheramiProtocolPtr(protocol cherami.Protocol) *cherami.Protocol

+ func CheramiStatusPtr(status cherami.Status) *cherami.Status

+ func ClassifyErrorByType(in error) metrics.ErrorClass

+ func ConstructAckID(sessionID uint16, ackMgrID uint16, seqNum uint32, address int64) string

+ func ConsumerGroupExtentMetricsPtr(cgExtMetrics controller.ConsumerGroupExtentMetrics) *controller.ConsumerGroupExtentMetrics

+ func ConsumerGroupMetricsPtr(cgMetrics controller.ConsumerGroupMetrics) *controller.ConsumerGroupMetrics

+ func ConvertDownstreamErrors(l bark.Logger, in error) (metrics.ErrorClass, error)

+ func CreateCassandraKeyspace(s *gocql.Session, keyspace string, replicas int, overwrite bool) (err error)

+ func CreateHyperbahnClient(ch *tchannel.Channel, bootstrapFile string) *hyperbahn.Client

+ func CreateInputHostAdminClient(ch *tchannel.Channel, hostPort string) (admin.TChanInputHostAdmin, error)

+ func CreateOutputHostAdminClient(ch *tchannel.Channel, hostPort string) (admin.TChanOutputHostAdmin, error)

+ func CreateRingpop(service string, ch *tchannel.Channel, ipaddr string, port int) *(ringpop.Ringpop)

+ func DestinationExtentMetricsPtr(dstExtMetrics controller.DestinationExtentMetrics) *controller.DestinationExtentMetrics

+ func DestinationMetricsPtr(dstMetrics controller.DestinationMetrics) *controller.DestinationMetrics

+ func DropCassandraKeyspace(s *gocql.Session, keyspace string) (err error)

+ func ExtrapolateDifference(observedA, observedB SequenceNumber, observedARate, observedBRate float64, ...) (extrapolated int64)

+ func Float64Ptr(v float64) *float64

+ func FmtAckID(s string) string

+ func FmtAddr(i int64) string

+ func FmtCnsPth(s string) string

+ func FmtCnsm(s string) string

+ func FmtCnsmID(s int) string

+ func FmtCtrl(s string) string

+ func FmtDLQID(s string) string

+ func FmtDplName(s string) string

+ func FmtDst(s string) string

+ func FmtDstPth(s string) string

+ func FmtExt(s string) string

+ func FmtFrnt(s string) string

+ func FmtHostConnLimit(s int) string

+ func FmtHostIP(s string) string

+ func FmtHostName(s string) string

+ func FmtHostPort(s string) string

+ func FmtIn(s string) string

+ func FmtInPubConnID(s int) string

+ func FmtInPutAckID(s string) string

+ func FmtInReplicaHost(s string) string

+ func FmtMsgID(s string) string

+ func FmtOut(s string) string

+ func FmtReconfigureID(s string) string

+ func FmtReconfigureType(s admin.NotificationType) string

+ func FmtService(s string) string

+ func FmtSlowDown(s time.Duration) string

+ func FmtStor(s string) string

+ func FmtTbSleep(s time.Duration) string

+ func FmtTenancy(s string) string

+ func FmtZoneName(s string) string

+ func GetConnectionKey(host *cherami.HostAddress) string

+ func GetDLQPathNameFromCGName(CGName string) (string, error)

+ func GetDateTag() string

+ func GetDefaultLogger() bark.Logger

+ func GetDirectoryName(path string) (string, error)

+ func GetEnvVariableFromHostPort(hostPort string) (envVar string)

+ func GetLocalClusterInfo(deployment string) (zone string, tenancy string)

+ func GetOpenAppendStreamRequestHTTP(httpHeader http.Header) (req *store.OpenAppendStreamRequest, err error)

+ func GetOpenAppendStreamRequestHeaders(req *store.OpenAppendStreamRequest) (headers map[string]string)

+ func GetOpenAppendStreamRequestStruct(headers map[string]string) (req *store.OpenAppendStreamRequest, err error)

+ func GetOpenReadStreamRequestHTTP(httpHeader http.Header) (req *store.OpenReadStreamRequest, err error)

+ func GetOpenReadStreamRequestHTTPHeaders(req *store.OpenReadStreamRequest) http.Header

+ func GetOpenReadStreamRequestHeaders(req *store.OpenReadStreamRequest) (headers map[string]string)

+ func GetOpenReadStreamRequestStruct(headers map[string]string) (req *store.OpenReadStreamRequest, err error)

+ func GetOpenReplicationReadStreamRequestHTTPHeaders(req *OpenReplicationReadStreamRequest) http.Header

+ func GetOpenReplicationRemoteReadStreamRequestHTTPHeaders(req *OpenReplicationRemoteReadStreamRequest) http.Header

+ func GetRandInt64(min int64, max int64) int64

+ func GetTagsFromPath(path string) (string, error)

+ func Int32Ptr(v int32) *int32

+ func Int64Ptr(v int64) *int64

+ func IntPtr(v int) *int

+ func InternalChecksumOptionPtr(checksumOption shared.ChecksumOption) *shared.ChecksumOption

+ func InternalConsumerGroupStatusPtr(status shared.ConsumerGroupStatus) *shared.ConsumerGroupStatus

+ func InternalConsumerGroupTypePtr(cgType shared.ConsumerGroupType) *shared.ConsumerGroupType

+ func InternalDestinationStatusPtr(status shared.DestinationStatus) *shared.DestinationStatus

+ func InternalDestinationTypePtr(destType shared.DestinationType) *shared.DestinationType

+ func InternalExtentReplicaReplicationStatusTypePtr(status shared.ExtentReplicaReplicationStatus) *shared.ExtentReplicaReplicationStatus

+ func IsDLQDestination(dstDesc *shared.DestinationDescription) bool

+ func IsDLQDestinationPath(path string) bool

+ func IsDevelopmentEnvironment(deploymentName string) (devEnv bool)

+ func IsRemoteZoneExtent(extentOriginZone string, localZone string) bool

+ func IsRetryableTChanErr(err error) bool

+ func IsValidServiceName(input string) bool

+ func LoadCassandraSchema(cqlshpath string, fileName string, keyspace string) (err error)

+ func MaxInt(a, b int) int

+ func MaxInt64(a, b int64) int64

+ func MetadataConsumerGroupExtentStatusPtr(status metadata.ConsumerGroupExtentStatus) *metadata.ConsumerGroupExtentStatus

+ func MetadataExtentReplicaStatusPtr(status shared.ExtentReplicaStatus) *shared.ExtentReplicaStatus

+ func MetadataExtentStatusPtr(status shared.ExtentStatus) *shared.ExtentStatus

+ func MinInt(a, b int) int

+ func MinInt64(a, b int64) int64

+ func NewCassandraCluster(clusterHosts string) *gocql.ClusterConfig

+ func NewMetricReporterWithHostname(cfg configure.CommonServiceConfig) metrics.Reporter

+ func NodeMetricsPtr(nodeMetrics controller.NodeMetrics) *controller.NodeMetrics

+ func OverrideValueByPrefix(logFn func() bark.Logger, path string, overrides []string, defaultVal int64, ...) int64

+ func RWLockReadAndConditionalWrite(m *sync.RWMutex, readFn func() bool, writeFn func())

+ func RandomBytes(size int) []byte

+ func RolePtr(role controller.Role) *controller.Role

+ func SKUPtr(sku controller.SKU) *controller.SKU

+ func ServiceLoop(port int, cfg configure.CommonAppConfig, service *Service)

+ func SetupServerConfig(configurator configure.Configure) configure.CommonAppConfig

+ func ShortenGUIDString(s string) string

+ func SpinWaitOnCondition(condition ConditionFunc, timeout time.Duration) bool

+ func SplitHostPort(hostPort string) (string, int, error)

+ func StartEKG(lclLg bark.Logger)

+ func StoreExtentMetricsPtr(storeExtMetrics controller.StoreExtentMetrics) *controller.StoreExtentMetrics

+ func StringPtr(v string) *string

+ func TSPtr(v time.Time) *time.Time

+ func UUIDHashCode(key string) uint32

+ func UUIDToUint16(s string) uint16

+ func Uint32Ptr(v uint32) *uint32

+ func Uint64Ptr(v uint64) *uint64

+ func UnixNanoToCQLTimestamp(timestamp int64) int64

+ func WSStart(listenAddress string, port int, wsservice WSService)

+ func WaitTimeout(timeout time.Duration, fn func()) bool

+ type AckID struct

+ Address int64

+ MutatedID CombinedID

+ func AckIDFromString(ackID string) (*AckID, error)

+ func (a AckID) ConstructCombinedID(sessionID uint64, ackMgrID uint64, seqNum uint64) CombinedID

+ func (a AckID) ToString() string

+ type CliHelper interface

+ GetCanonicalZone func(zone string) (string, error)

+ GetDefaultOwnerEmail func() string

+ SetCanonicalZones func(map[string]string)

+ SetDefaultOwnerEmail func(string)

+ func NewCliHelper() CliHelper

+ type ClientFactory interface

+ GetAdminControllerClient func() (admin.TChanControllerHostAdmin, error)

+ GetControllerClient func() (controller.TChanController, error)

+ GetReplicatorClient func() (replicator.TChanReplicator, error)

+ GetThriftStoreClient func(replica string, pathUUID string) (store.TChanBStore, error)

+ GetThriftStoreClientUUID func(storeUUID string, contextID string) (store.TChanBStore, string, error)

+ ReleaseThriftStoreClient func(pathUUID string)

+ func NewClientFactory(rpm RingpopMonitor, ch *tchannel.Channel, log bark.Logger) ClientFactory

+ type CombinedID uint64

+ func (c CombinedID) DeconstructCombinedID() (uint16, uint16, uint32)

+ type ConcurrentMap interface

+ Contains func(key string) bool

+ Get func(key string) (interface{}, bool)

+ Iter func() MapIterator

+ Put func(key string, value interface{})

+ PutIfNotExist func(key string, value interface{}) bool

+ Remove func(key string)

+ Size func() int

+ func NewShardedConcurrentMap(initialCap int, hashfn HashFunc) ConcurrentMap

+ type ConditionFunc func() bool

+ type CounterBank struct

+ func NewCounterBank(size int) *CounterBank

+ func (c *CounterBank) Add(idx int, delta int64) int64

+ func (c *CounterBank) Decrement(idx int) int64

+ func (c *CounterBank) Get(idx int) int64

+ func (c *CounterBank) GetAndReset(idx int) int64

+ func (c *CounterBank) Increment(idx int) int64

+ func (c *CounterBank) Set(idx int, value int64) int64

+ type Daemon interface

+ Start func()

+ Stop func()

+ type GeometricRollingAverage float64

+ func (avg *GeometricRollingAverage) GetGeometricRollingAverage() float64

+ func (avg *GeometricRollingAverage) SetGeometricRollingAverage(val float64)

+ type HTTPHandler struct

+ func NewHTTPHandler(cfg configure.CommonAppConfig, service *Service) *HTTPHandler

+ func (handler *HTTPHandler) Register(mux *http.ServeMux)

+ type HashFunc func(string) uint32

+ type Heartbeat struct

+ func NewHeartbeat(id *string) *Heartbeat

+ func (h *Heartbeat) Beat()

+ func (h *Heartbeat) CloseHeartbeat()

+ type HostAckIDGenerator interface

+ GetNextAckID func() uint32

+ func NewHostAckIDGenerator(startFrom uint32) HostAckIDGenerator

+ type HostHardwareInfo struct

+ Rack string

+ Sku string

+ Zone string

+ type HostHardwareInfoReader interface

+ Read func(hostname string) (*HostHardwareInfo, error)

+ func NewHostHardwareInfoReader(mClient m.TChanMetadataService) HostHardwareInfoReader

+ type HostIDHeartbeater interface

+ func NewHostIDHeartbeater(mClient metadata.TChanMetadataService, hostID string, hostAddr string, ...) HostIDHeartbeater

+ type HostInfo struct

+ Addr string

+ Name string

+ Rack string

+ Sku string

+ UUID string

+ Zone string

+ func (hi *HostInfo) String() string

+ type Item struct

+ Key int64

+ Value interface{}

+ type LoadReporter interface

+ ReportConsumerGroupExtentMetric func(destinationUUID string, consumerGroupUUID string, extentUUID string, ...) error

+ ReportConsumerGroupMetric func(destinationUUID string, consumerGroupUUID string, ...) error

+ ReportDestinationExtentMetric func(destinationUUID string, extentUUID string, ...) error

+ ReportDestinationMetric func(destinationUUID string, metrics controller.DestinationMetrics) error

+ ReportHostMetric func(metrics controller.NodeMetrics) error

+ ReportStoreExtentMetric func(extentUUID string, metrics controller.StoreExtentMetrics) error

+ type LoadReporterDaemon interface

+ type LoadReporterDaemonFactory interface

+ CreateReporter func(interval time.Duration, source LoadReporterSource, logger bark.Logger) LoadReporterDaemon

+ func NewLoadReporterDaemonFactory(hostUUID string, sku controller.SKU, role controller.Role, ...) LoadReporterDaemonFactory

+ type LoadReporterSource interface

+ Report func(reporter LoadReporter)

+ type MapEntry struct

+ Key string

+ Value interface{}

+ type MapIterator interface

+ Close func()

+ Entries func() <-chan *MapEntry

+ type MetadataMgr interface

+ AddExtentToConsumerGroup func(dstID string, cgID string, extentID string, outHostID string, ...) error

+ CreateExtent func(dstID string, extentID string, inhostID string, storeIDs []string) (*shared.CreateExtentResult_, error)

+ CreateRemoteZoneExtent func(dstID string, extentID string, inhostID string, storeIDs []string, ...) (*shared.CreateExtentResult_, error)

+ DeleteConsumerGroup func(dstID string, cgName string) error

+ DeleteDestination func(dstID string) error

+ ListConsumerGroupsByDstID func(dstID string) ([]*shared.ConsumerGroupDescription, error)

+ ListConsumerGroupsPage func(mReq *m.ListConsumerGroupRequest) (*m.ListConsumerGroupResult_, error)

+ ListDestinations func() ([]*shared.DestinationDescription, error)

+ ListDestinationsByUUID func() ([]*shared.DestinationDescription, error)

+ ListDestinationsPage func(mReq *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

+ ListExtentsByConsumerGroup func(dstID string, cgID string, filterByStatus []m.ConsumerGroupExtentStatus) ([]*m.ConsumerGroupExtent, error)

+ ListExtentsByDstIDStatus func(dstID string, filterByStatus []shared.ExtentStatus) ([]*shared.ExtentStats, error)

+ ListExtentsByInputIDStatus func(inputID string, status *shared.ExtentStatus) ([]*shared.ExtentStats, error)

+ ListExtentsByReplicationStatus func(storeID string, status *shared.ExtentReplicaReplicationStatus) ([]*shared.ExtentStats, error)

+ ListExtentsByStoreIDStatus func(storeID string, status *shared.ExtentStatus) ([]*shared.ExtentStats, error)

+ MoveExtent func(fromDstID, toDstID, extentID, cgUUID string) error

+ ReadConsumerGroup func(dstID, dstPath, cgUUID, cgName string) (*shared.ConsumerGroupDescription, error)

+ ReadConsumerGroupByUUID func(cgUUID string) (*shared.ConsumerGroupDescription, error)

+ ReadConsumerGroupExtent func(dstID string, cgID string, extentID string) (*m.ConsumerGroupExtent, error)

+ ReadDestination func(dstID string, dstPath string) (*shared.DestinationDescription, error)

+ ReadExtentStats func(dstID string, extentID string) (*shared.ExtentStats, error)

+ ReadStoreExtentStats func(extentID string, storeID string) (*shared.ExtentStats, error)

+ SealExtent func(dstID string, extentID string) error

+ UpdateConsumerGroupExtentStatus func(cgID, extID string, status m.ConsumerGroupExtentStatus) error

+ UpdateDestinationDLQCursors func(dstID string, mergeBefore UnixNanoTime, purgeBefore UnixNanoTime) error

+ UpdateExtentStatus func(dstID, extID string, status shared.ExtentStatus) error

+ UpdateOutHost func(dstID string, cgID string, extentID string, outHostID string) error

+ UpdateRemoteExtentPrimaryStore func(dstID string, extentID string, remoteExtentPrimaryStore string) (*m.UpdateExtentStatsResult_, error)

+ func NewMetadataMgr(mClient m.TChanMetadataService, m3Client metrics.Client, logger bark.Logger) MetadataMgr

+ type MinHeap []*Item

+ func (mh *MinHeap) Pop() interface{}

+ func (mh *MinHeap) Push(x interface{})

+ func (mh MinHeap) Len() int

+ func (mh MinHeap) Less(i, j int) bool

+ func (mh MinHeap) Swap(i, j int)

+ type MockLoadReporterDaemon struct

+ func (m *MockLoadReporterDaemon) Start()

+ func (m *MockLoadReporterDaemon) Stop()

+ type MockLoadReporterDaemonFactory struct

+ func (m *MockLoadReporterDaemonFactory) CreateReporter(interval time.Duration, source LoadReporterSource, logger bark.Logger) LoadReporterDaemon

+ type MockRingpopMonitor struct

+ func NewMockRingpopMonitor() *MockRingpopMonitor

+ func (rpm *MockRingpopMonitor) Add(service string, uuid string, addr string)

+ func (rpm *MockRingpopMonitor) AddListener(service string, name string, ch chan<- *RingpopListenerEvent) error

+ func (rpm *MockRingpopMonitor) FindHostForAddr(service string, addr string) (*HostInfo, error)

+ func (rpm *MockRingpopMonitor) FindHostForKey(service string, key string) (*HostInfo, error)

+ func (rpm *MockRingpopMonitor) GetBootstrappedChannel() chan struct{}

+ func (rpm *MockRingpopMonitor) GetHosts(service string) ([]*HostInfo, error)

+ func (rpm *MockRingpopMonitor) IsHostHealthy(service string, uuid string) bool

+ func (rpm *MockRingpopMonitor) Remove(service string, uuid string)

+ func (rpm *MockRingpopMonitor) RemoveListener(service string, name string) error

+ func (rpm *MockRingpopMonitor) ResolveUUID(service string, uuid string) (string, error)

+ func (rpm *MockRingpopMonitor) SetMetadata(key string, data string) error

+ func (rpm *MockRingpopMonitor) Start()

+ func (rpm *MockRingpopMonitor) Stop()

+ type MockService struct

+ func (m *MockService) GetClientFactory() ClientFactory

+ func (m *MockService) GetConfig() configure.CommonServiceConfig

+ func (m *MockService) GetDConfigClient() dconfig.Client

+ func (m *MockService) GetHostName() string

+ func (m *MockService) GetHostPort() string

+ func (m *MockService) GetHostUUID() string

+ func (m *MockService) GetLoadReporterDaemonFactory() LoadReporterDaemonFactory

+ func (m *MockService) GetMetricsReporter() metrics.Reporter

+ func (m *MockService) GetRingpopMonitor() RingpopMonitor

+ func (m *MockService) GetTChannel() *tchannel.Channel

+ func (m *MockService) GetWSConnector() WSConnector

+ func (m *MockService) IsLimitsEnabled() bool

+ func (m *MockService) Report(reporter LoadReporter)

+ func (m *MockService) SetClientFactory(cf ClientFactory)

+ func (m *MockService) Start(thriftService []thrift.TChanServer)

+ func (m *MockService) Stop()

+ type MockTimeSource struct

+ func NewMockTimeSource() *MockTimeSource

+ func (ts *MockTimeSource) Advance(d time.Duration)

+ func (ts *MockTimeSource) Now() time.Time

+ type OneShotTimer interface

+ Chan func() <-chan time.Time

+ Reset func(d time.Duration) bool

+ Stop func() bool

+ type OpenAppendInWebsocketStream struct

+ func NewOpenAppendInWebsocketStream(stream websocket.StreamServer) *OpenAppendInWebsocketStream

+ func (s *OpenAppendInWebsocketStream) Done() error

+ func (s *OpenAppendInWebsocketStream) Flush() error

+ func (s *OpenAppendInWebsocketStream) Read() (*store.AppendMessage, error)

+ func (s *OpenAppendInWebsocketStream) SetResponseHeaders(headers map[string]string) error

+ func (s *OpenAppendInWebsocketStream) Write(arg *store.AppendMessageAck) error

+ type OpenAppendOutWebsocketStream struct

+ func NewOpenAppendOutWebsocketStream(stream websocket.StreamClient) *OpenAppendOutWebsocketStream

+ func (s *OpenAppendOutWebsocketStream) Done() error

+ func (s *OpenAppendOutWebsocketStream) Flush() error

+ func (s *OpenAppendOutWebsocketStream) Read() (*store.AppendMessageAck, error)

+ func (s *OpenAppendOutWebsocketStream) ResponseHeaders() (map[string]string, error)

+ func (s *OpenAppendOutWebsocketStream) Write(arg *store.AppendMessage) error

+ type OpenConsumerInWebsocketStream struct

+ func NewOpenConsumerInWebsocketStream(stream websocket.StreamServer) *OpenConsumerInWebsocketStream

+ func (s *OpenConsumerInWebsocketStream) Done() error

+ func (s *OpenConsumerInWebsocketStream) Flush() error

+ func (s *OpenConsumerInWebsocketStream) Read() (*cherami.ControlFlow, error)

+ func (s *OpenConsumerInWebsocketStream) SetResponseHeaders(headers map[string]string) error

+ func (s *OpenConsumerInWebsocketStream) Write(arg *cherami.OutputHostCommand) error

+ type OpenConsumerOutWebsocketStream struct

+ func NewOpenConsumerOutWebsocketStream(stream websocket.StreamClient) *OpenConsumerOutWebsocketStream

+ func (s *OpenConsumerOutWebsocketStream) Done() error

+ func (s *OpenConsumerOutWebsocketStream) Flush() error

+ func (s *OpenConsumerOutWebsocketStream) Read() (*cherami.OutputHostCommand, error)

+ func (s *OpenConsumerOutWebsocketStream) ResponseHeaders() (map[string]string, error)

+ func (s *OpenConsumerOutWebsocketStream) Write(arg *cherami.ControlFlow) error

+ type OpenPublisherInWebsocketStream struct

+ func NewOpenPublisherInWebsocketStream(stream websocket.StreamServer) *OpenPublisherInWebsocketStream

+ func (s *OpenPublisherInWebsocketStream) Done() error

+ func (s *OpenPublisherInWebsocketStream) Flush() error

+ func (s *OpenPublisherInWebsocketStream) Read() (*cherami.PutMessage, error)

+ func (s *OpenPublisherInWebsocketStream) SetResponseHeaders(headers map[string]string) error

+ func (s *OpenPublisherInWebsocketStream) Write(arg *cherami.InputHostCommand) error

+ type OpenPublisherOutWebsocketStream struct

+ func NewOpenPublisherOutWebsocketStream(stream websocket.StreamClient) *OpenPublisherOutWebsocketStream

+ func (s *OpenPublisherOutWebsocketStream) Done() error

+ func (s *OpenPublisherOutWebsocketStream) Flush() error

+ func (s *OpenPublisherOutWebsocketStream) Read() (*cherami.InputHostCommand, error)

+ func (s *OpenPublisherOutWebsocketStream) ResponseHeaders() (map[string]string, error)

+ func (s *OpenPublisherOutWebsocketStream) Write(arg *cherami.PutMessage) error

+ type OpenReadInWebsocketStream struct

+ func NewOpenReadInWebsocketStream(stream websocket.StreamServer) *OpenReadInWebsocketStream

+ func (s *OpenReadInWebsocketStream) Done() error

+ func (s *OpenReadInWebsocketStream) Flush() error

+ func (s *OpenReadInWebsocketStream) Read() (*cherami.ControlFlow, error)

+ func (s *OpenReadInWebsocketStream) SetResponseHeaders(headers map[string]string) error

+ func (s *OpenReadInWebsocketStream) Write(arg *store.ReadMessageContent) error

+ type OpenReadOutWebsocketStream struct

+ func NewOpenReadOutWebsocketStream(stream websocket.StreamClient) *OpenReadOutWebsocketStream

+ func (s *OpenReadOutWebsocketStream) Done() error

+ func (s *OpenReadOutWebsocketStream) Flush() error

+ func (s *OpenReadOutWebsocketStream) Read() (*store.ReadMessageContent, error)

+ func (s *OpenReadOutWebsocketStream) ResponseHeaders() (map[string]string, error)

+ func (s *OpenReadOutWebsocketStream) Write(arg *cherami.ControlFlow) error

+ type OpenReplicationReadStreamRequest struct

+ func GetOpenReplicationReadStreamRequestHTTP(httpHeader http.Header) (req *OpenReplicationReadStreamRequest, err error)

+ type OpenReplicationRemoteReadStreamRequest struct

+ func GetOpenReplicationRemoteReadStreamRequestHTTP(httpHeader http.Header) (req *OpenReplicationRemoteReadStreamRequest, err error)

+ type RingpopEventType int

+ const HostAddedEvent

+ const HostRemovedEvent

+ type RingpopListenerEvent struct

+ Key string

+ Type RingpopEventType

+ type RingpopMonitor interface

+ AddListener func(service string, name string, notifyChannel chan<- *RingpopListenerEvent) error

+ FindHostForAddr func(service string, addr string) (*HostInfo, error)

+ FindHostForKey func(service string, key string) (*HostInfo, error)

+ GetBootstrappedChannel func() chan struct{}

+ GetHosts func(service string) ([]*HostInfo, error)

+ IsHostHealthy func(service string, uuid string) bool

+ RemoveListener func(service string, name string) error

+ ResolveUUID func(service string, uuid string) (string, error)

+ SetMetadata func(key string, data string) error

+ Start func()

+ Stop func()

+ func NewRingpopMonitor(rp *ringpop.Ringpop, services []string, resolver UUIDResolver, ...) RingpopMonitor

+ type SCommon interface

+ GetClientFactory func() ClientFactory

+ GetConfig func() configure.CommonServiceConfig

+ GetDConfigClient func() dconfig.Client

+ GetHostName func() string

+ GetHostPort func() string

+ GetHostUUID func() string

+ GetLoadReporterDaemonFactory func() LoadReporterDaemonFactory

+ GetMetricsReporter func() metrics.Reporter

+ GetRingpopMonitor func() RingpopMonitor

+ GetTChannel func() *tchannel.Channel

+ GetWSConnector func() WSConnector

+ IsLimitsEnabled func() bool

+ Report func(reporter LoadReporter)

+ SetClientFactory func(cf ClientFactory)

+ Start func(thriftService []thrift.TChanServer)

+ Stop func()

+ type Seconds float64

+ func DurationToSeconds(t time.Duration) Seconds

+ type SequenceNumber int64

+ func ExtrapolateValue(observed SequenceNumber, observedRate float64, ...) (extrapolated SequenceNumber)

+ type Service struct

+ func NewService(serviceName string, uuid string, cfg configure.CommonServiceConfig, ...) *Service

+ func (h *Service) GetClientFactory() ClientFactory

+ func (h *Service) GetConfig() configure.CommonServiceConfig

+ func (h *Service) GetDConfigClient() dconfig.Client

+ func (h *Service) GetHostName() string

+ func (h *Service) GetHostPort() string

+ func (h *Service) GetHostUUID() string

+ func (h *Service) GetLoadReporterDaemonFactory() LoadReporterDaemonFactory

+ func (h *Service) GetMetricsReporter() metrics.Reporter

+ func (h *Service) GetRingpopMonitor() RingpopMonitor

+ func (h *Service) GetTChannel() *tchannel.Channel

+ func (h *Service) GetWSConnector() WSConnector

+ func (h *Service) IsLimitsEnabled() bool

+ func (h *Service) Report(reporter LoadReporter)

+ func (h *Service) SetClientFactory(cf ClientFactory)

+ func (h *Service) Start(thriftServices []thrift.TChanServer)

+ func (h *Service) Stop()

+ func (h *Service) UpdateAdvertisedName(deploymentName string)

+ type ShardedConcurrentMap struct

+ func (cmap *ShardedConcurrentMap) Contains(key string) bool

+ func (cmap *ShardedConcurrentMap) Get(key string) (interface{}, bool)

+ func (cmap *ShardedConcurrentMap) Iter() MapIterator

+ func (cmap *ShardedConcurrentMap) Put(key string, value interface{})

+ func (cmap *ShardedConcurrentMap) PutIfNotExist(key string, value interface{}) bool

+ func (cmap *ShardedConcurrentMap) Remove(key string)

+ func (cmap *ShardedConcurrentMap) Size() int

+ type TickerSource interface

+ Stop func()

+ Ticks func() <-chan time.Time

+ type TickerSourceFactory interface

+ CreateTicker func(interval time.Duration) TickerSource

+ func NewRealTimeTickerFactory() TickerSourceFactory

+ type TimeSource interface

+ Now func() time.Time

+ func NewRealTimeSource() TimeSource

+ type Timer struct

+ func NewTimer(d time.Duration) *Timer

+ func (t *Timer) Chan() <-chan time.Time

+ func (t *Timer) Reset(d time.Duration) bool

+ func (t *Timer) Stop() bool

+ type TimerFactory interface

+ NewTimer func(d time.Duration) OneShotTimer

+ func NewTimerFactory() TimerFactory

+ type TokenBucket interface

+ Consume func(count int, timeout time.Duration) bool

+ TryConsume func(count int) (bool, time.Duration)

+ func NewTokenBucket(rps int, timeSource TimeSource) TokenBucket

+ type TokenBucketFactory interface

+ CreateTokenBucket func(rps int, timeSource TimeSource) TokenBucket

+ func NewTokenBucketFactory() TokenBucketFactory

+ type UUIDResolver interface

+ ClearCache func()

+ Lookup func(uuid string) (string, error)

+ ReverseLookup func(addr string) (string, error)

+ func NewUUIDResolver(mClient metadata.TChanMetadataService) UUIDResolver

+ type UnixNanoTime int64

+ func Now() UnixNanoTime

+ func (u UnixNanoTime) ToSeconds() Seconds

+ func (u UnixNanoTime) ToSecondsFmt() string

+ type WSConnector interface

+ AcceptAppendStream func(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenAppendStreamInCall, error)

+ AcceptConsumerStream func(w http.ResponseWriter, r *http.Request) (serverStream.BOutOpenConsumerStreamInCall, error)

+ AcceptPublisherStream func(w http.ResponseWriter, r *http.Request) (serverStream.BInOpenPublisherStreamInCall, error)

+ AcceptReadStream func(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)

+ AcceptReplicationReadStream func(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)

+ AcceptReplicationRemoteReadStream func(w http.ResponseWriter, r *http.Request) (serverStream.BStoreOpenReadStreamInCall, error)

+ OpenAppendStream func(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenAppendStreamOutCall, error)

+ OpenConsumerStream func(hostPort string, requestHeader http.Header) (stream.BOutOpenConsumerStreamOutCall, error)

+ OpenPublisherStream func(hostPort string, requestHeader http.Header) (stream.BInOpenPublisherStreamOutCall, error)

+ OpenReadStream func(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

+ OpenReplicationReadStream func(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

+ OpenReplicationRemoteReadStream func(hostPort string, requestHeader http.Header) (serverStream.BStoreOpenReadStreamOutCall, error)

+ func NewWSConnector() WSConnector

+ type WSService interface

+ RegisterWSHandler func() *http.ServeMux

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