models

Documentation

Index

• type CheckpointDocument
  • func NewEmptyCheckpointDocument(bucketUUID string) *CheckpointDocument
• type CheckpointDocumentCheckpoint
• type CheckpointDocumentSnapshot
• type DcpCollectionCreation
• type DcpCollectionDeletion
• type DcpCollectionFlush
• type DcpCollectionModification
• type DcpDeletion
• type DcpExpiration
• type DcpMutation
• type DcpOSOSnapshot
• type DcpScopeCreation
• type DcpScopeDeletion
• type DcpSeqNoAdvanced
• type DcpSnapshotMarker
• type DcpStreamEnd
• type EmptyEventHandler
  • func (h *EmptyEventHandler) AfterRebalanceEnd()
  • func (h *EmptyEventHandler) AfterRebalanceStart()
  • func (h *EmptyEventHandler) AfterStreamStart()
  • func (h *EmptyEventHandler) AfterStreamStop()
  • func (h *EmptyEventHandler) BeforeRebalanceEnd()
  • func (h *EmptyEventHandler) BeforeRebalanceStart()
  • func (h *EmptyEventHandler) BeforeStreamStart()
  • func (h *EmptyEventHandler) BeforeStreamStop()
• type EventHandler
• type Identity
  • func NewIdentityFromEnv() *Identity
  • func NewIdentityFromStr(str string) *Identity
  • func (k *Identity) Equal(other *Identity) bool
  • func (k *Identity) String() string
• type InternalDcpDeletion
• type InternalDcpExpiration
• type InternalDcpMutation
  • func (i *InternalDcpMutation) IsCreated() bool
• type InternalDcpSeqNoAdvance
• type Listener
• type ListenerArgs
• type ListenerCh
• type ListenerContext
• type ListenerEndCh
• type Offset
• type PersistSeqNo
• type SnapshotMarker

Types

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 = gocbcore.DcpCollectionCreation

type DcpCollectionDeletion

type DcpCollectionDeletion = gocbcore.DcpCollectionDeletion

type DcpCollectionFlush

type DcpCollectionFlush = gocbcore.DcpCollectionFlush

type DcpCollectionModification

type DcpCollectionModification = gocbcore.DcpCollectionModification

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 = gocbcore.DcpScopeCreation

type DcpScopeDeletion

type DcpScopeDeletion = gocbcore.DcpScopeDeletion

type DcpSeqNoAdvanced

type DcpSeqNoAdvanced = InternalDcpSeqNoAdvance

type DcpSnapshotMarker

type DcpSnapshotMarker = gocbcore.DcpSnapshotMarker

type DcpStreamEnd

type DcpStreamEnd = gocbcore.DcpStreamEnd

type EmptyEventHandler

type EmptyEventHandler struct{}

func (*EmptyEventHandler) AfterRebalanceEnd

func (h *EmptyEventHandler) AfterRebalanceEnd()

func (*EmptyEventHandler) AfterRebalanceStart

func (h *EmptyEventHandler) AfterRebalanceStart()

func (*EmptyEventHandler) AfterStreamStart

func (h *EmptyEventHandler) AfterStreamStart()

func (*EmptyEventHandler) AfterStreamStop

func (h *EmptyEventHandler) AfterStreamStop()

func (*EmptyEventHandler) BeforeRebalanceEnd

func (h *EmptyEventHandler) BeforeRebalanceEnd()

func (*EmptyEventHandler) BeforeRebalanceStart

func (h *EmptyEventHandler) BeforeRebalanceStart()

func (*EmptyEventHandler) BeforeStreamStart

func (h *EmptyEventHandler) BeforeStreamStart()

func (*EmptyEventHandler) BeforeStreamStop

func (h *EmptyEventHandler) BeforeStreamStop()

type EventHandler

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

var DefaultEventHandler EventHandler = &EmptyEventHandler{}

type Identity

type Identity struct {
	IP   string
	Name string
}

func NewIdentityFromEnv

func NewIdentityFromEnv() *Identity

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 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 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 DcpStreamEnd

type Offset

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

type PersistSeqNo

type PersistSeqNo struct {
	VbID  uint16
	SeqNo gocbcore.SeqNo
}

type SnapshotMarker

type SnapshotMarker struct {
	StartSeqNo uint64
	EndSeqNo   uint64
}