tap

type TapClient ¶

type TapClient interface {
	Tap(ctx context.Context, in *public.TapRequest, opts ...grpc.CallOption) (Tap_TapClient, error)
	TapByResource(ctx context.Context, in *public.TapByResourceRequest, opts ...grpc.CallOption) (Tap_TapByResourceClient, error)
}

TapClient is the client API for Tap service.

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

func NewTapClient(cc *grpc.ClientConn) TapClient

type TapServer ¶

type TapServer interface {
	Tap(*public.TapRequest, Tap_TapServer) error
	TapByResource(*public.TapByResourceRequest, Tap_TapByResourceServer) error
}

TapServer is the server API for Tap service.

type Tap_TapByResourceClient ¶ added in v0.4.1

type Tap_TapByResourceClient interface {
	Recv() (*public.TapEvent, error)
	grpc.ClientStream
}

type Tap_TapByResourceServer ¶ added in v0.4.1

type Tap_TapByResourceServer interface {
	Send(*public.TapEvent) error
	grpc.ServerStream
}

type Tap_TapClient ¶

type Tap_TapClient interface {
	Recv() (*public.TapEvent, error)
	grpc.ClientStream
}

type Tap_TapServer ¶

type Tap_TapServer interface {
	Send(*public.TapEvent) error
	grpc.ServerStream
}