Documentation
¶
Index ¶
Constants ¶
View Source
const (
MetadataContentType = "gcs.contentType"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CDCIterator ¶
type CDCIterator struct {
// contains filtered or unexported fields
}
CDCIterator scans the bucket periodically and detects changes made to it.
func NewCDCIterator ¶
func NewCDCIterator(ctx context.Context, bucket string, pollingPeriod time.Duration, client *storage.Client, from time.Time, fromKey string) (*CDCIterator, error)
NewCDCIterator returns a CDCIterator and starts the process of listening to changes every pollingPeriod.
func (*CDCIterator) Stop ¶
func (w *CDCIterator) Stop(ctx context.Context)
type CacheEntry ¶
type CacheEntry struct {
// contains filtered or unexported fields
}
type CombinedIterator ¶
type CombinedIterator struct {
// contains filtered or unexported fields
}
func NewCombinedIterator ¶
func (*CombinedIterator) Stop ¶
func (c *CombinedIterator) Stop(ctx context.Context)
type SnapshotIterator ¶
type SnapshotIterator struct {
// contains filtered or unexported fields
}
SnapshotIterator to iterate through GoogleCloudStorage objects in a specific bucket.
func NewSnapshotIterator ¶
func NewSnapshotIterator(ctx context.Context, bucket string, client *storage.Client, p position.Position) (*SnapshotIterator, error)
NewSnapshotIterator takes the GoogleCloudStorage bucket, the client, and the position. it returns a snapshotIterator starting from the position provided.
func (*SnapshotIterator) Next ¶
Next returns the next record in the iterator. returns an empty record and an error if anything wrong happened.
func (*SnapshotIterator) Stop ¶
func (s *SnapshotIterator) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.