egress

Documentation

Index

• func RegisterEgressFilterServer(s *grpc.Server, srv EgressFilterServer)
• type EgressFilterClient
  • func NewEgressFilterClient(cc *grpc.ClientConn) EgressFilterClient
• type EgressFilterServer
• type EgressFilter_StreamFilterClient
• type EgressFilter_StreamFilterServer
• type UnimplementedEgressFilterServer
  • func (*UnimplementedEgressFilterServer) Filter(ctx context.Context, req *payload.Search_Response) (*payload.Search_Response, error)
  • func (*UnimplementedEgressFilterServer) StreamFilter(srv EgressFilter_StreamFilterServer) error

Functions

func RegisterEgressFilterServer

func RegisterEgressFilterServer(s *grpc.Server, srv EgressFilterServer)

Types

type EgressFilterClient

type EgressFilterClient interface {
	Filter(ctx context.Context, in *payload.Search_Response, opts ...grpc.CallOption) (*payload.Search_Response, error)
	StreamFilter(ctx context.Context, opts ...grpc.CallOption) (EgressFilter_StreamFilterClient, error)
}

EgressFilterClient is the client API for EgressFilter service.

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

func NewEgressFilterClient

func NewEgressFilterClient(cc *grpc.ClientConn) EgressFilterClient

type EgressFilterServer

type EgressFilterServer interface {
	Filter(context.Context, *payload.Search_Response) (*payload.Search_Response, error)
	StreamFilter(EgressFilter_StreamFilterServer) error
}

EgressFilterServer is the server API for EgressFilter service.

type EgressFilter_StreamFilterClient

type EgressFilter_StreamFilterClient interface {
	Send(*payload.Object_Distance) error
	Recv() (*payload.Object_Distance, error)
	grpc.ClientStream
}

type EgressFilter_StreamFilterServer

type EgressFilter_StreamFilterServer interface {
	Send(*payload.Object_Distance) error
	Recv() (*payload.Object_Distance, error)
	grpc.ServerStream
}

type UnimplementedEgressFilterServer

type UnimplementedEgressFilterServer struct {
}

UnimplementedEgressFilterServer can be embedded to have forward compatible implementations.

func (*UnimplementedEgressFilterServer) Filter

func (*UnimplementedEgressFilterServer) Filter(ctx context.Context, req *payload.Search_Response) (*payload.Search_Response, error)

func (*UnimplementedEgressFilterServer) StreamFilter

func (*UnimplementedEgressFilterServer) StreamFilter(srv EgressFilter_StreamFilterServer) error