example

Documentation

Overview

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.

Index

• Constants
• type ClientExampleRPC
  • func (cli *ClientExampleRPC) ReqTest(ctx context.Context, callback retExampleRPCTest, arg0 int, arg1 string, ...) (request RequestRPC)
  • func (cli *ClientExampleRPC) ReqTest2(ctx context.Context, callback retExampleRPCTest2, arg0 int, arg1 string, ...) (request RequestRPC)
  • func (cli *ClientExampleRPC) Test(ctx context.Context, arg0 int, arg1 string, opts ...interface{}) (ret1 int, ret2 string, err error)
  • func (cli *ClientExampleRPC) Test2(ctx context.Context, arg0 int, arg1 string, opts ...interface{}) (ret1 int, ret2 string, err error)
• type ClientJsonRPC
  • func New(endpoint string, opts ...Option) (cli *ClientJsonRPC)
  • func (cli *ClientJsonRPC) Batch(ctx context.Context, requests ...RequestRPC)
  • func (cli *ClientJsonRPC) ExampleRPC() *ClientExampleRPC
• type ErrorDecoder
• type Option
  • func Cache(cache cache) Option
  • func CircuitBreaker(cfg cb.Settings) Option
  • func DecodeError(decoder ErrorDecoder) Option
  • func FallbackExampleRPCErr(fallback fallbackExampleRPC) Option
  • func FallbackTTL(ttl time.Duration) Option
  • func Headers(headers ...interface{}) Option
  • func Insecure() Option
  • func LogOnError() Option
  • func LogRequest() Option
• type RequestRPC

Constants

const VersionTg = "v2.3.29"

Types

type ClientExampleRPC

type ClientExampleRPC struct {
	*ClientJsonRPC
}

func (*ClientExampleRPC) ReqTest

func (cli *ClientExampleRPC) ReqTest(ctx context.Context, callback retExampleRPCTest, arg0 int, arg1 string, opts ...interface{}) (request RequestRPC)

func (*ClientExampleRPC) ReqTest2

func (cli *ClientExampleRPC) ReqTest2(ctx context.Context, callback retExampleRPCTest2, arg0 int, arg1 string, opts ...interface{}) (request RequestRPC)

func (*ClientExampleRPC) Test

func (cli *ClientExampleRPC) Test(ctx context.Context, arg0 int, arg1 string, opts ...interface{}) (ret1 int, ret2 string, err error)

func (*ClientExampleRPC) Test2

func (cli *ClientExampleRPC) Test2(ctx context.Context, arg0 int, arg1 string, opts ...interface{}) (ret1 int, ret2 string, err error)

type ClientJsonRPC

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

func New

func New(endpoint string, opts ...Option) (cli *ClientJsonRPC)

func (*ClientJsonRPC) Batch

func (cli *ClientJsonRPC) Batch(ctx context.Context, requests ...RequestRPC)

func (*ClientJsonRPC) ExampleRPC

func (cli *ClientJsonRPC) ExampleRPC() *ClientExampleRPC

type ErrorDecoder

type ErrorDecoder func(errData json.RawMessage) error

type Option

type Option func(cli *ClientJsonRPC)

func Cache

func Cache(cache cache) Option

func CircuitBreaker

func CircuitBreaker(cfg cb.Settings) Option

func DecodeError

func DecodeError(decoder ErrorDecoder) Option

func FallbackExampleRPCErr

func FallbackExampleRPCErr(fallback fallbackExampleRPC) Option

func FallbackTTL

func FallbackTTL(ttl time.Duration) Option

func Headers

func Headers(headers ...interface{}) Option

func Insecure

func Insecure() Option

func LogOnError

func LogOnError() Option

func LogRequest

func LogRequest() Option

type RequestRPC

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