streaming

type Item struct {
	Id       int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Category string `protobuf:"bytes,3,opt,name=category,proto3" json:"category,omitempty"`
	// contains filtered or unexported fields
}

type ItemEvent struct {
	EventType string `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` // "created", "updated", "deleted"
	Item      *Item  `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type ItemResponse struct {
	Item    *Item  `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ListItemsRequest struct {
	Category string `protobuf:"bytes,1,opt,name=category,proto3" json:"category,omitempty"`
	Limit    int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// Optional fields demonstrate explicit presence tracking
	Offset         *int32  `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	SortBy         *string `protobuf:"bytes,4,opt,name=sort_by,json=sortBy,proto3,oneof" json:"sort_by,omitempty"`
	IncludeDeleted *bool   `protobuf:"varint,5,opt,name=include_deleted,json=includeDeleted,proto3,oneof" json:"include_deleted,omitempty"`
	// contains filtered or unexported fields
}

type StreamingService struct {
	UnimplementedStreamingServiceServer
}

type StreamingServiceClient interface {
	// Server streaming: list items as they're found
	ListItems(ctx context.Context, in *ListItemsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ItemResponse], error)
	// Server streaming: watch for changes
	WatchItems(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ItemEvent], error)
}

type StreamingServiceServer interface {
	// Server streaming: list items as they're found
	ListItems(*ListItemsRequest, grpc.ServerStreamingServer[ItemResponse]) error
	// Server streaming: watch for changes
	WatchItems(*WatchRequest, grpc.ServerStreamingServer[ItemEvent]) error
	// contains filtered or unexported methods
}

type StreamingService_ListItemsClient = grpc.ServerStreamingClient[ItemResponse]

type StreamingService_ListItemsServer = grpc.ServerStreamingServer[ItemResponse]

type StreamingService_WatchItemsClient = grpc.ServerStreamingClient[ItemEvent]

type StreamingService_WatchItemsServer = grpc.ServerStreamingServer[ItemEvent]

type UnimplementedStreamingServiceServer struct{}

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

type WatchRequest struct {
	StartId int64 `protobuf:"varint,1,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"`
	// contains filtered or unexported fields
}