proto

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRoute        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRoute          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRoute = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterListenServer 

func RegisterListenServer(s *grpc.Server, srv ListenServer)

Types 

type Header struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val string `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
}

func (*Header) Descriptor 

func (*Header) Descriptor() ([]byte, []int)

func (*Header) GetKey 

func (m *Header) GetKey() string

func (*Header) GetVal 

func (m *Header) GetVal() string

func (*Header) Marshal 

func (m *Header) Marshal() (dAtA []byte, err error)

func (*Header) MarshalTo 

func (m *Header) MarshalTo(dAtA []byte) (int, error)

func (*Header) MarshalToSizedBuffer 

func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

func (m *Header) Size() (n int)

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Header) XXX_Merge 

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

func (m *Header) XXX_Unmarshal(b []byte) error

type ListenClient 

type ListenClient interface {
	Routing(ctx context.Context, in *RouteReq, opts ...grpc.CallOption) (*RouteRes, error)
}

ListenClient is the client API for Listen service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewListenClient 

func NewListenClient(cc *grpc.ClientConn) ListenClient

type ListenServer 

type ListenServer interface {
	Routing(context.Context, *RouteReq) (*RouteRes, error)
}

ListenServer is the server API for Listen service.

type RouteReq 

type RouteReq struct {
	// nod 目标服务节点名
	Nod string `protobuf:"bytes,1,opt,name=nod,proto3" json:"nod,omitempty"`
	// service 功能函数名
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Token   string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// body
	ReqBody []byte `protobuf:"bytes,4,opt,name=reqBody,proto3" json:"reqBody,omitempty"`
	// meta 元数据用于用户定制开发
	Meta []*Header `protobuf:"bytes,5,rep,name=meta,proto3" json:"meta,omitempty"`
}

func (*RouteReq) Descriptor 

func (*RouteReq) Descriptor() ([]byte, []int)

func (*RouteReq) GetMeta 

func (m *RouteReq) GetMeta() []*Header

func (*RouteReq) GetNod 

func (m *RouteReq) GetNod() string

func (*RouteReq) GetReqBody 

func (m *RouteReq) GetReqBody() []byte

func (*RouteReq) GetService 

func (m *RouteReq) GetService() string

func (*RouteReq) GetToken 

func (m *RouteReq) GetToken() string

func (*RouteReq) Marshal 

func (m *RouteReq) Marshal() (dAtA []byte, err error)

func (*RouteReq) MarshalTo 

func (m *RouteReq) MarshalTo(dAtA []byte) (int, error)

func (*RouteReq) MarshalToSizedBuffer 

func (m *RouteReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RouteReq) ProtoMessage 

func (*RouteReq) ProtoMessage()

func (*RouteReq) Reset 

func (m *RouteReq) Reset()

func (*RouteReq) Size 

func (m *RouteReq) Size() (n int)

func (*RouteReq) String 

func (m *RouteReq) String() string

func (*RouteReq) Unmarshal 

func (m *RouteReq) Unmarshal(dAtA []byte) error

func (*RouteReq) XXX_DiscardUnknown 

func (m *RouteReq) XXX_DiscardUnknown()

func (*RouteReq) XXX_Marshal 

func (m *RouteReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RouteReq) XXX_Merge 

func (m *RouteReq) XXX_Merge(src proto.Message)

func (*RouteReq) XXX_Size 

func (m *RouteReq) XXX_Size() int

func (*RouteReq) XXX_Unmarshal 

func (m *RouteReq) XXX_Unmarshal(b []byte) error

type RouteRes 

type RouteRes struct {
	ResBody []byte `protobuf:"bytes,1,opt,name=resBody,proto3" json:"resBody,omitempty"`
}

func (*RouteRes) Descriptor 

func (*RouteRes) Descriptor() ([]byte, []int)

func (*RouteRes) GetResBody 

func (m *RouteRes) GetResBody() []byte

func (*RouteRes) Marshal 

func (m *RouteRes) Marshal() (dAtA []byte, err error)

func (*RouteRes) MarshalTo 

func (m *RouteRes) MarshalTo(dAtA []byte) (int, error)

func (*RouteRes) MarshalToSizedBuffer 

func (m *RouteRes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RouteRes) ProtoMessage 

func (*RouteRes) ProtoMessage()

func (*RouteRes) Reset 

func (m *RouteRes) Reset()

func (*RouteRes) Size 

func (m *RouteRes) Size() (n int)

func (*RouteRes) String 

func (m *RouteRes) String() string

func (*RouteRes) Unmarshal 

func (m *RouteRes) Unmarshal(dAtA []byte) error

func (*RouteRes) XXX_DiscardUnknown 

func (m *RouteRes) XXX_DiscardUnknown()

func (*RouteRes) XXX_Marshal 

func (m *RouteRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RouteRes) XXX_Merge 

func (m *RouteRes) XXX_Merge(src proto.Message)

func (*RouteRes) XXX_Size 

func (m *RouteRes) XXX_Size() int

func (*RouteRes) XXX_Unmarshal 

func (m *RouteRes) XXX_Unmarshal(b []byte) error

type UnimplementedListenServer 

type UnimplementedListenServer struct {
}

UnimplementedListenServer can be embedded to have forward compatible implementations.

func (*UnimplementedListenServer) Routing 

func (*UnimplementedListenServer) Routing(ctx context.Context, req *RouteReq) (*RouteRes, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.