context

package

v0.0.5-alpha Latest Latest Go to latest Published: Mar 29, 2024 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/azure/peerd

Links

Open Source Insights

Documentation ¶

Overview ¶

Copyright (c) Microsoft Corporation. Licensed under the MIT License.

Index ¶

Constants
Variables
func BlobUrl(c *gin.Context) string
func FillCorrelationId(c *gin.Context)
func IsRequestFromAPeer(c *gin.Context) bool
func Logger(c *gin.Context) zerolog.Logger
func Merge[T any](cs ...<-chan T) <-chan T
func RangeStartIndex(rangeValue string) (int64, error)
func SetOutboundHeaders(r *http.Request, c *gin.Context)

Constants ¶

View Source

const (
	P2pLookupCacheTtl      = 500 * time.Millisecond
	P2pLookupNotFoundValue = "PEER_NOT_FOUND"
)

Cache constants.

View Source

const (
	CorrelationIdCtxKey = "correlation_id"
	DigestCtxKey        = "digest"
	FileChunkCtxKey     = "file_chunk"
	BlobUrlCtxKey       = "blob_url"
	BlobRangeCtxKey     = "blob_range"
	NamespaceCtxKey     = "namespace"
	ReferenceCtxKey     = "reference"
	RefTypeCtxKey       = "ref_type"
	LoggerCtxKey        = "logger"
)

Context keys.

View Source

const (
	P2PHeaderKey         = "X-MS-Cluster-P2P-RequestFromPeer"
	CorrelationHeaderKey = "X-MS-Cluster-P2P-CorrelationId"
	NodeHeaderKey        = "X-MS-Cluster-P2P-Node"
)

Request headers.

View Source

const (
	PeerResolutionStartLog     = "peer resolution start"
	PeerResolutionStopLog      = "peer resolution stop"
	PeerNotFoundLog            = "peer not found"
	PeerResolutionExhaustedLog = "peer resolution exhausted"
	PeerRequestErrorLog        = "peer request error"
)

Log messages.

View Source

const (
	KeyTTL = 30 * time.Minute
)

P2P network.

Variables ¶

View Source

var (
	NodeName, _ = os.Hostname()
	Namespace   = "peerd-ns"

	// KubeConfigPath is the path of the kubeconfig file.
	KubeConfigPath = "/opt/peerd/kubeconfig"
)

Functions ¶

func BlobUrl ¶

func BlobUrl(c *gin.Context) string

BlobUrl extracts the blob URL from the incoming request URL.

func FillCorrelationId ¶

func FillCorrelationId(c *gin.Context)

func IsRequestFromAPeer ¶

func IsRequestFromAPeer(c *gin.Context) bool

IsRequestFromAPeer indicates if the current request is from a peer.

func Logger ¶

func Logger(c *gin.Context) zerolog.Logger

Logger gets the logger with request specific fields.

func Merge ¶

func Merge[T any](cs ...<-chan T) <-chan T

Merge merges multiple input channels into a single output channel. It starts a goroutine for each input channel and sends the values from each input channel to the output channel. Once all input channels are closed, it closes the output channel. The function returns the output channel.

func RangeStartIndex ¶

func RangeStartIndex(rangeValue string) (int64, error)

RangeStartIndex returns the start index of a byte range specified in the given range header value. It expects the range value to be in the format "bytes=startIndex-endIndex".

func SetOutboundHeaders ¶

func SetOutboundHeaders(r *http.Request, c *gin.Context)

SetOutboundHeaders sets the mandatory headers for all outbound requests.

Types ¶

This section is empty.

Source Files ¶

View all Source files

context.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL