Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GrpcSubscribeSVC ¶
type GrpcSubscribeSVC struct { pb.UnimplementedSubscribeServiceServer // contains filtered or unexported fields }
GrpcSubscribeSVC ...
func NewGrpcSubscribeSVC ¶
func NewGrpcSubscribeSVC(writePool *nodemanager.WriterNodePool, readPool *nodemanager.ReaderNodePool) *GrpcSubscribeSVC
func (*GrpcSubscribeSVC) ListReader ¶
func (s *GrpcSubscribeSVC) ListReader(ctx context.Context, in *pb.ListReaderRequest) (*pb.ListReaderResponse, error)
func (*GrpcSubscribeSVC) WatchWriterEvent ¶
func (s *GrpcSubscribeSVC) WatchWriterEvent(in *pb.WriterEventSubcribeRequest, stream pb.SubscribeService_WatchWriterEventServer) error
Click to show internal directories.
Click to hide internal directories.