invocation

type Authorizer interface {
	Authorize(ctx context.Context, input *AuthzContext) error
}

type AuthzContext struct {
	// Service 表示目标业务服务的 DNS 身份。
	Service *ServiceDNS `json:"service"`
	// FullMethod 表示完整 gRPC 方法，例如 /acme.user.v1.UserService/GetUser。
	FullMethod string `json:"full_method"`
	// TraceID 表示链路 ID。
	TraceId string `json:"trace_id"`
	// Caller 表示调用方身份。
	Caller Caller `json:"caller"`
	// Metadata 表示构造判定时附带的完整 metadata 副本。
	Metadata metadata.MD `json:"-"`
}

type Caller struct {
	// UserId 表示当前用户身份，可为空。
	UserId string `json:"user_id"`
	// AppId 表示当前应用身份，可为空。
	AppId string `json:"app_id"`
	// TenantId 表示当前租户身份，可为空。
	TenantId string `json:"tenant_id"`
	// OrgIds 表示当前组织范围，可为空。
	OrgIds []string `json:"org_ids"`
	// RoleIds 表示当前角色范围，可为空。
	RoleIds []string `json:"role_ids"`
}

type ConnectionManager struct {
	// contains filtered or unexported fields
}

type ConnectionManagerOptions struct {
	// DNSManager 用于把业务服务 DNS 描述解析为最终 Target。
	DNSManager *DNSManager
	// DialFunc 用于创建新的 grpc.ClientConn。
	// 若为空，则使用默认拨号实现。
	DialFunc DialFunc
	// DialOptions 表示创建 grpc.ClientConn 时使用的附加选项。
	DialOptions []grpc.DialOption
}

type DNSConfig struct {
	// DefaultNamespace 表示默认命名空间。
	DefaultNamespace string
	// DefaultServiceType 表示默认服务类型片段。
	DefaultServiceType string
	// DefaultClusterDomain 表示默认集群域名。
	DefaultClusterDomain string
	// DefaultPort 表示默认端口。
	DefaultPort uint16
	// ResolverScheme 表示默认 gRPC resolver scheme。
	ResolverScheme string
}

type DNSManager struct {
	// contains filtered or unexported fields
}

type DialFunc func(ctx context.Context, target Target, options []grpc.DialOption) (*grpc.ClientConn, error)

type Dialer interface {
	Dial(ctx context.Context, service *ServiceDNS) (*grpc.ClientConn, error)
	Close() error
}

type InvocationContext struct {
	// TraceId 表示当前调用使用的链路 ID。
	TraceId string `json:"trace_id"`
	// Caller 表示调用者身份。
	Caller Caller `json:"caller"`
	// Metadata 表示调用方额外附带的 metadata。
	// 这里允许业务侧做补充，但核心库仍会统一注入标准字段。
	Metadata metadata.MD `json:"-"`
	// Timeout 表示本次调用的超时时间。
	Timeout time.Duration `json:"timeout"`
}

type InvokeOption func(*InvokeOptions)

type InvokeOptions struct {
	// InvocationContext 表示本次调用要附带的统一上下文。
	InvocationContext *InvocationContext
	// CallOptions 表示附加的 gRPC CallOption。
	CallOptions []grpc.CallOption
}

type Invoker interface {
	Invoke(ctx context.Context, service *ServiceDNS, method string, req any, resp any, options ...InvokeOption) error
}

type ServiceDNS struct {
	// Service 表示业务服务名，例如 auth。
	Service string `json:"service"`
	// Namespace 表示命名空间，例如 default。
	Namespace string `json:"namespace"`
	// ServiceType 表示服务类型片段，默认值为 svc。
	ServiceType string `json:"service_type"`
	// ClusterDomain 表示集群域，默认值为 cluster.local。
	ClusterDomain string `json:"cluster_domain"`
	// Port 表示业务服务监听端口，默认值为 9090。
	Port uint16 `json:"port"`
}

type Target struct {
	// ResolverScheme 表示 gRPC resolver scheme，例如 dns。
	ResolverScheme string `json:"resolver_scheme"`
	// Host 表示服务的标准主机名。
	Host string `json:"host"`
	// Port 表示服务端口。
	Port uint16 `json:"port"`
}

type UnaryInvokeFunc func(ctx context.Context, conn *grpc.ClientConn, method string, req any, resp any, options ...grpc.CallOption) error

type UnaryInvoker struct {
	// Dialer 负责连接获取与复用。
	Dialer Dialer
	// Authorizer 是可选依赖；若为空，则跳过 Authz 预检查。
	Authorizer Authorizer
	// InvokeFunc 是可选依赖；若为空，则默认调用 grpc.ClientConn.Invoke。
	InvokeFunc UnaryInvokeFunc
}

type UserContextMeta struct {
	Session  string `json:"session"`
	ClientIp string `json:"client_ip"`

	UserId   string `json:"user_id"`
	AppId    string `json:"app_id"`
	TenantId string `json:"tenant_id"`

	RoleIds []string `json:"role_ids"`
	OrgIds  []string `json:"org_ids"`
}