Files
tasks/common/rpc/context.go
Alex ShtinandGitHub 8e8f1b0f7c Remove license header from every file (#7689)
## What changed?
<!-- Describe what has changed in this PR -->
Remove license header from every file. Because it is really hard to
follow in this PR here is the summary:
1. License header is removed from all `.go` and `.proto` files
:fireworks::fireworks:🎆.
2. `LICENSE` file in the root directory has only Temporal and Uber
copyrights.
3. 5 other `LICENSE` files added to the packages which have copyrights
different from Temporal and Uber: Datadog, Xargin, "Mat Ryer, Tyler
Bunnell and contributors".
4. `license_file` flag is removed from all code generation tools.
5. `copyright_file` flag is removed from `go:generate mockgen`
directive.
6. All copyright related targets are removed from `Makefile`.
7. Updated Temporal copyright year to 2025 everywhere.

## Why?
<!-- Tell your future self why have you made these changes -->
I double checked with legal department that it is not needed to have
license header in every file. One file per repo is enough. I put all
copyrights to the root `LICENSE` file and removed header from all other
files. Also updated tools and `Makefile`.
2025-05-01 18:50:21 -07:00

49 lines
1.5 KiB
Go

package rpc
import (
"context"
"time"
"go.temporal.io/server/common/headers"
)
type (
valueCopyCtx struct {
context.Context
valueCtx context.Context
}
)
func (c *valueCopyCtx) Value(key any) any {
if value := c.Context.Value(key); value != nil {
return value
}
return c.valueCtx.Value(key)
}
// CopyContextValues copies values in source Context to destination Context.
func CopyContextValues(dst context.Context, src context.Context) context.Context {
return &valueCopyCtx{
Context: dst,
valueCtx: src,
}
}
// ResetContextTimeout creates new context with specified timeout and copies values from source Context.
func ResetContextTimeout(ctx context.Context, newTimeout time.Duration) (context.Context, context.CancelFunc) {
newContext, cancel := context.WithTimeout(context.Background(), newTimeout)
return CopyContextValues(newContext, ctx), cancel
}
// NewContextWithTimeoutAndVersionHeaders creates context with timeout and version headers.
func NewContextWithTimeoutAndVersionHeaders(timeout time.Duration) (context.Context, context.CancelFunc) {
return context.WithTimeout(headers.SetVersions(context.Background()), timeout)
}
// NewContextFromParentWithTimeoutAndVersionHeaders creates context from parent context with timeout and version headers.
func NewContextFromParentWithTimeoutAndVersionHeaders(parentCtx context.Context, timeout time.Duration) (context.Context, context.CancelFunc) {
return context.WithTimeout(headers.SetVersions(parentCtx), timeout)
}