harvester

type Client struct {
	Cfg    *Config
	Client api.Client
	URL    string
	// contains filtered or unexported fields
}

type Config struct {
	ClientTimeout    time.Duration
	Host             string
	PageSize         int
	Port             uint32
	Protocol         string
	ProxyURL         string
	SequenceProvider events.SequenceProvider
	TenantID         string
	TLSCfg           *tls.Config
	TokenGetter      func() (string, error)
	// contains filtered or unexported fields
}

type ErrSeqGone struct {
}

type Harvest interface {
	EventCatchUp(ctx context.Context, link string, events chan *proto.Event) error
	ReceiveSyncEvents(ctx context.Context, topicSelfLink string, sequenceID int64, eventCh chan *proto.Event) (int64, error)
}