edge

package
v0.2.1 Latest Latest
Warning

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

Go to latest
Published: Mar 8, 2024 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_proto_edge_forward_proto protoreflect.FileDescriptor

Functions

func RegisterForwardServiceServer

func RegisterForwardServiceServer(s *grpc.Server, srv ForwardServiceServer)

Types

type ForwardPayload

type ForwardPayload struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardPayload) Descriptor deprecated

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

Deprecated: Use ForwardPayload.ProtoReflect.Descriptor instead.

func (*ForwardPayload) GetPayload

func (x *ForwardPayload) GetPayload() []byte

func (*ForwardPayload) ProtoMessage

func (*ForwardPayload) ProtoMessage()

func (*ForwardPayload) ProtoReflect

func (x *ForwardPayload) ProtoReflect() protoreflect.Message

func (*ForwardPayload) Reset

func (x *ForwardPayload) Reset()

func (*ForwardPayload) String

func (x *ForwardPayload) String() string

type ForwardResponse

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

func (*ForwardResponse) Descriptor deprecated

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

Deprecated: Use ForwardResponse.ProtoReflect.Descriptor instead.

func (*ForwardResponse) ProtoMessage

func (*ForwardResponse) ProtoMessage()

func (*ForwardResponse) ProtoReflect

func (x *ForwardResponse) ProtoReflect() protoreflect.Message

func (*ForwardResponse) Reset

func (x *ForwardResponse) Reset()

func (*ForwardResponse) String

func (x *ForwardResponse) String() string

type ForwardServiceClient

type ForwardServiceClient interface {
	Forward(ctx context.Context, opts ...grpc.CallOption) (ForwardService_ForwardClient, error)
}

ForwardServiceClient is the client API for ForwardService service.

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

type ForwardServiceServer

type ForwardServiceServer interface {
	Forward(ForwardService_ForwardServer) error
}

ForwardServiceServer is the server API for ForwardService service.

type ForwardService_ForwardClient

type ForwardService_ForwardClient interface {
	Send(*ForwardPayload) error
	CloseAndRecv() (*ForwardResponse, error)
	grpc.ClientStream
}

type ForwardService_ForwardServer

type ForwardService_ForwardServer interface {
	SendAndClose(*ForwardResponse) error
	Recv() (*ForwardPayload, error)
	grpc.ServerStream
}

type UnimplementedForwardServiceServer

type UnimplementedForwardServiceServer struct {
}

UnimplementedForwardServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedForwardServiceServer) Forward

Jump to

Keyboard shortcuts

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