client

Documentation

Index

• Variables
• type ClientManager
• type DefaultClientManager
  • func (manager *DefaultClientManager) DecoratorInvoke(path string, hystrixName string, tracer opentracing.Tracer, ...) (err error)
• type InvokerAfterFunc
• type InvokerBeforeFunc
• type OAuthClient
  • func NewOAuthClient(serviceName string, lb loadbalance.LoadBalance, tracer opentracing.Tracer) (OAuthClient, error)
• type OAuthClientImpl
  • func (impl *OAuthClientImpl) CheckToken(ctx context.Context, tracer opentracing.Tracer, request *pb.CheckTokenRequest) (*pb.CheckTokenResponse, error)
• type UserClient
  • func NewUserClient(serviceName string, lb loadbalance.LoadBalance, tracer opentracing.Tracer) (UserClient, error)
• type UserClientImpl
  • func (impl *UserClientImpl) CheckUser(ctx context.Context, tracer opentracing.Tracer, request *pb.UserRequest) (*pb.UserResponse, error)

Variables

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

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)