stream

type IManager interface {
	CreateNewStream(server metrov1.Subscriber_StreamingPullServer, req *ParsedStreamingPullRequest, errGroup *errgroup.Group, ch cache.ICache) error
	Acknowledge(ctx context.Context, parsedReq *ParsedStreamingPullRequest) error
	ModifyAcknowledgement(ctx context.Context, req *ParsedStreamingPullRequest) error
}

type IStream interface {
	// contains filtered or unexported methods
}

type Manager struct {
	// contains filtered or unexported fields
}

type ParsedStreamingPullRequest struct {
	ClientID                     string
	Subscription                 string
	AckIDs                       []string
	ModAckIDs                    []string
	AckMessages                  []*subscriber.AckMessage
	ModAckMessages               []*subscriber.AckMessage
	ModifyDeadlineMsgIdsWithSecs map[string]int32
}