proto

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jun 1, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const ServiceNameOfUser = "UserRpc"

Variables

View Source
var (
	ErrInvalidLengthUser        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUser          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUser = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type GetInfoReply

type GetInfoReply struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetInfoReply) Descriptor

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

func (*GetInfoReply) GetName

func (m *GetInfoReply) GetName() string

func (*GetInfoReply) Marshal

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

func (*GetInfoReply) MarshalTo

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

func (*GetInfoReply) MarshalToSizedBuffer

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

func (*GetInfoReply) ProtoMessage

func (*GetInfoReply) ProtoMessage()

func (*GetInfoReply) Reset

func (m *GetInfoReply) Reset()

func (*GetInfoReply) Size

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

func (*GetInfoReply) String

func (m *GetInfoReply) String() string

func (*GetInfoReply) Unmarshal

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

func (*GetInfoReply) XXX_DiscardUnknown

func (m *GetInfoReply) XXX_DiscardUnknown()

func (*GetInfoReply) XXX_Marshal

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

func (*GetInfoReply) XXX_Merge

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

func (*GetInfoReply) XXX_Size

func (m *GetInfoReply) XXX_Size() int

func (*GetInfoReply) XXX_Unmarshal

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

type GetInfoReq

type GetInfoReq struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetInfoReq) Descriptor

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

func (*GetInfoReq) GetId

func (m *GetInfoReq) GetId() uint64

func (*GetInfoReq) Marshal

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

func (*GetInfoReq) MarshalTo

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

func (*GetInfoReq) MarshalToSizedBuffer

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

func (*GetInfoReq) ProtoMessage

func (*GetInfoReq) ProtoMessage()

func (*GetInfoReq) Reset

func (m *GetInfoReq) Reset()

func (*GetInfoReq) Size

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

======================================================

func (*GetInfoReq) String

func (m *GetInfoReq) String() string

func (*GetInfoReq) Unmarshal

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

func (*GetInfoReq) XXX_DiscardUnknown

func (m *GetInfoReq) XXX_DiscardUnknown()

func (*GetInfoReq) XXX_Marshal

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

func (*GetInfoReq) XXX_Merge

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

func (*GetInfoReq) XXX_Size

func (m *GetInfoReq) XXX_Size() int

func (*GetInfoReq) XXX_Unmarshal

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

type SayHelloReply added in v1.0.0

type SayHelloReply struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SayHelloReply) Descriptor added in v1.0.0

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

func (*SayHelloReply) GetName added in v1.0.0

func (m *SayHelloReply) GetName() string

func (*SayHelloReply) Marshal added in v1.0.0

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

func (*SayHelloReply) MarshalTo added in v1.0.0

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

func (*SayHelloReply) MarshalToSizedBuffer added in v1.0.0

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

func (*SayHelloReply) ProtoMessage added in v1.0.0

func (*SayHelloReply) ProtoMessage()

func (*SayHelloReply) Reset added in v1.0.0

func (m *SayHelloReply) Reset()

func (*SayHelloReply) Size added in v1.0.0

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

func (*SayHelloReply) String added in v1.0.0

func (m *SayHelloReply) String() string

func (*SayHelloReply) Unmarshal added in v1.0.0

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

func (*SayHelloReply) XXX_DiscardUnknown added in v1.0.0

func (m *SayHelloReply) XXX_DiscardUnknown()

func (*SayHelloReply) XXX_Marshal added in v1.0.0

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

func (*SayHelloReply) XXX_Merge added in v1.0.0

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

func (*SayHelloReply) XXX_Size added in v1.0.0

func (m *SayHelloReply) XXX_Size() int

func (*SayHelloReply) XXX_Unmarshal added in v1.0.0

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

type SayHelloReq added in v1.0.0

type SayHelloReq struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SayHelloReq) Descriptor added in v1.0.0

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

func (*SayHelloReq) GetId added in v1.0.0

func (m *SayHelloReq) GetId() uint64

func (*SayHelloReq) Marshal added in v1.0.0

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

func (*SayHelloReq) MarshalTo added in v1.0.0

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

func (*SayHelloReq) MarshalToSizedBuffer added in v1.0.0

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

func (*SayHelloReq) ProtoMessage added in v1.0.0

func (*SayHelloReq) ProtoMessage()

func (*SayHelloReq) Reset added in v1.0.0

func (m *SayHelloReq) Reset()

func (*SayHelloReq) Size added in v1.0.0

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

func (*SayHelloReq) String added in v1.0.0

func (m *SayHelloReq) String() string

func (*SayHelloReq) Unmarshal added in v1.0.0

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

func (*SayHelloReq) XXX_DiscardUnknown added in v1.0.0

func (m *SayHelloReq) XXX_DiscardUnknown()

func (*SayHelloReq) XXX_Marshal added in v1.0.0

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

func (*SayHelloReq) XXX_Merge added in v1.0.0

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

func (*SayHelloReq) XXX_Size added in v1.0.0

func (m *SayHelloReq) XXX_Size() int

func (*SayHelloReq) XXX_Unmarshal added in v1.0.0

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

type UserClient

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

User is a client wrapped XClient.

func NewUserClient

func NewUserClient(group, cluster string) *UserClient

NewUserClient wraps a XClient as UserClient. You can pass a shared XClient object created by NewXClientForUser.

func (*UserClient) GetInfo

func (c *UserClient) GetInfo(ctx context.Context, req *GetInfoReq) (reply *GetInfoReply, err error)

GetInfo is client rpc method as defined

func (*UserClient) SayHello added in v1.0.0

func (c *UserClient) SayHello(ctx context.Context, req *SayHelloReq) (reply *SayHelloReply, err error)

SayHello is client rpc method as defined

type UserInterface

type UserInterface interface {

	// UserInterface can be used for interface verification.
	// GetInfo is server rpc method as defined
	GetInfo(ctx context.Context, req *GetInfoReq, reply *GetInfoReply) (err error)

	// SayHello is server rpc method as defined
	SayHello(ctx context.Context, req *SayHelloReq, reply *SayHelloReply) (err error)
}

================== interface ===================

type UserRpcDemo

type UserRpcDemo struct{}

================== server implement demo =================== ripple.Default().RegisterRpc("User", &UserRpcDemo{}, "")

func (*UserRpcDemo) GetInfo

func (this *UserRpcDemo) GetInfo(ctx context.Context, req *GetInfoReq, reply *GetInfoReply) (err error)

func (*UserRpcDemo) SayHello added in v1.0.0

func (this *UserRpcDemo) SayHello(ctx context.Context, req *SayHelloReq, reply *SayHelloReply) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL