text:
DESCRIPTION = "System configuration and startup scripts for the Android compatibility layer"
LICENSE = "GPL-3.0-only"
LIC_FILES_CHKSUM = "file://${COMMON_LICENSE_DIR}/GPL-3.0-only;md5=c79ff39f19dfec6d293b95dea7b07891"

PR = "r4"

PACKAGE_ARCH = "${MACHINE_ARCH}"

# For some of the operations inside our setup script we need "real" sed!
RDEPENDS:${PN} = "sed"

# For running the container we're using lxc (>= 1.0 required)
# we use this with lxc from meta-luneos:
# https://github.com/webOS-ports/meta-webos-ports/tree/master/meta-luneos/recipes-containers/lxc
# because we don't want to include whole meta-virtualization
# https://github.com/webOS-ports/meta-webos-ports/commit/000ba06e2075e14ce9939f38e8dae9f4eea5824b
# But the one form meta-virtualization should work as well.
#
# Not adding the runtime dependency here to keep yocto-check-layer happy
# without this layer depending on whole meta-virtualization
# RDEPENDS:${PN} += "lxc"

# We're the former android-initscripts package
RPROVIDES:${PN} = "android-initscripts"
RREPLACES:${PN} = "android-initscripts"
RCONFLICTS:${PN} = "android-initscripts"

inherit systemd useradd

SRC_URI = " \
    file://android-system.service \
    file://wait-for-android.sh \
    file://lxc-config \
    file://pre-start.sh \
    file://post-stop.sh \
    file://10-boot-marker \
    file://30-mount-nothing \
    file://40-rootfs-rw \
"

# Create additional android users we need (need to have same UIDs as in android)
USERADD_PACKAGES = "${PN}"
USERADD_PARAM:${PN} = " \
                       -u 1000 -M system; \
                       -u 1001 -M radio; \
                       -u 1002 -M bluetooth; \
                       -u 1003 -M graphics; \
                       -u 1006 -M camera; \
                       -u 1007 -M log; \
                       -u 1008 -M compass; \
                       -u 1010 -M wifi; \
                       -u 1011 -M adb; \
                       -u 1012 -M install; \
                       -u 1013 -M media; \
                       -u 1014 -M dhcp; \
                       -u 1015 -M sdcard_rw; \
                       -u 1016 -M vpn; \
                       -u 1017 -M keystore; \
                       -u 1018 -M usb; \
                       -u 1019 -M drm; \
                       -u 1020 -M mdnsr; \
                       -u 1021 -M gps; \
                       -u 1023 -M media_rw; \
                       -u 1024 -M mtp; \
                       -u 1026 -M drmrpc; \
                       -u 1027 -M nfc; \
                       -u 1028 -M sdcard_r; \
                       -u 1029 -M clat; \
                       -u 1030 -M loop_radio; \
                       -u 1031 -M mediadrm; \
                       -u 1032 -M package_info; \
                       -u 1033 -M sdcard_pics; \
                       -u 1034 -M sdcard_av; \
                       -u 1035 -M sdcard_all; \
                       -u 1036 -M logd; \
                       -u 1037 -M shared_relro; \
                       -u 1038 -M dbus; \
                       -u 1039 -M tlsdate; \
                       -u 1040 -M mediaex; \
                       -u 1041 -M audioserver; \
                       -u 1042 -M metrics_coll; \
                       -u 1043 -M metricsd; \
                       -u 1044 -M webserv; \
                       -u 1045 -M debuggerd; \
                       -u 1046 -M mediacodec; \
                       -u 1047 -M cameraserver; \
                       -u 1048 -M firewall; \
                       -u 1049 -M trunks; \
                       -u 1050 -M nvram; \
                       -u 1051 -M dns; \
                       -u 1052 -M dns_tether; \
                       -u 1053 -M webview_zygote; \
                       -u 1054 -M vehicle_network; \
                       -u 1055 -M media_audio; \
                       -u 1056 -M media_video; \
                       -u 1057 -M media_image; \
                       -u 1058 -M tombstoned; \
                       -u 1059 -M media_obb; \
                       -u 1060 -M ese; \
                       -u 1061 -M ota_update; \
                       -u 1062 -M automotive_evs; \
                       -u 1063 -M lowpan; \
                       -u 1064 -M hsm; \
                       -u 1065 -M reserved_disk; \
                       -u 1066 -M statsd; \
                       -u 1067 -M incidentd; \
                       -u 1068 -M secure_element; \
                       -u 1069 -M lmkd; \
                       -u 1070 -M llkd; \
                       -u 1071 -M iorapd; \
                       -u 1072 -M gpu_service; \
                       -u 1073 -M network_stack; \
                       -u 1074 -M gsid; \
                       -u 1075 -M fsverity_cert; \
                       -u 1076 -M credstore; \
                       -u 1077 -M external_storage; \
                       -u 1078 -M ext_data_rw; \
                       -u 1079 -M ext_obb_rw; \
                       -u 1080 -M context_hub; \
                       -u 2000 -M shell; \
                       -u 2001 -M cache; \
                       -u 2002 -M diag; \
                       -u 2901 -M oem_2901; \
                       -u 2902 -M oem_2902; \
                       -u 2903 -M oem_2903; \
                       -u 2904 -M oem_2904; \
                       -u 2905 -M oem_2905; \
                       -u 2906 -M oem_2906; \
                       -u 3001 -M net_bt_admin; \
                       -u 3002 -M net_bt; \
                       -u 3003 -M inet; \
                       -u 3004 -M net_raw; \
                       -u 3005 -M net_admin; \
                       -u 3006 -M net_bw_stats; \
                       -u 3007 -M net_bw_acct; \
                       -u 3008 -M net_bt_stack; \
                       -u 3009 -M readproc; \
                       -u 3010 -M wakelock; \
                       -u 3011 -M uhid; \
                       -u 9997 -M everybody; \
                       -u 9998 -M misc; \
                       -u 9999 -M nobody; "

do_install() {
    install -d ${D}${systemd_unitdir}/system
    install -m 0644 ${WORKDIR}/android-system.service ${D}${systemd_unitdir}/system

    install -d ${D}${bindir}
    install -m 0755 ${WORKDIR}/wait-for-android.sh ${D}${bindir}

    install -d ${D}${localstatedir}/lib/lxc/android
    install -m 0644 ${WORKDIR}/lxc-config ${D}${localstatedir}/lib/lxc/android/config
    install -m 0755 ${WORKDIR}/pre-start.sh ${D}${localstatedir}/lib/lxc/android/
    install -m 0755 ${WORKDIR}/post-stop.sh ${D}${localstatedir}/lib/lxc/android/

    install -d ${D}${localstatedir}/lib/lxc/android/pre-start.d
    install -m 0755 ${WORKDIR}/10-boot-marker ${D}${localstatedir}/lib/lxc/android/pre-start.d/
    install -m 0755 ${WORKDIR}/30-mount-nothing ${D}${localstatedir}/lib/lxc/android/pre-start.d/
    install -m 0755 ${WORKDIR}/40-rootfs-rw ${D}${localstatedir}/lib/lxc/android/pre-start.d/

    install -d ${D}${localstatedir}/lib/lxc/android/rootfs

    # Somehow during post installation the link for android-system.service isn't created
    install -d ${D}${sysconfdir}/systemd/system/basic.target.requires
    ln -sf ${systemd_unitdir}/system/android-system.service \
        ${D}${sysconfdir}/systemd/system/basic.target.requires/android-system.service
}

SYSTEMD_SERVICE:${PN} = "android-system.service"

license: MIT

repository: shr-distribution/meta-smartphone

repo_name: shr-distribution/meta-smartphone

gha_language: Roff

extension: bb


text:
using System;
using MonoTouch.ObjCRuntime;

[assembly: LinkWith ("libCorePlot-CocoaTouch.a", LinkTarget.Simulator | LinkTarget.ArmV6 | LinkTarget.ArmV7, Frameworks = "CoreGraphics QuartzCore", ForceLoad = true, IsCxx = true)]

repository: chrisbranson/monotouch-bindings

license_type: permissive

repo_name: chrisbranson/monotouch-bindings

branch_name: refs/heads/master

extension: cs


text:
package gooky

import "fmt"
import "net/http"
import "os"
import "bufio"

type Micro struct {
    di *DI
    handlers [32]func(*AppContext)
    httpWriter http.ResponseWriter
}

func (this *Micro) Map(pattern string, handler func(*AppContext)) *Route {
    route := this.GetDI().GetRouter().Add(pattern)
    this.handlers[route.GetId()] = handler
    return route
}

func (this *Micro) SetDI(di *DI) *Micro {
    this.di = di
    return this
}

func (this *Micro) GetDI() *DI {
    if this.di == nil {
        this.di = &DI {};
    }
    return this.di
}

func (this *Micro) GetResponse() *Response {
    return this.GetDI().GetResponse()
}

func (this *Micro) ServeHTTP(httpWriter http.ResponseWriter, httpRequest *http.Request) {

    this.httpWriter = httpWriter

    uri := httpRequest.URL.Path
    fmt.Println(uri)

    //Check if the file exists
    fi, err := os.Stat("public" + uri)
    if err == nil {
        if !fi.IsDir() {

            var (
                file *os.File
                part []byte
                prefix bool
            )

            if file, err = os.Open("public" + uri); err != nil {
                return
            }

            reader := bufio.NewReader(file)
            for {
                if part, prefix, err = reader.ReadLine(); err != nil {
                    break
                }
                fmt.Println(prefix)
                httpWriter.Write(part)
            }
            return
        }
    }

    //Try match a route
    router := this.GetDI().GetRouter()

    match := router.Handle(uri)

    if (match.WasMatched()) {

        //Create a context
        context := &AppContext {}

        request := &Request {HttpRequest: httpRequest}
        context.SetRequest(request)

        response := &Response {}
        context.SetResponse(response)

        route := match.GetMatchedRoute()
        context.SetParams(match.GetParams())

        this.handlers[route.GetId()](context)

        httpWriter.Write([]byte(context.GetResponse().GetContent()))
        return
    }

    handler := http.NotFoundHandler()
    handler.ServeHTTP(httpWriter, httpRequest)
}

func (this *Micro) Handle() {
    http.ListenAndServe(":3030", this)
}

repository: gooky/gooky

repo_name: gooky/gooky

extension: go


text:
using System;
namespace net.kibotu.recyclerview
{
    public class PresenterViewModel<T>
    {
        public T Model { get; set; }

        public Action<T> OnClick { get; set; }
    }
}


text:
require xorg-proto-common.inc

SUMMARY = "XC-MISC: X XC-Miscellaneous extension headers"

DESCRIPTION = "This package provides the wire protocol for the XC-MISC \
extension, which is used to get details of XID allocations within the \
server."

LICENSE = "MIT-style"
LIC_FILES_CHKSUM = "file://COPYING;md5=09d83047c15994e05db29b423ed6662e"

PE = "1"

BBCLASSEXTEND = "native nativesdk"

SRC_URI[md5sum] = "5f4847c78e41b801982c8a5e06365b24"
SRC_URI[sha256sum] = "b13236869372256c36db79ae39d54214172677fb79e9cdc555dceec80bd9d2df"

#
# Meta-debian
#
inherit debian-package
DPR = "0"
DPN = "x11proto-xcmisc"
DEBIAN_SECTIONS = "x11"
DEBIAN_PATCH_TYPE = "nopatch"

repository: takuya-t/meta-debian

repo_name: takuya-t/meta-debian

branch_name: refs/heads/daisy


text:
/// <reference path="include.d.ts" />

import * as should from "should";
import * as q from "q";

describe('mocha', function() {
    it('should test correctly', function() {
        should(1).be.equal(1);
        should('test').be.equal('test');
    });

    it('should await promise', async function() {
        let result = await createPromise('delay', 10);
        should(result).be.equal('delay');
    })
});

function createPromise(value: string, delay: number = 50) {
    let deferred = q.defer<string>();
    setTimeout(() => deferred.resolve(value), delay);
    return deferred.promise;
}

repository: marcel-hofer/markdown-document

repo_name: marcel-hofer/markdown-document

gha_license_id: MIT

gha_language: TypeScript

extension: ts


text:
package checkip

import (
	"encoding/json"
	"fmt"
	"net"
	"net/http"
)

// OTX holds information from otx.alienvault.com.
type OTX struct {
	PulseInfo struct {
		Count int `json:"count"`
	} `json:"pulse_info"`
}

// Check gets data from https://otx.alienvault.com/api.
func (otx *OTX) Check(ipaddr net.IP) error {
	apiurl := fmt.Sprintf("https://otx.alienvault.com/api/v1/indicators/IPv4/%s/", ipaddr.String())

	resp, err := makeAPIcall(apiurl, map[string]string{}, map[string]string{})
	if err != nil {
		return err
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusOK {
		return fmt.Errorf("%s", resp.Status)
	}

	if err := json.NewDecoder(resp.Body).Decode(otx); err != nil {
		return err
	}

	return nil
}

// IsOK returns true if the IP address is not considered suspicious.
func (otx *OTX) IsOK() bool {
	return otx.PulseInfo.Count <= 10
}

repository: cloudxo/checkip

repo_name: cloudxo/checkip


text:
package providers

import (
	"fmt"
	"strings"

	"github.com/BurntSushi/toml"
	log "github.com/Sirupsen/logrus"
	"github.com/camptocamp/bivac/orchestrators"
	"github.com/camptocamp/bivac/volume"
)

// Providers stores the list of available providers
type Providers struct {
	Providers map[string]Provider
}

// Provider stores data for one provider
type Provider struct {
	Name         string `toml:"-"`
	PreCmd       string `toml:"pre_cmd"`
	PostCmd      string `toml:"post_cmd"`
	DetectionCmd string `toml:"detect_cmd"`
	BackupDir    string `toml:"backup_dir"`
}

type configToml struct {
	Providers map[string]Provider `toml:"providers"`
}

// LoadProviders returns the list of providers from the provider config file
func LoadProviders(path string) (providers Providers, err error) {
	c := &configToml{}
	providers.Providers = make(map[string]Provider)
	_, err = toml.DecodeFile(path, &c)
	if err != nil {
		err = fmt.Errorf("failed to load providers from config file: %s", err)
		return
	}

	for key, value := range c.Providers {
		provider := Provider{
			Name:         key,
			PreCmd:       value.PreCmd,
			PostCmd:      value.PostCmd,
			DetectionCmd: value.DetectionCmd,
			BackupDir:    value.BackupDir,
		}
		providers.Providers[key] = provider
	}
	return
}

// GetProvider returns a provider based on detection commands
func (providers *Providers) GetProvider(o orchestrators.Orchestrator, v *volume.Volume) (prov Provider, err error) {
	detectionCmds := []string{}
	for _, p := range providers.Providers {
		detectionCmds = append(detectionCmds, fmt.Sprintf("(%s && echo '%s')", p.DetectionCmd, p.Name))
	}
	detectionCmds = append(detectionCmds, "true")
	fullDetectionCmd := strings.Join(detectionCmds, " || ")

	containers, err := o.GetContainersMountingVolume(v)
	if err != nil {
		return
	}
	if len(containers) < 1 {
		log.WithFields(log.Fields{
			"volume": v.Name,
		}).Info("No running container found using the volume.")
		return
	}

	var stdout string
	for _, container := range containers {
		fullDetectionCmd = strings.Replace(fullDetectionCmd, "$volume", container.Path, -1)
		log.WithFields(log.Fields{
			"volume": v.Name,
			"cmd":    fullDetectionCmd,
		}).Debugf("Running detection command in container %s...", container.ContainerID)

		stdout, err = o.ContainerExec(container, []string{"bash", "-c", fullDetectionCmd})
		if err != nil {
			log.Debugf("failed to run provider detection: %s", err)
			err = nil
			continue
		}

		stdout = strings.TrimSpace(stdout)

		for _, p := range providers.Providers {
			if p.Name == stdout {
				log.WithFields(log.Fields{
					"volume": v.Name,
				}).Infof("This volume should be a %s datadir", p.Name)
				prov = p
				v.BackupDir = p.BackupDir
				return
			}
		}
	}
	return
}

// RunCmd runs a command into a container
func RunCmd(p Provider, o orchestrators.Orchestrator, v *volume.Volume, cmd string) (err error) {
	containers, err := o.GetContainersMountingVolume(v)
	if err != nil {
		return err
	}

	cmdSuccess := false
	var stdout string
	for _, container := range containers {
		cmd = strings.Replace(cmd, "$volume", container.Path, -1)

		log.WithFields(log.Fields{
			"volume": v.Name,
			"cmd":    cmd,
		}).Debugf("Running command in container %s...", container.ContainerID)

		stdout, err = o.ContainerExec(container, []string{"bash", "-c", cmd})
		if err != nil {
			log.WithFields(log.Fields{
				"volume":    v.Name,
				"cmd":       cmd,
				"container": container.ContainerID,
			}).Errorf("failed to run command in container: %s", err)
		} else {
			cmdSuccess = true
			break
		}
	}

	if cmdSuccess {
		log.WithFields(log.Fields{
			"volume": v.Name,
			"cmd":    cmd,
		}).Debugf("stdout: %s", stdout)
	} else {
		return fmt.Errorf("failed to run command \"%s\" in containers mounting volume %s", cmd, v.Name)
	}
	return
}

repository: pi-geosolutions/bivac

repo_name: pi-geosolutions/bivac


text:
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: alameda_api/v1alpha1/datahub/server.proto

package containers_ai_alameda_v1alpha1_datahub

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import empty "github.com/golang/protobuf/ptypes/empty"
import status "google.golang.org/genproto/googleapis/rpc/status"

import (
	context "golang.org/x/net/context"
	grpc "google.golang.org/grpc"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package

// *
// Represents a request for listing metric data of a pod
//
type ListPodMetricsRequest struct {
	NamespacedName       *NamespacedName `protobuf:"bytes,1,opt,name=namespaced_name,json=namespacedName,proto3" json:"namespaced_name,omitempty"`
	TimeRange            *TimeRange      `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *ListPodMetricsRequest) Reset()         { *m = ListPodMetricsRequest{} }
func (m *ListPodMetricsRequest) String() string { return proto.CompactTextString(m) }
func (*ListPodMetricsRequest) ProtoMessage()    {}
func (*ListPodMetricsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{0}
}
func (m *ListPodMetricsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodMetricsRequest.Unmarshal(m, b)
}
func (m *ListPodMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodMetricsRequest.Marshal(b, m, deterministic)
}
func (dst *ListPodMetricsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodMetricsRequest.Merge(dst, src)
}
func (m *ListPodMetricsRequest) XXX_Size() int {
	return xxx_messageInfo_ListPodMetricsRequest.Size(m)
}
func (m *ListPodMetricsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodMetricsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodMetricsRequest proto.InternalMessageInfo

func (m *ListPodMetricsRequest) GetNamespacedName() *NamespacedName {
	if m != nil {
		return m.NamespacedName
	}
	return nil
}

func (m *ListPodMetricsRequest) GetTimeRange() *TimeRange {
	if m != nil {
		return m.TimeRange
	}
	return nil
}

// *
// Represents a response for a listing pod metric data request
//
type ListPodMetricsResponse struct {
	Status               *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PodMetrics           []*PodMetric   `protobuf:"bytes,2,rep,name=pod_metrics,json=podMetrics,proto3" json:"pod_metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *ListPodMetricsResponse) Reset()         { *m = ListPodMetricsResponse{} }
func (m *ListPodMetricsResponse) String() string { return proto.CompactTextString(m) }
func (*ListPodMetricsResponse) ProtoMessage()    {}
func (*ListPodMetricsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{1}
}
func (m *ListPodMetricsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodMetricsResponse.Unmarshal(m, b)
}
func (m *ListPodMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodMetricsResponse.Marshal(b, m, deterministic)
}
func (dst *ListPodMetricsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodMetricsResponse.Merge(dst, src)
}
func (m *ListPodMetricsResponse) XXX_Size() int {
	return xxx_messageInfo_ListPodMetricsResponse.Size(m)
}
func (m *ListPodMetricsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodMetricsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodMetricsResponse proto.InternalMessageInfo

func (m *ListPodMetricsResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListPodMetricsResponse) GetPodMetrics() []*PodMetric {
	if m != nil {
		return m.PodMetrics
	}
	return nil
}

// *
// Represents a request for listing metric data of a node
//
type ListNodeMetricsRequest struct {
	NodeNames            []string   `protobuf:"bytes,1,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
	TimeRange            *TimeRange `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (m *ListNodeMetricsRequest) Reset()         { *m = ListNodeMetricsRequest{} }
func (m *ListNodeMetricsRequest) String() string { return proto.CompactTextString(m) }
func (*ListNodeMetricsRequest) ProtoMessage()    {}
func (*ListNodeMetricsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{2}
}
func (m *ListNodeMetricsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListNodeMetricsRequest.Unmarshal(m, b)
}
func (m *ListNodeMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListNodeMetricsRequest.Marshal(b, m, deterministic)
}
func (dst *ListNodeMetricsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListNodeMetricsRequest.Merge(dst, src)
}
func (m *ListNodeMetricsRequest) XXX_Size() int {
	return xxx_messageInfo_ListNodeMetricsRequest.Size(m)
}
func (m *ListNodeMetricsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListNodeMetricsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListNodeMetricsRequest proto.InternalMessageInfo

func (m *ListNodeMetricsRequest) GetNodeNames() []string {
	if m != nil {
		return m.NodeNames
	}
	return nil
}

func (m *ListNodeMetricsRequest) GetTimeRange() *TimeRange {
	if m != nil {
		return m.TimeRange
	}
	return nil
}

// *
// Represents a response for a listing node metrics request
//
type ListNodeMetricsResponse struct {
	Status               *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	NodeMetrics          []*NodeMetric  `protobuf:"bytes,2,rep,name=node_metrics,json=nodeMetrics,proto3" json:"node_metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *ListNodeMetricsResponse) Reset()         { *m = ListNodeMetricsResponse{} }
func (m *ListNodeMetricsResponse) String() string { return proto.CompactTextString(m) }
func (*ListNodeMetricsResponse) ProtoMessage()    {}
func (*ListNodeMetricsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{3}
}
func (m *ListNodeMetricsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListNodeMetricsResponse.Unmarshal(m, b)
}
func (m *ListNodeMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListNodeMetricsResponse.Marshal(b, m, deterministic)
}
func (dst *ListNodeMetricsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListNodeMetricsResponse.Merge(dst, src)
}
func (m *ListNodeMetricsResponse) XXX_Size() int {
	return xxx_messageInfo_ListNodeMetricsResponse.Size(m)
}
func (m *ListNodeMetricsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListNodeMetricsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListNodeMetricsResponse proto.InternalMessageInfo

func (m *ListNodeMetricsResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListNodeMetricsResponse) GetNodeMetrics() []*NodeMetric {
	if m != nil {
		return m.NodeMetrics
	}
	return nil
}

// *
// Represents a response for a listing pods request
//
type ListPodsResponse struct {
	Status               *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Pods                 []*Pod         `protobuf:"bytes,2,rep,name=pods,proto3" json:"pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *ListPodsResponse) Reset()         { *m = ListPodsResponse{} }
func (m *ListPodsResponse) String() string { return proto.CompactTextString(m) }
func (*ListPodsResponse) ProtoMessage()    {}
func (*ListPodsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{4}
}
func (m *ListPodsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodsResponse.Unmarshal(m, b)
}
func (m *ListPodsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodsResponse.Marshal(b, m, deterministic)
}
func (dst *ListPodsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodsResponse.Merge(dst, src)
}
func (m *ListPodsResponse) XXX_Size() int {
	return xxx_messageInfo_ListPodsResponse.Size(m)
}
func (m *ListPodsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodsResponse proto.InternalMessageInfo

func (m *ListPodsResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListPodsResponse) GetPods() []*Pod {
	if m != nil {
		return m.Pods
	}
	return nil
}

// *
// Represents a request for listing pods that need to be predicted
//
type ListAlamedaPodsRequest struct {
	AlamedaScaler        *NamespacedName `protobuf:"bytes,1,opt,name=alameda_scaler,json=alamedaScaler,proto3" json:"alameda_scaler,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *ListAlamedaPodsRequest) Reset()         { *m = ListAlamedaPodsRequest{} }
func (m *ListAlamedaPodsRequest) String() string { return proto.CompactTextString(m) }
func (*ListAlamedaPodsRequest) ProtoMessage()    {}
func (*ListAlamedaPodsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{5}
}
func (m *ListAlamedaPodsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListAlamedaPodsRequest.Unmarshal(m, b)
}
func (m *ListAlamedaPodsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListAlamedaPodsRequest.Marshal(b, m, deterministic)
}
func (dst *ListAlamedaPodsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListAlamedaPodsRequest.Merge(dst, src)
}
func (m *ListAlamedaPodsRequest) XXX_Size() int {
	return xxx_messageInfo_ListAlamedaPodsRequest.Size(m)
}
func (m *ListAlamedaPodsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListAlamedaPodsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListAlamedaPodsRequest proto.InternalMessageInfo

func (m *ListAlamedaPodsRequest) GetAlamedaScaler() *NamespacedName {
	if m != nil {
		return m.AlamedaScaler
	}
	return nil
}

// *
// Represents a response for a listing nodes request
//
type ListNodesResponse struct {
	Status               *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Nodes                []*Node        `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *ListNodesResponse) Reset()         { *m = ListNodesResponse{} }
func (m *ListNodesResponse) String() string { return proto.CompactTextString(m) }
func (*ListNodesResponse) ProtoMessage()    {}
func (*ListNodesResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{6}
}
func (m *ListNodesResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListNodesResponse.Unmarshal(m, b)
}
func (m *ListNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListNodesResponse.Marshal(b, m, deterministic)
}
func (dst *ListNodesResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListNodesResponse.Merge(dst, src)
}
func (m *ListNodesResponse) XXX_Size() int {
	return xxx_messageInfo_ListNodesResponse.Size(m)
}
func (m *ListNodesResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListNodesResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListNodesResponse proto.InternalMessageInfo

func (m *ListNodesResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListNodesResponse) GetNodes() []*Node {
	if m != nil {
		return m.Nodes
	}
	return nil
}

// *
// Represents a request for listing predictions of pods
//
type ListPodPredictionsRequest struct {
	NamespacedName       *NamespacedName `protobuf:"bytes,1,opt,name=namespaced_name,json=namespacedName,proto3" json:"namespaced_name,omitempty"`
	TimeRange            *TimeRange      `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *ListPodPredictionsRequest) Reset()         { *m = ListPodPredictionsRequest{} }
func (m *ListPodPredictionsRequest) String() string { return proto.CompactTextString(m) }
func (*ListPodPredictionsRequest) ProtoMessage()    {}
func (*ListPodPredictionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{7}
}
func (m *ListPodPredictionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodPredictionsRequest.Unmarshal(m, b)
}
func (m *ListPodPredictionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodPredictionsRequest.Marshal(b, m, deterministic)
}
func (dst *ListPodPredictionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodPredictionsRequest.Merge(dst, src)
}
func (m *ListPodPredictionsRequest) XXX_Size() int {
	return xxx_messageInfo_ListPodPredictionsRequest.Size(m)
}
func (m *ListPodPredictionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodPredictionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodPredictionsRequest proto.InternalMessageInfo

func (m *ListPodPredictionsRequest) GetNamespacedName() *NamespacedName {
	if m != nil {
		return m.NamespacedName
	}
	return nil
}

func (m *ListPodPredictionsRequest) GetTimeRange() *TimeRange {
	if m != nil {
		return m.TimeRange
	}
	return nil
}

// *
// Represents a response for a listing predictions of pods request
//
type ListPodPredictionsResponse struct {
	Status               *status.Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PodPredictions       []*PodPrediction `protobuf:"bytes,2,rep,name=pod_predictions,json=podPredictions,proto3" json:"pod_predictions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *ListPodPredictionsResponse) Reset()         { *m = ListPodPredictionsResponse{} }
func (m *ListPodPredictionsResponse) String() string { return proto.CompactTextString(m) }
func (*ListPodPredictionsResponse) ProtoMessage()    {}
func (*ListPodPredictionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{8}
}
func (m *ListPodPredictionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodPredictionsResponse.Unmarshal(m, b)
}
func (m *ListPodPredictionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodPredictionsResponse.Marshal(b, m, deterministic)
}
func (dst *ListPodPredictionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodPredictionsResponse.Merge(dst, src)
}
func (m *ListPodPredictionsResponse) XXX_Size() int {
	return xxx_messageInfo_ListPodPredictionsResponse.Size(m)
}
func (m *ListPodPredictionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodPredictionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodPredictionsResponse proto.InternalMessageInfo

func (m *ListPodPredictionsResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListPodPredictionsResponse) GetPodPredictions() []*PodPrediction {
	if m != nil {
		return m.PodPredictions
	}
	return nil
}

// *
// Represents a request for listing predictions of nodes
//
type ListNodePredictionsRequest struct {
	NodeNames            []string   `protobuf:"bytes,1,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
	TimeRange            *TimeRange `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (m *ListNodePredictionsRequest) Reset()         { *m = ListNodePredictionsRequest{} }
func (m *ListNodePredictionsRequest) String() string { return proto.CompactTextString(m) }
func (*ListNodePredictionsRequest) ProtoMessage()    {}
func (*ListNodePredictionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{9}
}
func (m *ListNodePredictionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListNodePredictionsRequest.Unmarshal(m, b)
}
func (m *ListNodePredictionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListNodePredictionsRequest.Marshal(b, m, deterministic)
}
func (dst *ListNodePredictionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListNodePredictionsRequest.Merge(dst, src)
}
func (m *ListNodePredictionsRequest) XXX_Size() int {
	return xxx_messageInfo_ListNodePredictionsRequest.Size(m)
}
func (m *ListNodePredictionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListNodePredictionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListNodePredictionsRequest proto.InternalMessageInfo

func (m *ListNodePredictionsRequest) GetNodeNames() []string {
	if m != nil {
		return m.NodeNames
	}
	return nil
}

func (m *ListNodePredictionsRequest) GetTimeRange() *TimeRange {
	if m != nil {
		return m.TimeRange
	}
	return nil
}

// *
// Represents a response for a listing predictions of nodes request
//
type ListNodePredictionsResponse struct {
	Status               *status.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	NodePredictions      []*NodePrediction `protobuf:"bytes,2,rep,name=node_predictions,json=nodePredictions,proto3" json:"node_predictions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ListNodePredictionsResponse) Reset()         { *m = ListNodePredictionsResponse{} }
func (m *ListNodePredictionsResponse) String() string { return proto.CompactTextString(m) }
func (*ListNodePredictionsResponse) ProtoMessage()    {}
func (*ListNodePredictionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{10}
}
func (m *ListNodePredictionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListNodePredictionsResponse.Unmarshal(m, b)
}
func (m *ListNodePredictionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListNodePredictionsResponse.Marshal(b, m, deterministic)
}
func (dst *ListNodePredictionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListNodePredictionsResponse.Merge(dst, src)
}
func (m *ListNodePredictionsResponse) XXX_Size() int {
	return xxx_messageInfo_ListNodePredictionsResponse.Size(m)
}
func (m *ListNodePredictionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListNodePredictionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListNodePredictionsResponse proto.InternalMessageInfo

func (m *ListNodePredictionsResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListNodePredictionsResponse) GetNodePredictions() []*NodePrediction {
	if m != nil {
		return m.NodePredictions
	}
	return nil
}

// *
// Represents a request for listing recommendations of pods
//
type ListPodRecommendationsRequest struct {
	NamespacedName       *NamespacedName `protobuf:"bytes,1,opt,name=namespaced_name,json=namespacedName,proto3" json:"namespaced_name,omitempty"`
	TimeRange            *TimeRange      `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *ListPodRecommendationsRequest) Reset()         { *m = ListPodRecommendationsRequest{} }
func (m *ListPodRecommendationsRequest) String() string { return proto.CompactTextString(m) }
func (*ListPodRecommendationsRequest) ProtoMessage()    {}
func (*ListPodRecommendationsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{11}
}
func (m *ListPodRecommendationsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodRecommendationsRequest.Unmarshal(m, b)
}
func (m *ListPodRecommendationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodRecommendationsRequest.Marshal(b, m, deterministic)
}
func (dst *ListPodRecommendationsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodRecommendationsRequest.Merge(dst, src)
}
func (m *ListPodRecommendationsRequest) XXX_Size() int {
	return xxx_messageInfo_ListPodRecommendationsRequest.Size(m)
}
func (m *ListPodRecommendationsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodRecommendationsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodRecommendationsRequest proto.InternalMessageInfo

func (m *ListPodRecommendationsRequest) GetNamespacedName() *NamespacedName {
	if m != nil {
		return m.NamespacedName
	}
	return nil
}

func (m *ListPodRecommendationsRequest) GetTimeRange() *TimeRange {
	if m != nil {
		return m.TimeRange
	}
	return nil
}

// *
// Represents a response for listing pod recommendations request
//
type ListPodRecommendationsResponse struct {
	Status               *status.Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PodRecommendations   []*PodRecommendation `protobuf:"bytes,2,rep,name=pod_recommendations,json=podRecommendations,proto3" json:"pod_recommendations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (m *ListPodRecommendationsResponse) Reset()         { *m = ListPodRecommendationsResponse{} }
func (m *ListPodRecommendationsResponse) String() string { return proto.CompactTextString(m) }
func (*ListPodRecommendationsResponse) ProtoMessage()    {}
func (*ListPodRecommendationsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{12}
}
func (m *ListPodRecommendationsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodRecommendationsResponse.Unmarshal(m, b)
}
func (m *ListPodRecommendationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodRecommendationsResponse.Marshal(b, m, deterministic)
}
func (dst *ListPodRecommendationsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodRecommendationsResponse.Merge(dst, src)
}
func (m *ListPodRecommendationsResponse) XXX_Size() int {
	return xxx_messageInfo_ListPodRecommendationsResponse.Size(m)
}
func (m *ListPodRecommendationsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodRecommendationsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodRecommendationsResponse proto.InternalMessageInfo

func (m *ListPodRecommendationsResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListPodRecommendationsResponse) GetPodRecommendations() []*PodRecommendation {
	if m != nil {
		return m.PodRecommendations
	}
	return nil
}

// *
// Represents a request for listing pods by nodes' name
//
type ListPodsByNodeNamesRequest struct {
	NodeNames            []string `protobuf:"bytes,1,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListPodsByNodeNamesRequest) Reset()         { *m = ListPodsByNodeNamesRequest{} }
func (m *ListPodsByNodeNamesRequest) String() string { return proto.CompactTextString(m) }
func (*ListPodsByNodeNamesRequest) ProtoMessage()    {}
func (*ListPodsByNodeNamesRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{13}
}
func (m *ListPodsByNodeNamesRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPodsByNodeNamesRequest.Unmarshal(m, b)
}
func (m *ListPodsByNodeNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPodsByNodeNamesRequest.Marshal(b, m, deterministic)
}
func (dst *ListPodsByNodeNamesRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPodsByNodeNamesRequest.Merge(dst, src)
}
func (m *ListPodsByNodeNamesRequest) XXX_Size() int {
	return xxx_messageInfo_ListPodsByNodeNamesRequest.Size(m)
}
func (m *ListPodsByNodeNamesRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPodsByNodeNamesRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListPodsByNodeNamesRequest proto.InternalMessageInfo

func (m *ListPodsByNodeNamesRequest) GetNodeNames() []string {
	if m != nil {
		return m.NodeNames
	}
	return nil
}

// *
// Represents a request for listing system scores of pod scheduled on node
//
type ListSimulatedSchedulingScoresRequest struct {
	TimeRange            *TimeRange `protobuf:"bytes,1,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (m *ListSimulatedSchedulingScoresRequest) Reset()         { *m = ListSimulatedSchedulingScoresRequest{} }
func (m *ListSimulatedSchedulingScoresRequest) String() string { return proto.CompactTextString(m) }
func (*ListSimulatedSchedulingScoresRequest) ProtoMessage()    {}
func (*ListSimulatedSchedulingScoresRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{14}
}
func (m *ListSimulatedSchedulingScoresRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListSimulatedSchedulingScoresRequest.Unmarshal(m, b)
}
func (m *ListSimulatedSchedulingScoresRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListSimulatedSchedulingScoresRequest.Marshal(b, m, deterministic)
}
func (dst *ListSimulatedSchedulingScoresRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListSimulatedSchedulingScoresRequest.Merge(dst, src)
}
func (m *ListSimulatedSchedulingScoresRequest) XXX_Size() int {
	return xxx_messageInfo_ListSimulatedSchedulingScoresRequest.Size(m)
}
func (m *ListSimulatedSchedulingScoresRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListSimulatedSchedulingScoresRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListSimulatedSchedulingScoresRequest proto.InternalMessageInfo

func (m *ListSimulatedSchedulingScoresRequest) GetTimeRange() *TimeRange {
	if m != nil {
		return m.TimeRange
	}
	return nil
}

// *
// Represents a response for listing system scores request
//
type ListSimulatedSchedulingScoresResponse struct {
	Status               *status.Status              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Scores               []*SimulatedSchedulingScore `protobuf:"bytes,2,rep,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (m *ListSimulatedSchedulingScoresResponse) Reset()         { *m = ListSimulatedSchedulingScoresResponse{} }
func (m *ListSimulatedSchedulingScoresResponse) String() string { return proto.CompactTextString(m) }
func (*ListSimulatedSchedulingScoresResponse) ProtoMessage()    {}
func (*ListSimulatedSchedulingScoresResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{15}
}
func (m *ListSimulatedSchedulingScoresResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListSimulatedSchedulingScoresResponse.Unmarshal(m, b)
}
func (m *ListSimulatedSchedulingScoresResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListSimulatedSchedulingScoresResponse.Marshal(b, m, deterministic)
}
func (dst *ListSimulatedSchedulingScoresResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListSimulatedSchedulingScoresResponse.Merge(dst, src)
}
func (m *ListSimulatedSchedulingScoresResponse) XXX_Size() int {
	return xxx_messageInfo_ListSimulatedSchedulingScoresResponse.Size(m)
}
func (m *ListSimulatedSchedulingScoresResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListSimulatedSchedulingScoresResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListSimulatedSchedulingScoresResponse proto.InternalMessageInfo

func (m *ListSimulatedSchedulingScoresResponse) GetStatus() *status.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ListSimulatedSchedulingScoresResponse) GetScores() []*SimulatedSchedulingScore {
	if m != nil {
		return m.Scores
	}
	return nil
}

// *
// Represents a request for creating predictions of containers' metric data belonging to a pod
type CreatePodPredictionsRequest struct {
	PodPredictions       []*PodPrediction `protobuf:"bytes,1,rep,name=pod_predictions,json=podPredictions,proto3" json:"pod_predictions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *CreatePodPredictionsRequest) Reset()         { *m = CreatePodPredictionsRequest{} }
func (m *CreatePodPredictionsRequest) String() string { return proto.CompactTextString(m) }
func (*CreatePodPredictionsRequest) ProtoMessage()    {}
func (*CreatePodPredictionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{16}
}
func (m *CreatePodPredictionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePodPredictionsRequest.Unmarshal(m, b)
}
func (m *CreatePodPredictionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePodPredictionsRequest.Marshal(b, m, deterministic)
}
func (dst *CreatePodPredictionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePodPredictionsRequest.Merge(dst, src)
}
func (m *CreatePodPredictionsRequest) XXX_Size() int {
	return xxx_messageInfo_CreatePodPredictionsRequest.Size(m)
}
func (m *CreatePodPredictionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePodPredictionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePodPredictionsRequest proto.InternalMessageInfo

func (m *CreatePodPredictionsRequest) GetPodPredictions() []*PodPrediction {
	if m != nil {
		return m.PodPredictions
	}
	return nil
}

// *
// Represents a request for creating predictions of a node metric data
//
type CreateNodePredictionsRequest struct {
	NodePredictions      []*NodePrediction `protobuf:"bytes,1,rep,name=node_predictions,json=nodePredictions,proto3" json:"node_predictions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *CreateNodePredictionsRequest) Reset()         { *m = CreateNodePredictionsRequest{} }
func (m *CreateNodePredictionsRequest) String() string { return proto.CompactTextString(m) }
func (*CreateNodePredictionsRequest) ProtoMessage()    {}
func (*CreateNodePredictionsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{17}
}
func (m *CreateNodePredictionsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateNodePredictionsRequest.Unmarshal(m, b)
}
func (m *CreateNodePredictionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateNodePredictionsRequest.Marshal(b, m, deterministic)
}
func (dst *CreateNodePredictionsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateNodePredictionsRequest.Merge(dst, src)
}
func (m *CreateNodePredictionsRequest) XXX_Size() int {
	return xxx_messageInfo_CreateNodePredictionsRequest.Size(m)
}
func (m *CreateNodePredictionsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateNodePredictionsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateNodePredictionsRequest proto.InternalMessageInfo

func (m *CreateNodePredictionsRequest) GetNodePredictions() []*NodePrediction {
	if m != nil {
		return m.NodePredictions
	}
	return nil
}

// *
// Represents a request for creating a pod's recommendation
//
type CreatePodRecommendationsRequest struct {
	PodRecommendations   []*PodRecommendation `protobuf:"bytes,1,rep,name=pod_recommendations,json=podRecommendations,proto3" json:"pod_recommendations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (m *CreatePodRecommendationsRequest) Reset()         { *m = CreatePodRecommendationsRequest{} }
func (m *CreatePodRecommendationsRequest) String() string { return proto.CompactTextString(m) }
func (*CreatePodRecommendationsRequest) ProtoMessage()    {}
func (*CreatePodRecommendationsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{18}
}
func (m *CreatePodRecommendationsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePodRecommendationsRequest.Unmarshal(m, b)
}
func (m *CreatePodRecommendationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePodRecommendationsRequest.Marshal(b, m, deterministic)
}
func (dst *CreatePodRecommendationsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePodRecommendationsRequest.Merge(dst, src)
}
func (m *CreatePodRecommendationsRequest) XXX_Size() int {
	return xxx_messageInfo_CreatePodRecommendationsRequest.Size(m)
}
func (m *CreatePodRecommendationsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePodRecommendationsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePodRecommendationsRequest proto.InternalMessageInfo

func (m *CreatePodRecommendationsRequest) GetPodRecommendations() []*PodRecommendation {
	if m != nil {
		return m.PodRecommendations
	}
	return nil
}

// *
// Represents a request for creating pods
//
type CreatePodsRequest struct {
	Pods                 []*Pod   `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *CreatePodsRequest) Reset()         { *m = CreatePodsRequest{} }
func (m *CreatePodsRequest) String() string { return proto.CompactTextString(m) }
func (*CreatePodsRequest) ProtoMessage()    {}
func (*CreatePodsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{19}
}
func (m *CreatePodsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePodsRequest.Unmarshal(m, b)
}
func (m *CreatePodsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePodsRequest.Marshal(b, m, deterministic)
}
func (dst *CreatePodsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePodsRequest.Merge(dst, src)
}
func (m *CreatePodsRequest) XXX_Size() int {
	return xxx_messageInfo_CreatePodsRequest.Size(m)
}
func (m *CreatePodsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePodsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePodsRequest proto.InternalMessageInfo

func (m *CreatePodsRequest) GetPods() []*Pod {
	if m != nil {
		return m.Pods
	}
	return nil
}

// *
// Represents a request for adding nodes that need to be predicted
//
type CreateAlamedaNodesRequest struct {
	AlamedaNodes         []*Node  `protobuf:"bytes,1,rep,name=alameda_nodes,json=alamedaNodes,proto3" json:"alameda_nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *CreateAlamedaNodesRequest) Reset()         { *m = CreateAlamedaNodesRequest{} }
func (m *CreateAlamedaNodesRequest) String() string { return proto.CompactTextString(m) }
func (*CreateAlamedaNodesRequest) ProtoMessage()    {}
func (*CreateAlamedaNodesRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{20}
}
func (m *CreateAlamedaNodesRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateAlamedaNodesRequest.Unmarshal(m, b)
}
func (m *CreateAlamedaNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateAlamedaNodesRequest.Marshal(b, m, deterministic)
}
func (dst *CreateAlamedaNodesRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateAlamedaNodesRequest.Merge(dst, src)
}
func (m *CreateAlamedaNodesRequest) XXX_Size() int {
	return xxx_messageInfo_CreateAlamedaNodesRequest.Size(m)
}
func (m *CreateAlamedaNodesRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateAlamedaNodesRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateAlamedaNodesRequest proto.InternalMessageInfo

func (m *CreateAlamedaNodesRequest) GetAlamedaNodes() []*Node {
	if m != nil {
		return m.AlamedaNodes
	}
	return nil
}

// *
// Represents a request for adding scheduling scores produced by ai engine
//
type CreateSimulatedSchedulingScoresRequest struct {
	Scores               []*SimulatedSchedulingScore `protobuf:"bytes,1,rep,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (m *CreateSimulatedSchedulingScoresRequest) Reset() {
	*m = CreateSimulatedSchedulingScoresRequest{}
}
func (m *CreateSimulatedSchedulingScoresRequest) String() string { return proto.CompactTextString(m) }
func (*CreateSimulatedSchedulingScoresRequest) ProtoMessage()    {}
func (*CreateSimulatedSchedulingScoresRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{21}
}
func (m *CreateSimulatedSchedulingScoresRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateSimulatedSchedulingScoresRequest.Unmarshal(m, b)
}
func (m *CreateSimulatedSchedulingScoresRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateSimulatedSchedulingScoresRequest.Marshal(b, m, deterministic)
}
func (dst *CreateSimulatedSchedulingScoresRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateSimulatedSchedulingScoresRequest.Merge(dst, src)
}
func (m *CreateSimulatedSchedulingScoresRequest) XXX_Size() int {
	return xxx_messageInfo_CreateSimulatedSchedulingScoresRequest.Size(m)
}
func (m *CreateSimulatedSchedulingScoresRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateSimulatedSchedulingScoresRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateSimulatedSchedulingScoresRequest proto.InternalMessageInfo

func (m *CreateSimulatedSchedulingScoresRequest) GetScores() []*SimulatedSchedulingScore {
	if m != nil {
		return m.Scores
	}
	return nil
}

// *
// Represents a request for deleting pods data
//
type DeletePodsRequest struct {
	Pods                 []*Pod   `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DeletePodsRequest) Reset()         { *m = DeletePodsRequest{} }
func (m *DeletePodsRequest) String() string { return proto.CompactTextString(m) }
func (*DeletePodsRequest) ProtoMessage()    {}
func (*DeletePodsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{22}
}
func (m *DeletePodsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeletePodsRequest.Unmarshal(m, b)
}
func (m *DeletePodsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeletePodsRequest.Marshal(b, m, deterministic)
}
func (dst *DeletePodsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeletePodsRequest.Merge(dst, src)
}
func (m *DeletePodsRequest) XXX_Size() int {
	return xxx_messageInfo_DeletePodsRequest.Size(m)
}
func (m *DeletePodsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DeletePodsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DeletePodsRequest proto.InternalMessageInfo

func (m *DeletePodsRequest) GetPods() []*Pod {
	if m != nil {
		return m.Pods
	}
	return nil
}

// *
// Represents a request for stoping predicting nodes
//
type DeleteAlamedaNodesRequest struct {
	AlamedaNodes         []*Node  `protobuf:"bytes,1,rep,name=alameda_nodes,json=alamedaNodes,proto3" json:"alameda_nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DeleteAlamedaNodesRequest) Reset()         { *m = DeleteAlamedaNodesRequest{} }
func (m *DeleteAlamedaNodesRequest) String() string { return proto.CompactTextString(m) }
func (*DeleteAlamedaNodesRequest) ProtoMessage()    {}
func (*DeleteAlamedaNodesRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_server_9505d9e944a1aa23, []int{23}
}
func (m *DeleteAlamedaNodesRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeleteAlamedaNodesRequest.Unmarshal(m, b)
}
func (m *DeleteAlamedaNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeleteAlamedaNodesRequest.Marshal(b, m, deterministic)
}
func (dst *DeleteAlamedaNodesRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeleteAlamedaNodesRequest.Merge(dst, src)
}
func (m *DeleteAlamedaNodesRequest) XXX_Size() int {
	return xxx_messageInfo_DeleteAlamedaNodesRequest.Size(m)
}
func (m *DeleteAlamedaNodesRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DeleteAlamedaNodesRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DeleteAlamedaNodesRequest proto.InternalMessageInfo

func (m *DeleteAlamedaNodesRequest) GetAlamedaNodes() []*Node {
	if m != nil {
		return m.AlamedaNodes
	}
	return nil
}

func init() {
	proto.RegisterType((*ListPodMetricsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodMetricsRequest")
	proto.RegisterType((*ListPodMetricsResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodMetricsResponse")
	proto.RegisterType((*ListNodeMetricsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListNodeMetricsRequest")
	proto.RegisterType((*ListNodeMetricsResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListNodeMetricsResponse")
	proto.RegisterType((*ListPodsResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodsResponse")
	proto.RegisterType((*ListAlamedaPodsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListAlamedaPodsRequest")
	proto.RegisterType((*ListNodesResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListNodesResponse")
	proto.RegisterType((*ListPodPredictionsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodPredictionsRequest")
	proto.RegisterType((*ListPodPredictionsResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodPredictionsResponse")
	proto.RegisterType((*ListNodePredictionsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListNodePredictionsRequest")
	proto.RegisterType((*ListNodePredictionsResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListNodePredictionsResponse")
	proto.RegisterType((*ListPodRecommendationsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodRecommendationsRequest")
	proto.RegisterType((*ListPodRecommendationsResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodRecommendationsResponse")
	proto.RegisterType((*ListPodsByNodeNamesRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListPodsByNodeNamesRequest")
	proto.RegisterType((*ListSimulatedSchedulingScoresRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.ListSimulatedSchedulingScoresRequest")
	proto.RegisterType((*ListSimulatedSchedulingScoresResponse)(nil), "containers_ai.alameda.v1alpha1.datahub.ListSimulatedSchedulingScoresResponse")
	proto.RegisterType((*CreatePodPredictionsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.CreatePodPredictionsRequest")
	proto.RegisterType((*CreateNodePredictionsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.CreateNodePredictionsRequest")
	proto.RegisterType((*CreatePodRecommendationsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.CreatePodRecommendationsRequest")
	proto.RegisterType((*CreatePodsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.CreatePodsRequest")
	proto.RegisterType((*CreateAlamedaNodesRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.CreateAlamedaNodesRequest")
	proto.RegisterType((*CreateSimulatedSchedulingScoresRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.CreateSimulatedSchedulingScoresRequest")
	proto.RegisterType((*DeletePodsRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.DeletePodsRequest")
	proto.RegisterType((*DeleteAlamedaNodesRequest)(nil), "containers_ai.alameda.v1alpha1.datahub.DeleteAlamedaNodesRequest")
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// DatahubServiceClient is the client API for DatahubService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type DatahubServiceClient interface {
	// / Used to list pod metric data
	ListPodMetrics(ctx context.Context, in *ListPodMetricsRequest, opts ...grpc.CallOption) (*ListPodMetricsResponse, error)
	// / Used to list node metric data
	ListNodeMetrics(ctx context.Context, in *ListNodeMetricsRequest, opts ...grpc.CallOption) (*ListNodeMetricsResponse, error)
	// Used to list pods need to be predicted
	ListAlamedaPods(ctx context.Context, in *ListAlamedaPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error)
	// Used to list nodes need to be predicted
	ListAlamedaNodes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListNodesResponse, error)
	// / Used to list pod predictions
	ListPodPredictions(ctx context.Context, in *ListPodPredictionsRequest, opts ...grpc.CallOption) (*ListPodPredictionsResponse, error)
	// / Used to list node predictions
	ListNodePredictions(ctx context.Context, in *ListNodePredictionsRequest, opts ...grpc.CallOption) (*ListNodePredictionsResponse, error)
	// / Used to list pod recommenations
	ListPodRecommendations(ctx context.Context, in *ListPodRecommendationsRequest, opts ...grpc.CallOption) (*ListPodRecommendationsResponse, error)
	// / Used to list pods by a node name
	ListPodsByNodeName(ctx context.Context, in *ListPodsByNodeNamesRequest, opts ...grpc.CallOption) (*ListPodsResponse, error)
	// / Used to list system scores
	ListSimulatedSchedulingScores(ctx context.Context, in *ListSimulatedSchedulingScoresRequest, opts ...grpc.CallOption) (*ListSimulatedSchedulingScoresResponse, error)
	// / Used to add pods that need to be predicted
	CreatePods(ctx context.Context, in *CreatePodsRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to add nodes that need to be predicted
	CreateAlamedaNodes(ctx context.Context, in *CreateAlamedaNodesRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to create predictions of pods
	CreatePodPredictions(ctx context.Context, in *CreatePodPredictionsRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to create predictions of nodes
	CreateNodePredictions(ctx context.Context, in *CreateNodePredictionsRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to create recommendations of pods
	CreatePodRecommendations(ctx context.Context, in *CreatePodRecommendationsRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to create scores of system
	CreateSimulatedSchedulingScores(ctx context.Context, in *CreateSimulatedSchedulingScoresRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to delete info of pods
	DeletePods(ctx context.Context, in *DeletePodsRequest, opts ...grpc.CallOption) (*status.Status, error)
	// / Used to stop generating predictions for the nodes
	DeleteAlamedaNodes(ctx context.Context, in *DeleteAlamedaNodesRequest, opts ...grpc.CallOption) (*status.Status, error)
}

type datahubServiceClient struct {
	cc *grpc.ClientConn
}

func NewDatahubServiceClient(cc *grpc.ClientConn) DatahubServiceClient {
	return &datahubServiceClient{cc}
}

func (c *datahubServiceClient) ListPodMetrics(ctx context.Context, in *ListPodMetricsRequest, opts ...grpc.CallOption) (*ListPodMetricsResponse, error) {
	out := new(ListPodMetricsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodMetrics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListNodeMetrics(ctx context.Context, in *ListNodeMetricsRequest, opts ...grpc.CallOption) (*ListNodeMetricsResponse, error) {
	out := new(ListNodeMetricsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListNodeMetrics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListAlamedaPods(ctx context.Context, in *ListAlamedaPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error) {
	out := new(ListPodsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListAlamedaPods", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListAlamedaNodes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListNodesResponse, error) {
	out := new(ListNodesResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListAlamedaNodes", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListPodPredictions(ctx context.Context, in *ListPodPredictionsRequest, opts ...grpc.CallOption) (*ListPodPredictionsResponse, error) {
	out := new(ListPodPredictionsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodPredictions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListNodePredictions(ctx context.Context, in *ListNodePredictionsRequest, opts ...grpc.CallOption) (*ListNodePredictionsResponse, error) {
	out := new(ListNodePredictionsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListNodePredictions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListPodRecommendations(ctx context.Context, in *ListPodRecommendationsRequest, opts ...grpc.CallOption) (*ListPodRecommendationsResponse, error) {
	out := new(ListPodRecommendationsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodRecommendations", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListPodsByNodeName(ctx context.Context, in *ListPodsByNodeNamesRequest, opts ...grpc.CallOption) (*ListPodsResponse, error) {
	out := new(ListPodsResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodsByNodeName", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) ListSimulatedSchedulingScores(ctx context.Context, in *ListSimulatedSchedulingScoresRequest, opts ...grpc.CallOption) (*ListSimulatedSchedulingScoresResponse, error) {
	out := new(ListSimulatedSchedulingScoresResponse)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListSimulatedSchedulingScores", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) CreatePods(ctx context.Context, in *CreatePodsRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreatePods", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) CreateAlamedaNodes(ctx context.Context, in *CreateAlamedaNodesRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreateAlamedaNodes", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) CreatePodPredictions(ctx context.Context, in *CreatePodPredictionsRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreatePodPredictions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) CreateNodePredictions(ctx context.Context, in *CreateNodePredictionsRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreateNodePredictions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) CreatePodRecommendations(ctx context.Context, in *CreatePodRecommendationsRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreatePodRecommendations", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) CreateSimulatedSchedulingScores(ctx context.Context, in *CreateSimulatedSchedulingScoresRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreateSimulatedSchedulingScores", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) DeletePods(ctx context.Context, in *DeletePodsRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/DeletePods", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *datahubServiceClient) DeleteAlamedaNodes(ctx context.Context, in *DeleteAlamedaNodesRequest, opts ...grpc.CallOption) (*status.Status, error) {
	out := new(status.Status)
	err := c.cc.Invoke(ctx, "/containers_ai.alameda.v1alpha1.datahub.DatahubService/DeleteAlamedaNodes", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DatahubServiceServer is the server API for DatahubService service.
type DatahubServiceServer interface {
	// / Used to list pod metric data
	ListPodMetrics(context.Context, *ListPodMetricsRequest) (*ListPodMetricsResponse, error)
	// / Used to list node metric data
	ListNodeMetrics(context.Context, *ListNodeMetricsRequest) (*ListNodeMetricsResponse, error)
	// Used to list pods need to be predicted
	ListAlamedaPods(context.Context, *ListAlamedaPodsRequest) (*ListPodsResponse, error)
	// Used to list nodes need to be predicted
	ListAlamedaNodes(context.Context, *empty.Empty) (*ListNodesResponse, error)
	// / Used to list pod predictions
	ListPodPredictions(context.Context, *ListPodPredictionsRequest) (*ListPodPredictionsResponse, error)
	// / Used to list node predictions
	ListNodePredictions(context.Context, *ListNodePredictionsRequest) (*ListNodePredictionsResponse, error)
	// / Used to list pod recommenations
	ListPodRecommendations(context.Context, *ListPodRecommendationsRequest) (*ListPodRecommendationsResponse, error)
	// / Used to list pods by a node name
	ListPodsByNodeName(context.Context, *ListPodsByNodeNamesRequest) (*ListPodsResponse, error)
	// / Used to list system scores
	ListSimulatedSchedulingScores(context.Context, *ListSimulatedSchedulingScoresRequest) (*ListSimulatedSchedulingScoresResponse, error)
	// / Used to add pods that need to be predicted
	CreatePods(context.Context, *CreatePodsRequest) (*status.Status, error)
	// / Used to add nodes that need to be predicted
	CreateAlamedaNodes(context.Context, *CreateAlamedaNodesRequest) (*status.Status, error)
	// / Used to create predictions of pods
	CreatePodPredictions(context.Context, *CreatePodPredictionsRequest) (*status.Status, error)
	// / Used to create predictions of nodes
	CreateNodePredictions(context.Context, *CreateNodePredictionsRequest) (*status.Status, error)
	// / Used to create recommendations of pods
	CreatePodRecommendations(context.Context, *CreatePodRecommendationsRequest) (*status.Status, error)
	// / Used to create scores of system
	CreateSimulatedSchedulingScores(context.Context, *CreateSimulatedSchedulingScoresRequest) (*status.Status, error)
	// / Used to delete info of pods
	DeletePods(context.Context, *DeletePodsRequest) (*status.Status, error)
	// / Used to stop generating predictions for the nodes
	DeleteAlamedaNodes(context.Context, *DeleteAlamedaNodesRequest) (*status.Status, error)
}

func RegisterDatahubServiceServer(s *grpc.Server, srv DatahubServiceServer) {
	s.RegisterService(&_DatahubService_serviceDesc, srv)
}

func _DatahubService_ListPodMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPodMetricsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListPodMetrics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodMetrics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListPodMetrics(ctx, req.(*ListPodMetricsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListNodeMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListNodeMetricsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListNodeMetrics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListNodeMetrics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListNodeMetrics(ctx, req.(*ListNodeMetricsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListAlamedaPods_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAlamedaPodsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListAlamedaPods(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListAlamedaPods",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListAlamedaPods(ctx, req.(*ListAlamedaPodsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListAlamedaNodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(empty.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListAlamedaNodes(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListAlamedaNodes",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListAlamedaNodes(ctx, req.(*empty.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListPodPredictions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPodPredictionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListPodPredictions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodPredictions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListPodPredictions(ctx, req.(*ListPodPredictionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListNodePredictions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListNodePredictionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListNodePredictions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListNodePredictions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListNodePredictions(ctx, req.(*ListNodePredictionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListPodRecommendations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPodRecommendationsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListPodRecommendations(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodRecommendations",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListPodRecommendations(ctx, req.(*ListPodRecommendationsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListPodsByNodeName_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPodsByNodeNamesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListPodsByNodeName(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListPodsByNodeName",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListPodsByNodeName(ctx, req.(*ListPodsByNodeNamesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_ListSimulatedSchedulingScores_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListSimulatedSchedulingScoresRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).ListSimulatedSchedulingScores(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/ListSimulatedSchedulingScores",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).ListSimulatedSchedulingScores(ctx, req.(*ListSimulatedSchedulingScoresRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_CreatePods_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreatePodsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).CreatePods(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreatePods",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).CreatePods(ctx, req.(*CreatePodsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_CreateAlamedaNodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateAlamedaNodesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).CreateAlamedaNodes(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreateAlamedaNodes",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).CreateAlamedaNodes(ctx, req.(*CreateAlamedaNodesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_CreatePodPredictions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreatePodPredictionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).CreatePodPredictions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreatePodPredictions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).CreatePodPredictions(ctx, req.(*CreatePodPredictionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_CreateNodePredictions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateNodePredictionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).CreateNodePredictions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreateNodePredictions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).CreateNodePredictions(ctx, req.(*CreateNodePredictionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_CreatePodRecommendations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreatePodRecommendationsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).CreatePodRecommendations(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreatePodRecommendations",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).CreatePodRecommendations(ctx, req.(*CreatePodRecommendationsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_CreateSimulatedSchedulingScores_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSimulatedSchedulingScoresRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).CreateSimulatedSchedulingScores(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/CreateSimulatedSchedulingScores",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).CreateSimulatedSchedulingScores(ctx, req.(*CreateSimulatedSchedulingScoresRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_DeletePods_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeletePodsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).DeletePods(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/DeletePods",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).DeletePods(ctx, req.(*DeletePodsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatahubService_DeleteAlamedaNodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteAlamedaNodesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatahubServiceServer).DeleteAlamedaNodes(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/containers_ai.alameda.v1alpha1.datahub.DatahubService/DeleteAlamedaNodes",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatahubServiceServer).DeleteAlamedaNodes(ctx, req.(*DeleteAlamedaNodesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _DatahubService_serviceDesc = grpc.ServiceDesc{
	ServiceName: "containers_ai.alameda.v1alpha1.datahub.DatahubService",
	HandlerType: (*DatahubServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPodMetrics",
			Handler:    _DatahubService_ListPodMetrics_Handler,
		},
		{
			MethodName: "ListNodeMetrics",
			Handler:    _DatahubService_ListNodeMetrics_Handler,
		},
		{
			MethodName: "ListAlamedaPods",
			Handler:    _DatahubService_ListAlamedaPods_Handler,
		},
		{
			MethodName: "ListAlamedaNodes",
			Handler:    _DatahubService_ListAlamedaNodes_Handler,
		},
		{
			MethodName: "ListPodPredictions",
			Handler:    _DatahubService_ListPodPredictions_Handler,
		},
		{
			MethodName: "ListNodePredictions",
			Handler:    _DatahubService_ListNodePredictions_Handler,
		},
		{
			MethodName: "ListPodRecommendations",
			Handler:    _DatahubService_ListPodRecommendations_Handler,
		},
		{
			MethodName: "ListPodsByNodeName",
			Handler:    _DatahubService_ListPodsByNodeName_Handler,
		},
		{
			MethodName: "ListSimulatedSchedulingScores",
			Handler:    _DatahubService_ListSimulatedSchedulingScores_Handler,
		},
		{
			MethodName: "CreatePods",
			Handler:    _DatahubService_CreatePods_Handler,
		},
		{
			MethodName: "CreateAlamedaNodes",
			Handler:    _DatahubService_CreateAlamedaNodes_Handler,
		},
		{
			MethodName: "CreatePodPredictions",
			Handler:    _DatahubService_CreatePodPredictions_Handler,
		},
		{
			MethodName: "CreateNodePredictions",
			Handler:    _DatahubService_CreateNodePredictions_Handler,
		},
		{
			MethodName: "CreatePodRecommendations",
			Handler:    _DatahubService_CreatePodRecommendations_Handler,
		},
		{
			MethodName: "CreateSimulatedSchedulingScores",
			Handler:    _DatahubService_CreateSimulatedSchedulingScores_Handler,
		},
		{
			MethodName: "DeletePods",
			Handler:    _DatahubService_DeletePods_Handler,
		},
		{
			MethodName: "DeleteAlamedaNodes",
			Handler:    _DatahubService_DeleteAlamedaNodes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "alameda_api/v1alpha1/datahub/server.proto",
}

func init() {
	proto.RegisterFile("alameda_api/v1alpha1/datahub/server.proto", fileDescriptor_server_9505d9e944a1aa23)
}

var fileDescriptor_server_9505d9e944a1aa23 = []byte{
	// 1097 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x58, 0xcf, 0x6f, 0xdc, 0x44,
	0x14, 0xee, 0xb4, 0x10, 0x29, 0x2f, 0x65, 0xd3, 0x4c, 0x69, 0x9b, 0x3a, 0x14, 0x2a, 0x0b, 0xaa,
	0xb4, 0x45, 0x5e, 0x25, 0x88, 0x8a, 0x0a, 0x41, 0x69, 0x92, 0xc2, 0xa5, 0x8d, 0x82, 0x37, 0x48,
	0x5c, 0xc2, 0x6a, 0x62, 0x0f, 0x1b, 0xa3, 0xb5, 0x3d, 0xb5, 0x67, 0x03, 0x39, 0x20, 0xc4, 0x0f,
	0x09, 0x71, 0xc8, 0x01, 0x89, 0x03, 0x07, 0x90, 0x38, 0x82, 0x04, 0x77, 0x4e, 0xfc, 0x01, 0x1c,
	0x38, 0xf0, 0x17, 0x55, 0xf6, 0x8c, 0xbd, 0xeb, 0xf5, 0x38, 0xeb, 0xf1, 0x6e, 0x2b, 0xe5, 0xe6,
	0xc4, 0xf3, 0xde, 0xfb, 0xde, 0xf7, 0x7e, 0xcc, 0xe7, 0x85, 0x9b, 0xa4, 0x4f, 0x7c, 0xea, 0x92,
	0x2e, 0x61, 0x5e, 0xfb, 0x70, 0x8d, 0xf4, 0xd9, 0x01, 0x59, 0x6b, 0xbb, 0x84, 0x93, 0x83, 0xc1,
	0x7e, 0x3b, 0xa6, 0xd1, 0x21, 0x8d, 0x2c, 0x16, 0x85, 0x3c, 0xc4, 0x37, 0x9c, 0x30, 0xe0, 0xc4,
	0x0b, 0x68, 0x14, 0x77, 0x89, 0x67, 0x49, 0x43, 0x2b, 0x33, 0xb2, 0xa4, 0x91, 0x71, 0xa5, 0x17,
	0x86, 0xbd, 0x3e, 0x6d, 0x47, 0xcc, 0x69, 0xc7, 0x9c, 0xf0, 0x41, 0x2c, 0x1c, 0x18, 0x2b, 0xf2,
	0x45, 0xfa, 0xd7, 0xfe, 0xe0, 0xd3, 0x36, 0xf5, 0x19, 0x3f, 0x92, 0x2f, 0x6f, 0x9f, 0x08, 0xc4,
	0xa7, 0x9c, 0x24, 0xcf, 0xf2, 0xf0, 0xad, 0x13, 0x0f, 0xb3, 0x88, 0xba, 0x9e, 0xc3, 0xe5, 0xd9,
	0x9b, 0x93, 0x1c, 0x47, 0x9e, 0x53, 0x0b, 0x43, 0x44, 0xe3, 0x70, 0x10, 0x39, 0x54, 0x1e, 0x5e,
	0x9b, 0x70, 0xd8, 0x09, 0x7d, 0x9f, 0x06, 0x2e, 0xe1, 0x5e, 0x18, 0x48, 0x93, 0xd5, 0x93, 0xc9,
	0x76, 0xc2, 0x48, 0x3a, 0x37, 0xff, 0x45, 0x70, 0xe9, 0xa1, 0x17, 0xf3, 0x9d, 0xd0, 0x7d, 0x94,
	0x22, 0x8c, 0x6d, 0xfa, 0x78, 0x40, 0x63, 0x8e, 0xbb, 0xb0, 0x18, 0x10, 0x9f, 0xc6, 0x8c, 0x38,
	0xd4, 0xed, 0x26, 0x8f, 0xcb, 0xe8, 0x3a, 0x5a, 0x5d, 0x58, 0xbf, 0x63, 0xd5, 0xab, 0x8f, 0xb5,
	0x9d, 0x9b, 0x27, 0x4f, 0x76, 0x2b, 0x28, 0xfc, 0x8d, 0x77, 0x00, 0xb8, 0xe7, 0xd3, 0x6e, 0x44,
	0x82, 0x1e, 0x5d, 0x3e, 0x9b, 0xfa, 0x5e, 0xab, 0xeb, 0x7b, 0xd7, 0xf3, 0xa9, 0x9d, 0x18, 0xda,
	0xf3, 0x3c, 0x7b, 0x34, 0x7f, 0x46, 0x70, 0x79, 0x3c, 0x99, 0x98, 0x85, 0x41, 0x4c, 0xf1, 0x2d,
	0x98, 0x13, 0x2d, 0x22, 0x93, 0xc0, 0x96, 0xe8, 0x11, 0x2b, 0x62, 0x8e, 0xd5, 0x49, 0xdf, 0xd8,
	0xf2, 0x04, 0xb6, 0x61, 0x81, 0x85, 0x6e, 0x57, 0x54, 0x2c, 0x5e, 0x3e, 0x7b, 0xfd, 0x9c, 0x0e,
	0xb2, 0x3c, 0xb8, 0x0d, 0x2c, 0xc7, 0x61, 0xfe, 0x20, 0xa1, 0x6d, 0x87, 0x2e, 0x1d, 0x23, 0xfa,
	0x1a, 0x40, 0x10, 0xba, 0x34, 0xa5, 0x38, 0x81, 0x77, 0x6e, 0x75, 0xde, 0x9e, 0x4f, 0xfe, 0x93,
	0xf2, 0xf7, 0x14, 0x68, 0xfa, 0x05, 0xc1, 0x95, 0x12, 0x96, 0x06, 0x3c, 0x7d, 0x04, 0xe7, 0x53,
	0xe0, 0x45, 0xa2, 0xd6, 0x6b, 0xb7, 0x47, 0x1e, 0xde, 0x5e, 0x08, 0x86, 0x50, 0xcc, 0xaf, 0xe0,
	0x82, 0x2c, 0x62, 0x33, 0x58, 0xf7, 0xe0, 0x39, 0x16, 0xba, 0x19, 0x9c, 0xdb, 0x1a, 0x75, 0xb3,
	0x53, 0x43, 0xf3, 0x73, 0x51, 0xaa, 0xfb, 0xe2, 0xa4, 0xc0, 0x21, 0x4a, 0xb5, 0x07, 0xad, 0x6c,
	0xb2, 0x62, 0x87, 0xf4, 0x69, 0x34, 0xe5, 0x48, 0xbc, 0x20, 0x0f, 0x76, 0x52, 0x67, 0xe6, 0xb7,
	0x08, 0x96, 0xb2, 0xc2, 0x34, 0xcb, 0x7d, 0x03, 0x9e, 0x4f, 0xa8, 0xcc, 0x92, 0x7f, 0x5d, 0xa7,
	0x16, 0xb6, 0x30, 0x35, 0xff, 0x43, 0x70, 0x55, 0x16, 0x60, 0x47, 0x2c, 0x38, 0x2f, 0x0c, 0x4e,
	0xf3, 0x5a, 0xf8, 0x1d, 0x81, 0xa1, 0x4a, 0xa8, 0x01, 0xbf, 0x9f, 0xc0, 0x62, 0xb2, 0x1a, 0xd8,
	0xd0, 0x8d, 0x64, 0xfa, 0x4d, 0x8d, 0x36, 0x1b, 0x82, 0xb0, 0x5b, 0xac, 0x80, 0xc9, 0x3c, 0x96,
	0x50, 0x93, 0x7a, 0x28, 0xc8, 0x7f, 0xe6, 0xab, 0xe2, 0x4f, 0x04, 0x2b, 0x4a, 0x3c, 0x0d, 0xb8,
	0x23, 0x70, 0x21, 0x05, 0x5f, 0x26, 0xef, 0x8e, 0x4e, 0x9b, 0x8e, 0xb0, 0xb7, 0x18, 0x14, 0x61,
	0x99, 0xff, 0x23, 0xb8, 0x26, 0x2b, 0x6d, 0x17, 0xee, 0xc5, 0xd3, 0xdc, 0xbe, 0x7f, 0x23, 0x78,
	0xb9, 0x2a, 0xa9, 0x06, 0x65, 0xf8, 0x0c, 0x2e, 0x26, 0x2d, 0x5c, 0xd4, 0x0d, 0x59, 0x25, 0xee,
	0xea, 0x6c, 0xcb, 0x82, 0x07, 0x1b, 0xb3, 0x12, 0x3e, 0xf3, 0xed, 0x7c, 0xf0, 0xe2, 0x8d, 0xa3,
	0xed, 0xac, 0x4f, 0xeb, 0x75, 0xb3, 0xf9, 0x05, 0xbc, 0x9a, 0x18, 0x77, 0x3c, 0x7f, 0xd0, 0x27,
	0x9c, 0xba, 0x1d, 0xe7, 0x80, 0xba, 0x83, 0xbe, 0x17, 0xf4, 0x3a, 0x89, 0x80, 0xc9, 0xdd, 0x14,
	0x19, 0x47, 0x33, 0x60, 0xfc, 0x2f, 0x04, 0xaf, 0x4d, 0x08, 0xdd, 0x80, 0xf8, 0x8f, 0x61, 0x2e,
	0x55, 0x5e, 0x19, 0xd7, 0xef, 0xd5, 0xc5, 0x58, 0x05, 0xc3, 0x96, 0xfe, 0xcc, 0x2f, 0x61, 0x65,
	0x33, 0xa2, 0x84, 0x53, 0xf5, 0xca, 0x56, 0x2c, 0x2d, 0x34, 0xcb, 0xa5, 0xf5, 0x35, 0x82, 0x97,
	0x44, 0xfc, 0x8a, 0xb5, 0xa5, 0x9a, 0x7c, 0x34, 0xdb, 0xc9, 0x3f, 0x46, 0xf0, 0x4a, 0xce, 0x41,
	0xc5, 0xec, 0x57, 0x74, 0x3e, 0x7a, 0x1a, 0x9d, 0xbf, 0x0b, 0x4b, 0x39, 0x9c, 0x1c, 0x40, 0xa6,
	0x4c, 0x50, 0x53, 0x65, 0x12, 0xc0, 0x55, 0xe1, 0x55, 0x6a, 0x13, 0x29, 0x14, 0x84, 0xf7, 0x0f,
	0x21, 0x93, 0x13, 0x5d, 0xa1, 0x01, 0x50, 0x03, 0x0d, 0x70, 0x9e, 0x8c, 0x78, 0x36, 0xbf, 0x41,
	0x70, 0x43, 0x04, 0x9c, 0x38, 0x85, 0xc3, 0xee, 0x46, 0x33, 0xee, 0xee, 0x5d, 0x58, 0xda, 0xa2,
	0x7d, 0x3a, 0x7b, 0x2a, 0x85, 0xd7, 0x67, 0x43, 0xe5, 0xfa, 0x77, 0x18, 0x5a, 0x5b, 0xe2, 0x75,
	0x87, 0x46, 0x87, 0x9e, 0x43, 0xf1, 0x8f, 0x08, 0x5a, 0xc5, 0xcf, 0x15, 0xfc, 0x4e, 0xdd, 0x08,
	0xca, 0x6f, 0x36, 0xe3, 0xdd, 0xa6, 0xe6, 0x62, 0x9d, 0x99, 0x67, 0xf0, 0x4f, 0x08, 0x16, 0xc7,
	0xbe, 0x0d, 0xb0, 0x96, 0xd7, 0xf2, 0x07, 0x8e, 0x71, 0xaf, 0xb1, 0x7d, 0x0e, 0xeb, 0x58, 0xc2,
	0x1a, 0xd1, 0xe4, 0x7a, 0xb0, 0xca, 0x62, 0xde, 0x78, 0x4b, 0x93, 0xac, 0x51, 0x3c, 0x3d, 0xf1,
	0x8d, 0x32, 0xda, 0x3b, 0xf8, 0x72, 0xb6, 0xfb, 0xb3, 0x9f, 0x1d, 0xac, 0x07, 0x3e, 0xe3, 0x47,
	0xc6, 0x5d, 0xdd, 0xf4, 0x47, 0x03, 0xfd, 0x8a, 0x00, 0x97, 0xb5, 0x2b, 0xbe, 0xaf, 0x89, 0xbd,
	0xbc, 0x94, 0x8d, 0x8d, 0x69, 0x5c, 0xe4, 0xf8, 0x7e, 0x43, 0x70, 0x51, 0x21, 0x10, 0xf1, 0x86,
	0x6e, 0xd2, 0x0a, 0x84, 0x9b, 0x53, 0xf9, 0xc8, 0x21, 0xfe, 0x31, 0xfc, 0x55, 0x60, 0x6c, 0x4b,
	0xe3, 0x07, 0x9a, 0x1c, 0xa8, 0x2f, 0x16, 0xe3, 0xfd, 0x69, 0xdd, 0x8c, 0x8e, 0x1f, 0x2e, 0x2b,
	0x26, 0xac, 0x5b, 0x2b, 0x85, 0xda, 0x9a, 0xaa, 0xdd, 0xff, 0x91, 0xba, 0xba, 0xf2, 0x16, 0xc0,
	0x0f, 0x75, 0xbc, 0x4f, 0xba, 0x4c, 0x8c, 0x47, 0x33, 0xf2, 0x96, 0x27, 0xb0, 0x07, 0x30, 0xbc,
	0x8e, 0x71, 0xed, 0x89, 0x2c, 0x5d, 0xe1, 0x86, 0x42, 0xe0, 0x99, 0x67, 0xb0, 0x0f, 0xb8, 0x7c,
	0x2f, 0xd7, 0x1f, 0xd2, 0xca, 0x3b, 0xbd, 0x22, 0xdc, 0x63, 0x78, 0x51, 0xa5, 0xf7, 0xf0, 0xa6,
	0x76, 0x5e, 0x8a, 0xa9, 0x53, 0x87, 0x8c, 0xe1, 0x92, 0x52, 0xe2, 0xe1, 0x2d, 0xbd, 0x98, 0x15,
	0xa3, 0xae, 0x0e, 0x7a, 0x04, 0xcb, 0x55, 0x9a, 0x0e, 0x7f, 0xa0, 0x9d, 0x6b, 0xc5, 0xf0, 0xaa,
	0x43, 0x7f, 0x9f, 0xeb, 0xc9, 0xea, 0x9e, 0xdf, 0xd6, 0x83, 0x30, 0xb1, 0xeb, 0xd5, 0x48, 0xf6,
	0x00, 0x86, 0xf2, 0xa7, 0x7e, 0xeb, 0x96, 0x24, 0x53, 0x75, 0xeb, 0x96, 0x75, 0x50, 0xfd, 0xd6,
	0xad, 0xd4, 0x50, 0xea, 0x70, 0xfb, 0x73, 0xe9, 0xe5, 0xf8, 0xc6, 0x93, 0x00, 0x00, 0x00, 0xff,
	0xff, 0x05, 0xfd, 0xd2, 0x6e, 0x0f, 0x18, 0x00, 0x00,
}


text:
/*
    Plugin-SDK (Grand Theft Auto 2) header file
    Authors: GTA Community. See more here
    https://github.com/DK22Pac/plugin-sdk
    Do not delete this comment block. Respect others' work!
*/

#pragma once
#include "PluginBase.h"

typedef void* HSTREAM;
typedef unsigned int HPROVIDER;
typedef void* H3DPOBJECT;
typedef H3DPOBJECT H3DSAMPLE;
typedef void* HSAMPLE;
typedef void* HDIGDRIVER;

struct tSample {
    int offset;
    unsigned int size;
    int frequency;
    int field_C;
    int loopStart;
    int loopEnd;
};

class cSampleManager {
public:
    HDIGDRIVER m_pDig;
    char field_4;
    char m_szCDRomRootPath[80];
    bool m_bInitialised;
    short pad;
    HSAMPLE m_hSamples[16];
    HSAMPLE m_hSample;
    HSTREAM m_hStreams[2];
    char field_A4;
    char field_A5;
    char field_A6;
    char field_A7;
    tSample m_aSamples[320];
    void* field_1EA8;
    void* field_1EAC;
    unsigned char m_nNumberOfSamples;
    unsigned char field_1EB1;
    unsigned char field_1EB2;
    char field_1EB3;
    HPROVIDER m_aProvider[256];
    char* m_szStr[256];
    HPROVIDER field_26B4;
    int m_nUsingEAX;
    int field_26BC;
    int m_n3dProvider;
    H3DSAMPLE m_a3dSamples[16];
    float field_2704;
    float field_2708;
    float field_270C;
    int field_2710;
    char field_2714;
    char field_2715;
    char field_2716;
    char field_2717;

public:
    void PlayVocal(int stream, int vocal, bool append);
    void CloseStream(int stream);
    void SetStreamVolume(int stream, unsigned char volume);
    void PlaySample(int sample);
    void SetSampleVolume(unsigned char volume);
    void PlayFrontendTrack(unsigned int id);
    void StopFrontendTrack();
    bool IsFrontendTrackPlaying();
    bool IsSampleNotPlaying();
};

VALIDATE_SIZE(cSampleManager, 0x2718);

extern cSampleManager& SampleManager;

license: Zlib

gha_license_id: Zlib

extension: h


text:
if (NOT FTXUI_BUILD_TESTS_FUZZER)
  return()
endif()

set(CMAKE_C_COMPILER clang)
set(CMAKE_CXX_COMPILER clang++)

function(fuzz source)
  set(name "ftxui-${source}")
  add_executable(${name}
    src/ftxui/component/${source}.cpp
  )
  target_include_directories(${name} PRIVATE src)
  target_link_libraries(${name} PRIVATE component)
  target_compile_options(${name} PRIVATE -fsanitize=fuzzer,address)
  target_link_libraries(${name} PRIVATE -fsanitize=fuzzer,address)
  target_compile_features(${name} PRIVATE cxx_std_17)
endfunction(fuzz)

fuzz(terminal_input_parser_test_fuzzer)
fuzz(component_fuzzer)

repository: ArthurSonzogni/FTXUI

repo_name: ArthurSonzogni/FTXUI

branch_name: refs/heads/main

extension: cmake


text:
# - Fixes imported target for yaml-cpp
# For some reason yaml-cpp does not have include directories in its imported
# target. Add them to the target, if not already set.
IF(TARGET yaml-cpp)
    GET_TARGET_PROPERTY(current_property yaml-cpp INTERFACE_INCLUDE_DIRECTORIES)
    IF(NOT current_property)
        SET_TARGET_PROPERTIES(yaml-cpp PROPERTIES INTERFACE_INCLUDE_DIRECTORIES
            "${YAML_CPP_INCLUDE_DIR}")
    ENDIF()
ENDIF()

repository: wavelab/libwave

repo_name: wavelab/libwave