invocation

package

Go to main page

Versions in this module

v1

v1.4.3

Apr 28, 2026

v1.4.2

Apr 27, 2026

Changes in this version

+ const DefaultNamespace

+ type DNS struct

+ ClusterDomain string

+ Namespace string

+ Port uint16

+ Service string

+ ServiceType string

+ func (d *DNS) Build(service string) string

+ func (d *DNS) BuildAddress(service string) string

+ func (d *DNS) Normalize()

v1.4.1

Apr 26, 2026

Changes in this version

+ const DefaultInvokeTimeout

+ var ErrRemoteServiceNotFound = errors.New("remote service not found")

+ type RemoteServiceManaged struct

+ func NewRemoteServiceManaged(invoker *UnaryInvoker, services ...svc.DNS) *RemoteServiceManaged

+ func (r *RemoteServiceManaged) Caller(serviceName string) (*RemoteServiceCaller, error)

+ func (r *RemoteServiceManaged) DNS(serviceName string) (*svc.DNS, error)

+ func (r *RemoteServiceManaged) Invoke(ctx context.Context, serviceName string, method string, req any, resp any, ...) error

type UnaryInvoker

+ ServiceAppId string

+ ServiceInstanceId string

+ Timeout time.Duration

+ func NewUnaryInvoker(dialer Dialer, serviceAppId string, serviceInstanceId string, ...) *UnaryInvoker

v1.4.0

Apr 25, 2026

Changes in this version

+ func NewOutgoingCallContext(parent context.Context, md metadata.MD, timeout time.Duration) (context.Context, context.CancelFunc)

type InvokeOption

+ func WithMetadata(md metadata.MD) InvokeOption

+ func WithTimeout(timeout time.Duration) InvokeOption

type InvokeOptions

+ Metadata metadata.MD

+ Timeout time.Duration

v1.3.9

Apr 18, 2026

Changes in this version

type InvocationContext

+ func BuildInvocationContextFromContext(ctx context.Context) *InvocationContext

type RemoteServiceCaller

+ func NewRemoteServiceCaller(invoker *UnaryInvoker, service *ServiceDNS, buildContext ContextBuilder) *RemoteServiceCaller

v1.3.8

Apr 18, 2026

Changes in this version

+ type ContextBuilder func(context.Context) *InvocationContext

+ type RemoteServiceCaller struct

+ BuildContext ContextBuilder

+ Invoker *UnaryInvoker

+ Service *ServiceDNS

+ func (c *RemoteServiceCaller) Invoke(ctx context.Context, method string, req any, resp any, options ...InvokeOption) error

v1.3.7

Apr 18, 2026

Changes in this version

+ const DefaultServicePort

+ const DefaultServiceType

+ var ErrDNSManagerIsNil = errors.New("dns manager is nil")

type ConnectionManagerOptions

+ DNSManager *DNSManager

+ type DNSConfig struct

+ DefaultClusterDomain string

+ DefaultNamespace string

+ DefaultPort uint16

+ DefaultServiceType string

+ ResolverScheme string

+ type DNSManager struct

+ func NewDNSManager(config *DNSConfig) *DNSManager

+ func (m *DNSManager) Build(service *ServiceDNS) (*Target, error)

+ func (m *DNSManager) Config() *DNSConfig

+ func (m *DNSManager) Normalize(service *ServiceDNS) *ServiceDNS

+ type ServiceDNS struct

+ ClusterDomain string

+ Namespace string

+ Port uint16

+ Service string

+ ServiceType string

+ func (s ServiceDNS) ClusterDomainName() string

+ func (s ServiceDNS) EffectivePort(defaultPort uint16) (uint16, error)

+ func (s ServiceDNS) NamespaceName() string

+ func (s ServiceDNS) ServiceName() string

+ func (s ServiceDNS) ServiceTypeName() string

+ func (s ServiceDNS) Validate() error

+ func (s ServiceDNS) WithPort(port uint16) ServiceDNS

v1.3.6

Apr 14, 2026

v1.3.5

Apr 13, 2026

v1.3.4

Apr 12, 2026

Changes in this version

+ const MetaKeyParseErrorFormat

+ func ParseMetaKey(md metadata.MD, key string) (string, error)

+ func WithUserContext(ctx context.Context, meta *UserContextMeta) context.Context

type ServiceEndpoint

+ Kernel *ServiceEndpointKernel

+ Methods []string

+ ServiceMeta *ServiceEndpointMeta

+ type ServiceEndpointKernel struct

+ Language string

+ Version string

+ type ServiceEndpointMeta struct

+ AppId string

+ Env string

+ InstanceId string

+ Version string

+ type UserContextMeta struct

+ AppId string

+ ClientIp string

+ OrgIds []string

+ RoleIds []string

+ Session string

+ TenantId string

+ UserId string

+ func MustUserContextFromContext(ctx context.Context) *UserContextMeta

+ func ParseUserContextMeta(md metadata.MD) (raw *UserContextMeta, err error)

+ func UserContextFromContext(ctx context.Context) (*UserContextMeta, bool)

v1.3.3

Apr 11, 2026

v1.3.2

Apr 9, 2026

v1.3.1

Mar 28, 2026

Changes in this version

+ const DefaultClusterDomain

+ const DefaultResolverScheme

+ var ErrConnectionManagerClosed = errors.New("connection manager is closed")

+ var ErrDialFnIsNil = errors.New("dial function is nil")

+ var ErrInvokeMethodEmpty = errors.New("invoke method is empty")

+ var ErrInvokerDialerIsNil = errors.New("invoker dialer is nil")

+ var ErrLocatorIsNil = errors.New("locator is nil")

+ var ErrNamespaceEmpty = errors.New("namespace is empty")

+ var ErrServiceNameEmpty = errors.New("service name is empty")

+ var ErrTargetHostEmpty = errors.New("target host is empty")

+ var ErrTargetPortInvalid = errors.New("target port is invalid")

+ func DefaultDialFunc(_ context.Context, target Target, options []grpc.DialOption) (*grpc.ClientConn, error)

+ type Authorizer interface

+ Authorize func(ctx context.Context, input AuthzContext) error

+ type AuthzContext struct

+ Caller Caller

+ FullMethod string

+ Metadata metadata.MD

+ Service ServiceRef

+ TraceId string

+ func NewAuthzContext(ref ServiceRef, method string, invocation InvocationContext) AuthzContext

+ type Caller struct

+ AppId string

+ OrgIds []string

+ RoleIds []string

+ TenantId string

+ UserId string

+ type ConnectionManager struct

+ func NewConnectionManager(options ConnectionManagerOptions) (*ConnectionManager, error)

+ func (m *ConnectionManager) Close() error

+ func (m *ConnectionManager) Dial(ctx context.Context, ref ServiceRef) (*grpc.ClientConn, error)

+ type ConnectionManagerOptions struct

+ DialFunc DialFunc

+ DialOptions []grpc.DialOption

+ Locator Locator

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

+ type Dialer interface

+ Close func() error

+ Dial func(ctx context.Context, ref ServiceRef) (*grpc.ClientConn, error)

+ type InvocationContext struct

+ Caller Caller

+ Metadata metadata.MD

+ Timeout time.Duration

+ TraceId string

+ func (c InvocationContext) BuildMetadata() metadata.MD

+ func (c InvocationContext) Clone() InvocationContext

+ func (c InvocationContext) NewOutgoingContext(parent context.Context) (context.Context, context.CancelFunc)

+ type InvokeOption func(*InvokeOptions)

+ func WithCallOptions(callOptions ...grpc.CallOption) InvokeOption

+ func WithInvocationContext(invocation InvocationContext) InvokeOption

+ type InvokeOptions struct

+ CallOptions []grpc.CallOption

+ InvocationContext InvocationContext

+ type Invoker interface

+ Invoke func(ctx context.Context, ref ServiceRef, method string, req any, resp any, ...) error

+ type Locator interface

+ Resolve func(ctx context.Context, ref ServiceRef) (Target, error)

+ type ServiceEndpoint struct

+ Address string

+ Healthy bool

+ Meta map[string]string

+ Weight int

+ type ServiceRef struct

+ Env string

+ Namespace string

+ Port uint16

+ Service string

+ func (s ServiceRef) EffectivePort(defaultPort uint16) (uint16, error)

+ func (s ServiceRef) NamespaceName() string

+ func (s ServiceRef) ServiceName() string

+ func (s ServiceRef) Validate() error

+ func (s ServiceRef) WithPort(port uint16) ServiceRef

+ type StaticLocator struct

+ Options TargetOptions

+ func (s StaticLocator) Resolve(_ context.Context, ref ServiceRef) (Target, error)

+ type Target struct

+ Host string

+ Port uint16

+ ResolverScheme string

+ func BuildTarget(ref ServiceRef, options TargetOptions) (Target, error)

+ func (t Target) Address() string

+ func (t Target) GRPCTarget() string

+ func (t Target) Validate() error

+ type TargetOptions struct

+ ClusterDomain string

+ DefaultPort uint16

+ ResolverScheme string

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

+ type UnaryInvoker struct

+ Authorizer Authorizer

+ Dialer Dialer

+ InvokeFunc UnaryInvokeFunc

+ func (u *UnaryInvoker) Invoke(ctx context.Context, ref ServiceRef, method string, req any, resp any, ...) error

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