rpc

package

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

Details

Package rpc propagates tenant metadata through framework-neutral carriers.

包 rpc 通过与框架无关的载体传播租户元数据。

View Source

const DefaultTenantMetadataKey = "x-tenant-id"

View Source

var (
	ErrNoTenantMetadata = errors.New("saas/rpc: no tenant metadata")
	ErrInvalidCarrier   = errors.New("saas/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.

Path	Synopsis
mq Package mq provides SDK-free adapters for propagating SaaS tenant metadata through NATS, RabbitMQ, and Kafka message headers.	Package mq provides SDK-free adapters for propagating SaaS tenant metadata through NATS, RabbitMQ, and Kafka message headers.