rpc

package

v0.1.3 Latest Latest Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Package rpc propagates tenant metadata through framework-neutral carriers.

View Source

const DefaultTenantMetadataKey = "x-tenant-id"

View Source

var (
	ErrNoTenantMetadata = errors.New("gotenancy/rpc: no tenant metadata")
	ErrInvalidCarrier   = errors.New("gotenancy/rpc: invalid carrier")
)

func ExtractTenant(carrier Carrier, key string, strategy types.TenantIDStrategy) (types.TenantID, error)

ExtractTenant reads tenant metadata from carrier.

func InjectTenant(ctx context.Context, carrier Carrier, key string) error

InjectTenant writes tenant metadata from ctx into carrier.

type Carrier interface {
	Get(key string) (string, bool)
	Set(key string, value string)
}

Carrier stores RPC metadata.

type MapCarrier map[string]string

MapCarrier is an in-memory metadata carrier.

func (carrier MapCarrier) Get(key string) (string, bool)

Get returns metadata by key.

func (carrier MapCarrier) Set(key string, value string)

Set stores metadata by key.