wrpc_go

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

type AppOption interface {
	// contains filtered or unexported methods
}

type AppOptionFunc func(app *App)

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

type ClientConfig struct {
	RequestTimeout time.Duration `yaml:"request-timeout"`
	ReadBufferSize int32         `yaml:"read-buffer-size"`
	Thread         int           `yaml:"thread"`
	MaxIdleTime    time.Duration `yaml:"max-idle-time"`
	EncodeType     string        `yaml:"encode-type"`
	ReTry          int           `yaml:"retry"`
}

type ClientOption func(opt *ClientOptions)

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

type Config struct {
	BaseDir        string                    `yaml:"base-dir"`
	LogDir         string                    `yaml:"log-dir"`
	DiscoverConfig *discovery.DiscoverConfig `yaml:"discover"`
	RegisterConfig *register.RegisterConfig  `yaml:"register"`
	ServerConfigs  []*ServerConfig           `yaml:"server-config"`
	ClientConfig   *ClientConfig             `yaml:"client-config"`
}

type Dispatcher func(ctx context.Context, impl interface{}, req *Request, enc Encoder) ([]byte, error)

type Encoder interface {
	Encode(v interface{}) ([]byte, error)
	Decode(bs []byte, addr interface{}) error
	Name() string
}

type HttpServer struct {
	*http.Server
	// contains filtered or unexported fields
}

type Meta map[string]string

type Protocol interface {
	PacketRequest(request *Request) ([]byte, error)
	UnPacketRequest(body []byte) (*Request, error)

	PacketResponse(response *Response) ([]byte, error)
	UnPacketResponse(body []byte) (*Response, error)

	Name() string
}

type Request struct {
	RequestId int64             `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Method    string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Meta      map[string]string `` /* 149-byte string literal not displayed */
	Body      []byte            `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {
	RequestId  int64             `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Meta       map[string]string `` /* 149-byte string literal not displayed */
	Body       []byte            `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Code       int32             `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	CodeStatus string            `protobuf:"bytes,5,opt,name=code_status,json=codeStatus,proto3" json:"code_status,omitempty"`
	// contains filtered or unexported fields
}

type Server interface {
	Start() error
	Stop(ctx context.Context) error
	Name() string
	Target() *register.Target
}

type ServerConfig struct {
	Name           string `yaml:"name"`
	IP             string `yaml:"ip"`
	Port           string `yaml:"port"`
	MaxInvoke      int32  `yaml:"max-invoke"`
	ReadBufferSize int32  `yaml:"read-buffer-size"`
}

type ServerOption func(opt *ServerOptions)

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

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