models

package
v1.1.44 Latest Latest
Warning

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

 Go to latest Published: May 29, 2024 License: MIT Imports: 4 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentQueue added in v1.1.29 

type AgentQueue struct {
	Address string
	IsDcp   bool
	Current int
	Max     int
}

type CheckpointDocument 

type CheckpointDocument struct {
	Checkpoint *CheckpointDocumentCheckpoint `json:"checkpoint"`
	BucketUUID string                        `json:"bucketUuid"`
}

func NewEmptyCheckpointDocument 

func NewEmptyCheckpointDocument(bucketUUID string) *CheckpointDocument

type CheckpointDocumentCheckpoint 

type CheckpointDocumentCheckpoint struct {
	Snapshot *CheckpointDocumentSnapshot `json:"snapshot"`
	VbUUID   uint64                      `json:"vbuuid"`
	SeqNo    uint64                      `json:"seqno"`
}

type CheckpointDocumentSnapshot 

type CheckpointDocumentSnapshot struct {
	StartSeqNo uint64 `json:"startSeqno"`
	EndSeqNo   uint64 `json:"endSeqno"`
}

type DcpCollectionCreation 

type DcpCollectionCreation = InternalDcpCollectionCreation

type DcpCollectionDeletion 

type DcpCollectionDeletion = InternalDcpCollectionDeletion

type DcpCollectionFlush 

type DcpCollectionFlush = InternalDcpCollectionFlush

type DcpCollectionModification 

type DcpCollectionModification = InternalDcpCollectionModification

type DcpDeletion 

type DcpDeletion = InternalDcpDeletion

type DcpExpiration 

type DcpExpiration = InternalDcpExpiration

type DcpMutation 

type DcpMutation = InternalDcpMutation

type DcpOSOSnapshot 

type DcpOSOSnapshot = gocbcore.DcpOSOSnapshot

type DcpScopeCreation 

type DcpScopeCreation = InternalDcpScopeCreation

type DcpScopeDeletion 

type DcpScopeDeletion = InternalDcpScopeDeletion

type DcpSeqNoAdvanced 

type DcpSeqNoAdvanced = InternalDcpSeqNoAdvance

type DcpSnapshotMarker 

type DcpSnapshotMarker = gocbcore.DcpSnapshotMarker

type DcpStreamEnd 

type DcpStreamEnd = gocbcore.DcpStreamEnd

type DcpStreamEndContext added in v1.1.7 

type DcpStreamEndContext struct {
	Err   error
	Event DcpStreamEnd
}

type EmptyEventHandler added in v0.0.67 

type EmptyEventHandler struct{}

func (*EmptyEventHandler) AfterRebalanceEnd added in v0.0.67 

func (h *EmptyEventHandler) AfterRebalanceEnd()

func (*EmptyEventHandler) AfterRebalanceStart added in v0.0.67 

func (h *EmptyEventHandler) AfterRebalanceStart()

func (*EmptyEventHandler) AfterStreamStart added in v0.0.67 

func (h *EmptyEventHandler) AfterStreamStart()

func (*EmptyEventHandler) AfterStreamStop added in v0.0.67 

func (h *EmptyEventHandler) AfterStreamStop()

func (*EmptyEventHandler) BeforeRebalanceEnd added in v0.0.67 

func (h *EmptyEventHandler) BeforeRebalanceEnd()

func (*EmptyEventHandler) BeforeRebalanceStart added in v0.0.67 

func (h *EmptyEventHandler) BeforeRebalanceStart()

func (*EmptyEventHandler) BeforeStreamStart added in v0.0.67 

func (h *EmptyEventHandler) BeforeStreamStart()

func (*EmptyEventHandler) BeforeStreamStop added in v0.0.67 

func (h *EmptyEventHandler) BeforeStreamStop()

type EventHandler added in v0.0.67 

type EventHandler interface {
	BeforeRebalanceStart()
	AfterRebalanceStart()
	BeforeRebalanceEnd()
	AfterRebalanceEnd()
	BeforeStreamStart()
	AfterStreamStart()
	BeforeStreamStop()
	AfterStreamStop()
}
var DefaultEventHandler EventHandler = &EmptyEventHandler{}

type Identity 

type Identity struct {
	IP              string
	Name            string
	ClusterJoinTime int64
}

func NewIdentityFromStr 

func NewIdentityFromStr(str string) *Identity

func (*Identity) Equal 

func (k *Identity) Equal(other *Identity) bool

func (*Identity) String 

func (k *Identity) String() string

type InternalDcpCollectionCreation added in v1.1.30 

type InternalDcpCollectionCreation struct {
	*gocbcore.DcpCollectionCreation
	Offset         *Offset
	CollectionName string
}

type InternalDcpCollectionDeletion added in v1.1.30 

type InternalDcpCollectionDeletion struct {
	*gocbcore.DcpCollectionDeletion
	Offset         *Offset
	CollectionName string
}

type InternalDcpCollectionFlush added in v1.1.30 

type InternalDcpCollectionFlush struct {
	*gocbcore.DcpCollectionFlush
	Offset         *Offset
	CollectionName string
}

type InternalDcpCollectionModification added in v1.1.30 

type InternalDcpCollectionModification struct {
	*gocbcore.DcpCollectionModification
	Offset         *Offset
	CollectionName string
}

type InternalDcpDeletion 

type InternalDcpDeletion struct {
	EventTime time.Time
	*gocbcore.DcpDeletion
	Offset         *Offset
	CollectionName string
}

type InternalDcpExpiration 

type InternalDcpExpiration struct {
	EventTime time.Time
	*gocbcore.DcpExpiration
	Offset         *Offset
	CollectionName string
}

type InternalDcpMutation 

type InternalDcpMutation struct {
	EventTime time.Time
	*gocbcore.DcpMutation
	Offset         *Offset
	CollectionName string
}

func (*InternalDcpMutation) IsCreated 

func (i *InternalDcpMutation) IsCreated() bool

type InternalDcpOSOSnapshot added in v1.1.30 

type InternalDcpOSOSnapshot struct {
	*gocbcore.DcpOSOSnapshot
	Offset *Offset
}

type InternalDcpScopeCreation added in v1.1.30 

type InternalDcpScopeCreation struct {
	*gocbcore.DcpScopeCreation
	Offset *Offset
}

type InternalDcpScopeDeletion added in v1.1.30 

type InternalDcpScopeDeletion struct {
	*gocbcore.DcpScopeDeletion
	Offset *Offset
}

type InternalDcpSeqNoAdvance 

type InternalDcpSeqNoAdvance struct {
	*gocbcore.DcpSeqNoAdvanced
	Offset *Offset
}

type Listener 

type Listener func(*ListenerContext)

type ListenerArgs 

type ListenerArgs struct {
	Event interface{}
}

type ListenerCh 

type ListenerCh chan ListenerArgs

type ListenerContext 

type ListenerContext struct {
	Commit func()
	Event  interface{}
	Ack    func()
}

type ListenerEndCh 

type ListenerEndCh chan DcpStreamEndContext

type Offset 

type Offset struct {
	*SnapshotMarker
	VbUUID gocbcore.VbUUID
	SeqNo  uint64
}

type PersistSeqNo 

type PersistSeqNo struct {
	VbID  uint16
	SeqNo gocbcore.SeqNo
}

type PingResult added in v1.1.19 

type PingResult struct {
	MemdEndpoint string
	MgmtEndpoint string
}

type SnapshotMarker 

type SnapshotMarker struct {
	StartSeqNo uint64
	EndSeqNo   uint64
}

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.