proxy

Documentation

Index

• Constants
• Variables
• func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
• type APIClient
  • func NewAPIClient(cc grpc.ClientConnInterface) APIClient
• type APIServer
• type API_ListenClient
• type API_ListenServer
• type ListenRequest
  • func (*ListenRequest) Descriptor() ([]byte, []int)
  • func (x *ListenRequest) GetChannel() string
  • func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (*ListenRequest) ProtoMessage()
  • func (x *ListenRequest) ProtoReflect() protoreflect.Message
  • func (x *ListenRequest) Reset()
  • func (x *ListenRequest) String() string
• type ListenResponse
  • func (*ListenResponse) Descriptor() ([]byte, []int)
  • func (x *ListenResponse) GetExtra() string
  • func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (*ListenResponse) ProtoMessage()
  • func (x *ListenResponse) ProtoReflect() protoreflect.Message
  • func (x *ListenResponse) Reset()
  • func (x *ListenResponse) String() string
• type UnimplementedAPIServer
  • func (UnimplementedAPIServer) Listen(*ListenRequest, API_ListenServer) error
• type UnsafeAPIServer

Constants

const (
	API_Listen_FullMethodName = "/proxy.API/Listen"
)

Variables

var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proxy.API",
	HandlerType: (*APIServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Listen",
			Handler:       _API_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proxy/proxy.proto",
}

API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_proxy_proxy_proto protoreflect.FileDescriptor

Functions

func RegisterAPIServer

func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)

Types

type APIClient

type APIClient interface {
	// Listen streams database events.
	// It signals that it is internally set up by sending an initial empty ListenResponse.
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (API_ListenClient, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAPIClient

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer

type APIServer interface {
	// Listen streams database events.
	// It signals that it is internally set up by sending an initial empty ListenResponse.
	Listen(*ListenRequest, API_ListenServer) error
	// contains filtered or unexported methods
}

APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility

type API_ListenClient

type API_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type API_ListenServer

type API_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type ListenRequest

type ListenRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenRequest) Descriptor

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

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetChannel

func (x *ListenRequest) GetChannel() string

func (*ListenRequest) MarshalLogObject

func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListenRequest) ProtoMessage

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect

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

func (*ListenRequest) Reset

func (x *ListenRequest) Reset()

func (*ListenRequest) String

func (x *ListenRequest) String() string

type ListenResponse

type ListenResponse struct {
	Extra string `protobuf:"bytes,1,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenResponse) Descriptor

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

Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse) GetExtra

func (x *ListenResponse) GetExtra() string

func (*ListenResponse) MarshalLogObject

func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListenResponse) ProtoMessage

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) ProtoReflect

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

func (*ListenResponse) Reset

func (x *ListenResponse) Reset()

func (*ListenResponse) String

func (x *ListenResponse) String() string

type UnimplementedAPIServer

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) Listen

func (UnimplementedAPIServer) Listen(*ListenRequest, API_ListenServer) error

type UnsafeAPIServer

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

UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.