client

package
v0.0.0-...-2816995 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 21, 2022 License: MIT Imports: 15 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrRPCService = errors.New("no rpc service")
)

Functions

This section is empty.

Types

type ClientManager

type ClientManager interface {
	DecoratorInvoke(path string, hystrixName string, tracer opentracing.Tracer,
		ctx context.Context, inputVal interface{}, outVal interface{}) (err error)
}

type DefaultClientManager

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

func (*DefaultClientManager) DecoratorInvoke

func (manager *DefaultClientManager) DecoratorInvoke(path string, hystrixName string,
	tracer opentracing.Tracer, ctx context.Context, inputVal interface{}, outVal interface{}) (err error)

type InvokerAfterFunc

type InvokerAfterFunc func() (err error)

type InvokerBeforeFunc

type InvokerBeforeFunc func() (err error)

type OAuthClient

type OAuthClient interface {
	CheckToken(ctx context.Context, tracer opentracing.Tracer, request *pb.CheckTokenRequest) (*pb.CheckTokenResponse, error)
}

func NewOAuthClient

func NewOAuthClient(serviceName string, lb loadbalance.LoadBalance, tracer opentracing.Tracer) (OAuthClient, error)

type OAuthClientImpl

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

func (*OAuthClientImpl) CheckToken

func (impl *OAuthClientImpl) CheckToken(ctx context.Context, tracer opentracing.Tracer, request *pb.CheckTokenRequest) (*pb.CheckTokenResponse, error)

type UserClient

type UserClient interface {
	CheckUser(ctx context.Context, tracer opentracing.Tracer, request *pb.UserRequest) (*pb.UserResponse, error)
}

func NewUserClient

func NewUserClient(serviceName string, lb loadbalance.LoadBalance, tracer opentracing.Tracer) (UserClient, error)

type UserClientImpl

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

func (*UserClientImpl) CheckUser

func (impl *UserClientImpl) CheckUser(ctx context.Context, tracer opentracing.Tracer, request *pb.UserRequest) (*pb.UserResponse, error)

Jump to

Keyboard shortcuts

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