Π·Π΅ΡΠΊΠ°Π»ΠΎ ΠΈΠ· https://github.com/Azure/azure-event-hubs-go.git
π¨ Use a string formatter to build the blob path
This commit is contained in:
Π ΠΎΠ΄ΠΈΡΠ΅Π»Ρ
aa1be2f753
ΠΠΎΠΌΠΌΠΈΡ
28dc0b0703
|
@ -29,6 +29,7 @@ import (
|
||||||
"context"
|
"context"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net/url"
|
"net/url"
|
||||||
"sync"
|
"sync"
|
||||||
|
@ -683,7 +684,7 @@ func startConsumerSpanFromContext(ctx context.Context, operationName string) (ta
|
||||||
// WithEventhubInfoInBlobPath configures the LeaserCheckpointerOption with a blob path
|
// WithEventhubInfoInBlobPath configures the LeaserCheckpointerOption with a blob path
|
||||||
func WithEventhubInfoInBlobPath(ehInfo *conn.ParsedConn, consumerGroup string) LeaserCheckpointerOption {
|
func WithEventhubInfoInBlobPath(ehInfo *conn.ParsedConn, consumerGroup string) LeaserCheckpointerOption {
|
||||||
return func(ls *LeaserCheckpointer) error {
|
return func(ls *LeaserCheckpointer) error {
|
||||||
ls.blobPathPrefix = ehInfo.Namespace + "." + ehInfo.Suffix + "/" + ehInfo.HubName + "/" + consumerGroup + "/"
|
ls.blobPathPrefix = fmt.Sprintf("%s.%s/%s/%s/", ehInfo.Namespace, ehInfo.Suffix, ehInfo.HubName, consumerGroup)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
ΠΠ°Π³ΡΡΠ·ΠΊΠ°β¦
Π‘ΡΡΠ»ΠΊΠ° Π² Π½ΠΎΠ²ΠΎΠΉ Π·Π°Π΄Π°ΡΠ΅