client

Documentation

Index

• type BaseClient
  • func (b *BaseClient) Call(ctx *light.Context, serviceMethod string, request interface{}, ...) (err error)
  • func (b *BaseClient) Error() error
• type Client
  • func NewClient(discover discovery.Discovery, options ...Option) *Client
  • func (c *Client) NewConnect(serverName string) (conn *Connect, err error)
• type Connect
  • func (c *Connect) Call(ctx *light.Context, serviceMethod string, request interface{}, ...) error
  • func (c *Connect) Close()
• type LightClient
• type Option
  • func SetAUTH(token string) Option
  • func SetCompressor(compressor codes.CompressorType) Option
  • func SetHeartBeat(heartBeat time.Duration) Option
  • func SetLoadBalancing(lb load_banlancing.LoadBalancing) Option
  • func SetPoolSize(p int) Option
  • func SetRASPublicKey(key []byte) Option
  • func SetSerialization(serialization codes.SerializationType) Option
  • func SetTimeOut(writeTimeout time.Duration, readTimeout time.Duration) Option
  • func Trance() Option
• type Options
• type Payload

Types

type BaseClient

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

func (*BaseClient) Call

func (b *BaseClient) Call(ctx *light.Context, serviceMethod string, request interface{}, response interface{}) (err error)

func (*BaseClient) Error

func (b *BaseClient) Error() error

type Client

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

func NewClient

func NewClient(discover discovery.Discovery, options ...Option) *Client

func (*Client) NewConnect

func (c *Client) NewConnect(serverName string) (conn *Connect, err error)

type Connect

type Connect struct {
	Client *Client
	// contains filtered or unexported fields
}

func (*Connect) Call

func (c *Connect) Call(ctx *light.Context, serviceMethod string, request interface{}, response interface{}) error

func (*Connect) Close

func (c *Connect) Close()

type LightClient

type LightClient interface {
	Call(ctx *light.Context, serviceMethod string, request interface{}, response interface{}) error
	Error() error
}

type Option

type Option func(options *Options)

func SetAUTH

func SetAUTH(token string) Option

func SetCompressor

func SetCompressor(compressor codes.CompressorType) Option

func SetHeartBeat

func SetHeartBeat(heartBeat time.Duration) Option

func SetLoadBalancing

func SetLoadBalancing(lb load_banlancing.LoadBalancing) Option

func SetPoolSize

func SetPoolSize(p int) Option

func SetRASPublicKey

func SetRASPublicKey(key []byte) Option

func SetSerialization

func SetSerialization(serialization codes.SerializationType) Option

func SetTimeOut

func SetTimeOut(writeTimeout time.Duration, readTimeout time.Duration) Option

func Trance

func Trance() Option

type Options

type Options struct {
	Discovery discovery.Discovery

	Trace bool
	AUTH  string
	// contains filtered or unexported fields
}

type Payload

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