hello

package
v0.14.6 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthHello        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHello          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHello = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterHelloFlowHandler 

func RegisterHelloFlowHandler(s *flow.ClientStore, hdlr HelloFlowHandler)

func RegisterHelloServer 

func RegisterHelloServer(s *grpc.Server, srv HelloServer)

Types

type Echo 

type Echo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*Echo) Desc added in v0.9.2 

func (m *Echo) Desc() string

func (*Echo) Descriptor 

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

func (*Echo) GetEID added in v0.13.2 

func (m *Echo) GetEID() string

func (*Echo) Marshal 

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

func (*Echo) MarshalTo 

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

func (*Echo) MarshalToSizedBuffer 

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

func (*Echo) OwnerReferences 

func (m *Echo) OwnerReferences() []*api.OwnerReference

func (*Echo) ProtoMessage 

func (*Echo) ProtoMessage()

func (*Echo) Reset 

func (m *Echo) Reset()

func (*Echo) String 

func (m *Echo) String() string

func (*Echo) Unmarshal 

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

func (*Echo) XSize 

func (m *Echo) XSize() (n int)

func (*Echo) XXX_DiscardUnknown 

func (m *Echo) XXX_DiscardUnknown()

func (*Echo) XXX_Marshal 

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

func (*Echo) XXX_Merge 

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

func (*Echo) XXX_Size 

func (m *Echo) XXX_Size() int

func (*Echo) XXX_Unmarshal 

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

type EchoRequest 

type EchoRequest struct {
	Echo string `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"`
}

func (*EchoRequest) Descriptor 

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

func (*EchoRequest) Marshal 

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

func (*EchoRequest) MarshalTo 

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

func (*EchoRequest) MarshalToSizedBuffer 

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

func (*EchoRequest) ProtoMessage 

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) Reset 

func (m *EchoRequest) Reset()

func (*EchoRequest) String 

func (m *EchoRequest) String() string

func (*EchoRequest) Unmarshal 

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

func (*EchoRequest) XSize 

func (m *EchoRequest) XSize() (n int)

func (*EchoRequest) XXX_DiscardUnknown 

func (m *EchoRequest) XXX_DiscardUnknown()

func (*EchoRequest) XXX_Marshal 

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

func (*EchoRequest) XXX_Merge 

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

func (*EchoRequest) XXX_Size 

func (m *EchoRequest) XXX_Size() int

func (*EchoRequest) XXX_Unmarshal 

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

type EchoResponse 

type EchoResponse struct {
	Reply string `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"`
}

func (*EchoResponse) Descriptor 

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

func (*EchoResponse) Marshal 

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

func (*EchoResponse) MarshalTo 

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

func (*EchoResponse) MarshalToSizedBuffer 

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

func (*EchoResponse) ProtoMessage 

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) Reset 

func (m *EchoResponse) Reset()

func (*EchoResponse) String 

func (m *EchoResponse) String() string

func (*EchoResponse) Unmarshal 

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

func (*EchoResponse) XSize 

func (m *EchoResponse) XSize() (n int)

func (*EchoResponse) XXX_DiscardUnknown 

func (m *EchoResponse) XXX_DiscardUnknown()

func (*EchoResponse) XXX_Marshal 

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

func (*EchoResponse) XXX_Merge 

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

func (*EchoResponse) XXX_Size 

func (m *EchoResponse) XXX_Size() int

func (*EchoResponse) XXX_Unmarshal 

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

type HelloClient 

type HelloClient interface {
	// ping 请求
	Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

HelloClient is the client API for Hello service.

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

func NewHelloClient 

func NewHelloClient(cc *grpc.ClientConn) HelloClient

type HelloEcho 

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

func NewHelloEcho 

func NewHelloEcho(h HelloFlowHandler) *HelloEcho

func (*HelloEcho) Call 

func (p *HelloEcho) Call(ctx context.Context, data []byte) ([]byte, error)

func (*HelloEcho) Desc added in v0.9.2 

func (p *HelloEcho) Desc() string

func (*HelloEcho) Owner 

func (e *HelloEcho) Owner() reflect.Type

type HelloFlowClient 

type HelloFlowClient interface {
	// ping 请求
	Echo(ctx context.Context, in *EchoRequest, opts ...client.CallOption) (*EchoResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...client.CallOption) (*PingResponse, error)
}

Client API for Hello service +gen:entity=Echo

func NewHelloFlowClient 

func NewHelloFlowClient(target string, c *flow.Client) HelloFlowClient

HelloFlowClient for Echo

type HelloFlowHandler 

type HelloFlowHandler interface {
	// ping 请求
	Echo(context.Context, *EchoRequest, *EchoResponse) error
	Ping(context.Context, *PingRequest, *PingResponse) error
}

Server API for Hello service +gen:entity=Echo

type HelloPing 

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

func NewHelloPing 

func NewHelloPing(h HelloFlowHandler) *HelloPing

func (*HelloPing) Call 

func (p *HelloPing) Call(ctx context.Context, data []byte) ([]byte, error)

func (*HelloPing) Desc added in v0.9.2 

func (p *HelloPing) Desc() string

func (*HelloPing) Owner 

func (e *HelloPing) Owner() reflect.Type

type HelloServer 

type HelloServer interface {
	// ping 请求
	Echo(context.Context, *EchoRequest) (*EchoResponse, error)
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

HelloServer is the server API for Hello service.

type PingRequest 

type PingRequest struct {
}

func (*PingRequest) Descriptor 

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

func (*PingRequest) Marshal 

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

func (*PingRequest) MarshalTo 

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

func (*PingRequest) MarshalToSizedBuffer 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) Unmarshal 

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

func (*PingRequest) XSize 

func (m *PingRequest) XSize() (n int)

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

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

func (*PingRequest) XXX_Merge 

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

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

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

type PingResponse 

type PingResponse struct {
	Out string `protobuf:"bytes,1,opt,name=out,proto3" json:"out,omitempty"`
}

func (*PingResponse) Descriptor 

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

func (*PingResponse) Marshal 

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

func (*PingResponse) MarshalTo 

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

func (*PingResponse) MarshalToSizedBuffer 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) String 

func (m *PingResponse) String() string

func (*PingResponse) Unmarshal 

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

func (*PingResponse) XSize 

func (m *PingResponse) XSize() (n int)

func (*PingResponse) XXX_DiscardUnknown 

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal 

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

func (*PingResponse) XXX_Merge 

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

func (*PingResponse) XXX_Size 

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal 

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

type UnimplementedHelloServer 

type UnimplementedHelloServer struct {
}

UnimplementedHelloServer can be embedded to have forward compatible implementations.

func (*UnimplementedHelloServer) Echo 

func (*UnimplementedHelloServer) Echo(ctx context.Context, req *EchoRequest) (*EchoResponse, error)

func (*UnimplementedHelloServer) Ping 

func (*UnimplementedHelloServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, 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.