models

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

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

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

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

type DcpCollectionCreation = InternalDcpCollectionCreation

type DcpCollectionDeletion = InternalDcpCollectionDeletion

type DcpCollectionFlush = InternalDcpCollectionFlush

type DcpCollectionModification = InternalDcpCollectionModification

type DcpDeletion = InternalDcpDeletion

type DcpExpiration = InternalDcpExpiration

type DcpMutation = InternalDcpMutation

type DcpOSOSnapshot = gocbcore.DcpOSOSnapshot

type DcpScopeCreation = InternalDcpScopeCreation

type DcpScopeDeletion = InternalDcpScopeDeletion

type DcpSeqNoAdvanced = InternalDcpSeqNoAdvance

type DcpSnapshotMarker = gocbcore.DcpSnapshotMarker

type DcpStreamEnd = gocbcore.DcpStreamEnd

type DcpStreamEndContext struct {
	Err   error
	Event DcpStreamEnd
}

type EmptyEventHandler struct{}

type EventHandler interface {
	BeforeRebalanceStart()
	AfterRebalanceStart()
	BeforeRebalanceEnd()
	AfterRebalanceEnd()
	BeforeStreamStart()
	AfterStreamStart()
	BeforeStreamStop()
	AfterStreamStop()
}

type Identity struct {
	IP              string
	Name            string
	ClusterJoinTime int64
}

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

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

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

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

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

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

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

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

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

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

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

type Listener func(*ListenerContext)

type ListenerArgs struct {
	Event interface{}
}

type ListenerCh chan ListenerArgs

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

type ListenerEndCh chan DcpStreamEndContext

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

type PersistSeqNo struct {
	VbID  uint16
	SeqNo gocbcore.SeqNo
}

type PingResult struct {
	MemdEndpoint string
	MgmtEndpoint string
}

type SnapshotMarker struct {
	StartSeqNo uint64
	EndSeqNo   uint64
}