| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // source: go.chromium.org/luci/machine-db/api/crimson/v1/crimson.proto |
| |
| package crimson |
| |
| import prpc "go.chromium.org/luci/grpc/prpc" |
| |
| import ( |
| context "context" |
| fmt "fmt" |
| proto "github.com/golang/protobuf/proto" |
| empty "github.com/golang/protobuf/ptypes/empty" |
| grpc "google.golang.org/grpc" |
| math "math" |
| ) |
| |
| // 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.ProtoPackageIsVersion3 // please upgrade the proto package |
| |
| func init() { |
| proto.RegisterFile("go.chromium.org/luci/machine-db/api/crimson/v1/crimson.proto", fileDescriptor_46e41eaf4c273b9a) |
| } |
| |
| var fileDescriptor_46e41eaf4c273b9a = []byte{ |
| // 710 bytes of a gzipped FileDescriptorProto |
| 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x55, 0xdd, 0x4f, 0xdb, 0x3e, |
| 0x14, 0x7d, 0xfb, 0x41, 0x2f, 0xf4, 0xb7, 0xcd, 0xd2, 0xbe, 0x0a, 0xec, 0x83, 0xf7, 0x25, 0x62, |
| 0x43, 0x62, 0x9b, 0x18, 0x2b, 0x4b, 0x87, 0x40, 0x90, 0x82, 0xca, 0xd6, 0x87, 0xbd, 0xa0, 0x90, |
| 0x9a, 0x36, 0x22, 0x89, 0xb3, 0x38, 0xed, 0xc4, 0x7f, 0xbe, 0xc7, 0xc9, 0xb1, 0x6f, 0x1a, 0x67, |
| 0xce, 0x50, 0xf2, 0xd6, 0x9e, 0x73, 0xcf, 0xb9, 0x1f, 0xb9, 0xb6, 0x61, 0x7f, 0xca, 0x2c, 0x7f, |
| 0x96, 0xb2, 0x28, 0x98, 0x47, 0x16, 0x4b, 0xa7, 0x76, 0x38, 0xf7, 0x03, 0x3b, 0xf2, 0xfc, 0x59, |
| 0x10, 0xd3, 0x37, 0x93, 0x6b, 0xdb, 0x4b, 0x02, 0xdb, 0x4f, 0x83, 0x88, 0xb3, 0xd8, 0x5e, 0xec, |
| 0xe0, 0x4f, 0x2b, 0x49, 0x59, 0xc6, 0xc8, 0x8a, 0xfa, 0xdb, 0xdb, 0x98, 0x32, 0x36, 0x0d, 0xa9, |
| 0x9d, 0xc3, 0xd7, 0xf3, 0x1b, 0x9b, 0x46, 0x49, 0x76, 0x27, 0xa3, 0x7a, 0xfd, 0x86, 0x39, 0x26, |
| 0x5e, 0xe6, 0xf9, 0x34, 0xce, 0x68, 0xca, 0x95, 0xc3, 0xc7, 0xa6, 0x0e, 0xa9, 0xe7, 0xb7, 0xd5, |
| 0xce, 0x18, 0xcf, 0x50, 0xfb, 0xbe, 0xa1, 0x36, 0x48, 0x50, 0xf9, 0xa1, 0xa1, 0xf2, 0x76, 0x11, |
| 0xa1, 0xf4, 0x53, 0x43, 0xa9, 0x62, 0xda, 0x66, 0x8e, 0x03, 0xbf, 0xad, 0x94, 0xf1, 0x22, 0xab, |
| 0xd3, 0x50, 0x9a, 0xcc, 0xee, 0x78, 0xe0, 0x7b, 0xe1, 0x55, 0x79, 0xdc, 0x07, 0x4d, 0x4d, 0x42, |
| 0x2f, 0xbb, 0x61, 0x69, 0xd4, 0xf6, 0x53, 0xa7, 0x9e, 0x7f, 0xdb, 0x76, 0xea, 0xfc, 0x57, 0x90, |
| 0xf9, 0x33, 0xda, 0x36, 0xf5, 0x22, 0xf4, 0xe2, 0xb6, 0xa9, 0x17, 0xd1, 0x15, 0x0f, 0x59, 0xeb, |
| 0x25, 0x2d, 0x36, 0xed, 0xed, 0xef, 0xff, 0x61, 0xc5, 0x91, 0x04, 0xf9, 0x06, 0x0f, 0xce, 0x02, |
| 0x9e, 0x0d, 0x96, 0x67, 0x8f, 0xbc, 0xb4, 0xf0, 0xb4, 0x57, 0x98, 0x11, 0xfd, 0x39, 0xa7, 0x3c, |
| 0xeb, 0xbd, 0xaa, 0x0f, 0xe0, 0x09, 0x8b, 0x39, 0x25, 0x03, 0x58, 0x13, 0xd4, 0x51, 0x4a, 0xe9, |
| 0xc9, 0x05, 0x27, 0x1b, 0x9a, 0x40, 0xa1, 0xe8, 0xf6, 0x4c, 0x23, 0x73, 0x42, 0xb9, 0x7c, 0x86, |
| 0x55, 0x01, 0x9d, 0x8e, 0x5d, 0x4e, 0xf4, 0x28, 0x01, 0xa1, 0xfe, 0xb9, 0x81, 0xd1, 0x0d, 0xce, |
| 0x2f, 0x69, 0xd5, 0x40, 0x40, 0x66, 0x03, 0xc9, 0x28, 0x83, 0x21, 0x74, 0x05, 0x76, 0x81, 0x0b, |
| 0x47, 0xb6, 0xb4, 0xd8, 0x02, 0x47, 0xab, 0x17, 0x75, 0xb4, 0xf2, 0xfb, 0x02, 0x1d, 0x41, 0x8c, |
| 0xc4, 0x02, 0x12, 0x3d, 0x6f, 0x8e, 0xa1, 0x4f, 0xcf, 0x44, 0x29, 0x8f, 0x53, 0x58, 0x17, 0xe0, |
| 0xa5, 0x5a, 0x44, 0xb2, 0xa9, 0xc5, 0x22, 0x8c, 0x4e, 0x5b, 0x35, 0xac, 0x5e, 0xd0, 0xf8, 0xec, |
| 0x70, 0x58, 0x2d, 0x28, 0xc7, 0xcc, 0x05, 0x29, 0x4a, 0x79, 0xf4, 0xa1, 0xeb, 0xa4, 0xd4, 0xcb, |
| 0xa8, 0x2b, 0x77, 0xaf, 0x34, 0x24, 0x0d, 0x47, 0xaf, 0x87, 0x05, 0x8d, 0x82, 0x23, 0xe8, 0x0e, |
| 0x68, 0x48, 0x4d, 0x0e, 0x1a, 0x8e, 0x0e, 0x4f, 0x2c, 0xf9, 0xee, 0x58, 0xf8, 0xee, 0x58, 0x5f, |
| 0xc5, 0xbb, 0x83, 0xa3, 0x51, 0xd1, 0xd5, 0xd1, 0x20, 0x6c, 0x1e, 0xcd, 0x92, 0x5d, 0xb6, 0x35, |
| 0xa2, 0xb1, 0x17, 0x19, 0x8a, 0xd2, 0xf0, 0xfa, 0xb6, 0xfa, 0xd0, 0xfd, 0x9e, 0x4c, 0x8c, 0x83, |
| 0xd1, 0xf0, 0x7a, 0x87, 0x5d, 0xe8, 0xc8, 0x11, 0x0e, 0x4f, 0x9c, 0xd2, 0xe7, 0x29, 0x30, 0x54, |
| 0xae, 0x17, 0x94, 0x08, 0x3c, 0x80, 0x8e, 0x1c, 0x9b, 0xae, 0x2a, 0xb0, 0xfb, 0xc6, 0xa8, 0x8e, |
| 0xcd, 0xf0, 0xc4, 0xa9, 0x1e, 0x1b, 0x01, 0x99, 0x8f, 0x8d, 0x64, 0xd4, 0xe8, 0x76, 0xa1, 0x23, |
| 0x1b, 0xd4, 0x0b, 0x28, 0x30, 0x73, 0xd9, 0x7b, 0x00, 0xb2, 0xb1, 0xc1, 0xe8, 0xd0, 0x21, 0xbd, |
| 0x4a, 0xb7, 0x02, 0x44, 0x5d, 0x77, 0xd9, 0x93, 0x08, 0x55, 0x4b, 0x2c, 0x7e, 0x57, 0x97, 0x38, |
| 0xc7, 0xcc, 0x4b, 0xac, 0x28, 0x55, 0xf2, 0x1e, 0x80, 0x2c, 0xaf, 0x92, 0x7c, 0x09, 0xd6, 0x24, |
| 0x3f, 0x07, 0x22, 0x0b, 0xbc, 0x50, 0x4f, 0xdb, 0x31, 0xe3, 0x19, 0xd9, 0xae, 0x54, 0x5f, 0x26, |
| 0xd1, 0xe8, 0x71, 0x11, 0xa3, 0x49, 0x7f, 0xc0, 0xa3, 0xfc, 0xf2, 0x28, 0x61, 0x9c, 0xbc, 0xd6, |
| 0x2f, 0x96, 0x32, 0x87, 0x76, 0xdb, 0xff, 0x0a, 0x51, 0x5d, 0x9e, 0x03, 0x91, 0x0d, 0xd5, 0x14, |
| 0xfb, 0x37, 0x79, 0x4f, 0xb1, 0xc7, 0xb0, 0x76, 0x14, 0xc4, 0x93, 0xb1, 0x7b, 0x29, 0x5e, 0xa6, |
| 0xd2, 0x45, 0x5f, 0x42, 0xd1, 0x62, 0xd3, 0x4c, 0xaa, 0xd2, 0x76, 0x60, 0x55, 0x8e, 0x6a, 0xec, |
| 0x96, 0x96, 0x0e, 0x21, 0xf4, 0x58, 0x2b, 0x98, 0xb1, 0x4b, 0xf6, 0x61, 0x25, 0xbf, 0x8d, 0x5c, |
| 0x4e, 0x9e, 0xea, 0xf7, 0x93, 0x5b, 0xf3, 0xba, 0x94, 0x1f, 0x87, 0x1d, 0x58, 0x95, 0xed, 0x6a, |
| 0x09, 0x11, 0x32, 0x26, 0xec, 0x03, 0xc8, 0x43, 0x94, 0xf7, 0xde, 0xab, 0x9c, 0xac, 0xf2, 0xb8, |
| 0x6a, 0x8e, 0xd6, 0xf5, 0x7f, 0xf9, 0xff, 0x77, 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x9d, 0x90, |
| 0xdc, 0x27, 0x80, 0x0b, 0x00, 0x00, |
| } |
| |
| // 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 |
| |
| // CrimsonClient is the client API for Crimson service. |
| // |
| // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. |
| type CrimsonClient interface { |
| // Lists datacenters in the database. |
| ListDatacenters(ctx context.Context, in *ListDatacentersRequest, opts ...grpc.CallOption) (*ListDatacentersResponse, error) |
| // Lists free IP addresses in the database. |
| ListFreeIPs(ctx context.Context, in *ListFreeIPsRequest, opts ...grpc.CallOption) (*ListIPsResponse, error) |
| // Lists KVMs in the database. |
| ListKVMs(ctx context.Context, in *ListKVMsRequest, opts ...grpc.CallOption) (*ListKVMsResponse, error) |
| // Lists operating systems in the database. |
| ListOSes(ctx context.Context, in *ListOSesRequest, opts ...grpc.CallOption) (*ListOSesResponse, error) |
| // Lists platforms in the database. |
| ListPlatforms(ctx context.Context, in *ListPlatformsRequest, opts ...grpc.CallOption) (*ListPlatformsResponse, error) |
| // Lists racks in the database. |
| ListRacks(ctx context.Context, in *ListRacksRequest, opts ...grpc.CallOption) (*ListRacksResponse, error) |
| // Lists switches in the database. |
| ListSwitches(ctx context.Context, in *ListSwitchesRequest, opts ...grpc.CallOption) (*ListSwitchesResponse, error) |
| // Lists VLANs in the database. |
| ListVLANs(ctx context.Context, in *ListVLANsRequest, opts ...grpc.CallOption) (*ListVLANsResponse, error) |
| // Creates a new machine in the database. |
| CreateMachine(ctx context.Context, in *CreateMachineRequest, opts ...grpc.CallOption) (*Machine, error) |
| // Deletes a machine from the database. |
| DeleteMachine(ctx context.Context, in *DeleteMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error) |
| // Lists machines in the database. |
| ListMachines(ctx context.Context, in *ListMachinesRequest, opts ...grpc.CallOption) (*ListMachinesResponse, error) |
| // Renames a machine in the database. |
| RenameMachine(ctx context.Context, in *RenameMachineRequest, opts ...grpc.CallOption) (*Machine, error) |
| // Updates a machine in the database. |
| UpdateMachine(ctx context.Context, in *UpdateMachineRequest, opts ...grpc.CallOption) (*Machine, error) |
| // Creates a new NIC in the database. |
| CreateNIC(ctx context.Context, in *CreateNICRequest, opts ...grpc.CallOption) (*NIC, error) |
| // Deletes a NIC from the database. |
| DeleteNIC(ctx context.Context, in *DeleteNICRequest, opts ...grpc.CallOption) (*empty.Empty, error) |
| // Lists NICs in the database. |
| ListNICs(ctx context.Context, in *ListNICsRequest, opts ...grpc.CallOption) (*ListNICsResponse, error) |
| // Updates a NIC in the database. |
| UpdateNIC(ctx context.Context, in *UpdateNICRequest, opts ...grpc.CallOption) (*NIC, error) |
| // Creates a new DRAC in the database. |
| CreateDRAC(ctx context.Context, in *CreateDRACRequest, opts ...grpc.CallOption) (*DRAC, error) |
| // Lists DRACs in the database. |
| ListDRACs(ctx context.Context, in *ListDRACsRequest, opts ...grpc.CallOption) (*ListDRACsResponse, error) |
| // Updates a DRAC in the database. |
| UpdateDRAC(ctx context.Context, in *UpdateDRACRequest, opts ...grpc.CallOption) (*DRAC, error) |
| // Creates a new physical host in the database. |
| CreatePhysicalHost(ctx context.Context, in *CreatePhysicalHostRequest, opts ...grpc.CallOption) (*PhysicalHost, error) |
| // Lists physical hosts in the database. |
| ListPhysicalHosts(ctx context.Context, in *ListPhysicalHostsRequest, opts ...grpc.CallOption) (*ListPhysicalHostsResponse, error) |
| // Updates a physical host in the database. |
| UpdatePhysicalHost(ctx context.Context, in *UpdatePhysicalHostRequest, opts ...grpc.CallOption) (*PhysicalHost, error) |
| // Finds available VM slots in the database. |
| FindVMSlots(ctx context.Context, in *FindVMSlotsRequest, opts ...grpc.CallOption) (*FindVMSlotsResponse, error) |
| // Creates a new VM in the database. |
| CreateVM(ctx context.Context, in *CreateVMRequest, opts ...grpc.CallOption) (*VM, error) |
| // Lists VMs in the database. |
| ListVMs(ctx context.Context, in *ListVMsRequest, opts ...grpc.CallOption) (*ListVMsResponse, error) |
| // Updates a VM in the database. |
| UpdateVM(ctx context.Context, in *UpdateVMRequest, opts ...grpc.CallOption) (*VM, error) |
| // Deletes a physical or virtual host from the database. |
| DeleteHost(ctx context.Context, in *DeleteHostRequest, opts ...grpc.CallOption) (*empty.Empty, error) |
| } |
| type crimsonPRPCClient struct { |
| client *prpc.Client |
| } |
| |
| func NewCrimsonPRPCClient(client *prpc.Client) CrimsonClient { |
| return &crimsonPRPCClient{client} |
| } |
| |
| func (c *crimsonPRPCClient) ListDatacenters(ctx context.Context, in *ListDatacentersRequest, opts ...grpc.CallOption) (*ListDatacentersResponse, error) { |
| out := new(ListDatacentersResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListDatacenters", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListFreeIPs(ctx context.Context, in *ListFreeIPsRequest, opts ...grpc.CallOption) (*ListIPsResponse, error) { |
| out := new(ListIPsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListFreeIPs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListKVMs(ctx context.Context, in *ListKVMsRequest, opts ...grpc.CallOption) (*ListKVMsResponse, error) { |
| out := new(ListKVMsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListKVMs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListOSes(ctx context.Context, in *ListOSesRequest, opts ...grpc.CallOption) (*ListOSesResponse, error) { |
| out := new(ListOSesResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListOSes", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListPlatforms(ctx context.Context, in *ListPlatformsRequest, opts ...grpc.CallOption) (*ListPlatformsResponse, error) { |
| out := new(ListPlatformsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListPlatforms", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListRacks(ctx context.Context, in *ListRacksRequest, opts ...grpc.CallOption) (*ListRacksResponse, error) { |
| out := new(ListRacksResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListRacks", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListSwitches(ctx context.Context, in *ListSwitchesRequest, opts ...grpc.CallOption) (*ListSwitchesResponse, error) { |
| out := new(ListSwitchesResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListSwitches", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListVLANs(ctx context.Context, in *ListVLANsRequest, opts ...grpc.CallOption) (*ListVLANsResponse, error) { |
| out := new(ListVLANsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListVLANs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) CreateMachine(ctx context.Context, in *CreateMachineRequest, opts ...grpc.CallOption) (*Machine, error) { |
| out := new(Machine) |
| err := c.client.Call(ctx, "crimson.Crimson", "CreateMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) DeleteMachine(ctx context.Context, in *DeleteMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error) { |
| out := new(empty.Empty) |
| err := c.client.Call(ctx, "crimson.Crimson", "DeleteMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListMachines(ctx context.Context, in *ListMachinesRequest, opts ...grpc.CallOption) (*ListMachinesResponse, error) { |
| out := new(ListMachinesResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListMachines", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) RenameMachine(ctx context.Context, in *RenameMachineRequest, opts ...grpc.CallOption) (*Machine, error) { |
| out := new(Machine) |
| err := c.client.Call(ctx, "crimson.Crimson", "RenameMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) UpdateMachine(ctx context.Context, in *UpdateMachineRequest, opts ...grpc.CallOption) (*Machine, error) { |
| out := new(Machine) |
| err := c.client.Call(ctx, "crimson.Crimson", "UpdateMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) CreateNIC(ctx context.Context, in *CreateNICRequest, opts ...grpc.CallOption) (*NIC, error) { |
| out := new(NIC) |
| err := c.client.Call(ctx, "crimson.Crimson", "CreateNIC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) DeleteNIC(ctx context.Context, in *DeleteNICRequest, opts ...grpc.CallOption) (*empty.Empty, error) { |
| out := new(empty.Empty) |
| err := c.client.Call(ctx, "crimson.Crimson", "DeleteNIC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListNICs(ctx context.Context, in *ListNICsRequest, opts ...grpc.CallOption) (*ListNICsResponse, error) { |
| out := new(ListNICsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListNICs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) UpdateNIC(ctx context.Context, in *UpdateNICRequest, opts ...grpc.CallOption) (*NIC, error) { |
| out := new(NIC) |
| err := c.client.Call(ctx, "crimson.Crimson", "UpdateNIC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) CreateDRAC(ctx context.Context, in *CreateDRACRequest, opts ...grpc.CallOption) (*DRAC, error) { |
| out := new(DRAC) |
| err := c.client.Call(ctx, "crimson.Crimson", "CreateDRAC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListDRACs(ctx context.Context, in *ListDRACsRequest, opts ...grpc.CallOption) (*ListDRACsResponse, error) { |
| out := new(ListDRACsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListDRACs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) UpdateDRAC(ctx context.Context, in *UpdateDRACRequest, opts ...grpc.CallOption) (*DRAC, error) { |
| out := new(DRAC) |
| err := c.client.Call(ctx, "crimson.Crimson", "UpdateDRAC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) CreatePhysicalHost(ctx context.Context, in *CreatePhysicalHostRequest, opts ...grpc.CallOption) (*PhysicalHost, error) { |
| out := new(PhysicalHost) |
| err := c.client.Call(ctx, "crimson.Crimson", "CreatePhysicalHost", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListPhysicalHosts(ctx context.Context, in *ListPhysicalHostsRequest, opts ...grpc.CallOption) (*ListPhysicalHostsResponse, error) { |
| out := new(ListPhysicalHostsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListPhysicalHosts", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) UpdatePhysicalHost(ctx context.Context, in *UpdatePhysicalHostRequest, opts ...grpc.CallOption) (*PhysicalHost, error) { |
| out := new(PhysicalHost) |
| err := c.client.Call(ctx, "crimson.Crimson", "UpdatePhysicalHost", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) FindVMSlots(ctx context.Context, in *FindVMSlotsRequest, opts ...grpc.CallOption) (*FindVMSlotsResponse, error) { |
| out := new(FindVMSlotsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "FindVMSlots", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) CreateVM(ctx context.Context, in *CreateVMRequest, opts ...grpc.CallOption) (*VM, error) { |
| out := new(VM) |
| err := c.client.Call(ctx, "crimson.Crimson", "CreateVM", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) ListVMs(ctx context.Context, in *ListVMsRequest, opts ...grpc.CallOption) (*ListVMsResponse, error) { |
| out := new(ListVMsResponse) |
| err := c.client.Call(ctx, "crimson.Crimson", "ListVMs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) UpdateVM(ctx context.Context, in *UpdateVMRequest, opts ...grpc.CallOption) (*VM, error) { |
| out := new(VM) |
| err := c.client.Call(ctx, "crimson.Crimson", "UpdateVM", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonPRPCClient) DeleteHost(ctx context.Context, in *DeleteHostRequest, opts ...grpc.CallOption) (*empty.Empty, error) { |
| out := new(empty.Empty) |
| err := c.client.Call(ctx, "crimson.Crimson", "DeleteHost", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| type crimsonClient struct { |
| cc *grpc.ClientConn |
| } |
| |
| func NewCrimsonClient(cc *grpc.ClientConn) CrimsonClient { |
| return &crimsonClient{cc} |
| } |
| |
| func (c *crimsonClient) ListDatacenters(ctx context.Context, in *ListDatacentersRequest, opts ...grpc.CallOption) (*ListDatacentersResponse, error) { |
| out := new(ListDatacentersResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListDatacenters", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListFreeIPs(ctx context.Context, in *ListFreeIPsRequest, opts ...grpc.CallOption) (*ListIPsResponse, error) { |
| out := new(ListIPsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListFreeIPs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListKVMs(ctx context.Context, in *ListKVMsRequest, opts ...grpc.CallOption) (*ListKVMsResponse, error) { |
| out := new(ListKVMsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListKVMs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListOSes(ctx context.Context, in *ListOSesRequest, opts ...grpc.CallOption) (*ListOSesResponse, error) { |
| out := new(ListOSesResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListOSes", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListPlatforms(ctx context.Context, in *ListPlatformsRequest, opts ...grpc.CallOption) (*ListPlatformsResponse, error) { |
| out := new(ListPlatformsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListPlatforms", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListRacks(ctx context.Context, in *ListRacksRequest, opts ...grpc.CallOption) (*ListRacksResponse, error) { |
| out := new(ListRacksResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListRacks", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListSwitches(ctx context.Context, in *ListSwitchesRequest, opts ...grpc.CallOption) (*ListSwitchesResponse, error) { |
| out := new(ListSwitchesResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListSwitches", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListVLANs(ctx context.Context, in *ListVLANsRequest, opts ...grpc.CallOption) (*ListVLANsResponse, error) { |
| out := new(ListVLANsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListVLANs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) CreateMachine(ctx context.Context, in *CreateMachineRequest, opts ...grpc.CallOption) (*Machine, error) { |
| out := new(Machine) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/CreateMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) DeleteMachine(ctx context.Context, in *DeleteMachineRequest, opts ...grpc.CallOption) (*empty.Empty, error) { |
| out := new(empty.Empty) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/DeleteMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListMachines(ctx context.Context, in *ListMachinesRequest, opts ...grpc.CallOption) (*ListMachinesResponse, error) { |
| out := new(ListMachinesResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListMachines", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) RenameMachine(ctx context.Context, in *RenameMachineRequest, opts ...grpc.CallOption) (*Machine, error) { |
| out := new(Machine) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/RenameMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) UpdateMachine(ctx context.Context, in *UpdateMachineRequest, opts ...grpc.CallOption) (*Machine, error) { |
| out := new(Machine) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/UpdateMachine", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) CreateNIC(ctx context.Context, in *CreateNICRequest, opts ...grpc.CallOption) (*NIC, error) { |
| out := new(NIC) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/CreateNIC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) DeleteNIC(ctx context.Context, in *DeleteNICRequest, opts ...grpc.CallOption) (*empty.Empty, error) { |
| out := new(empty.Empty) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/DeleteNIC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListNICs(ctx context.Context, in *ListNICsRequest, opts ...grpc.CallOption) (*ListNICsResponse, error) { |
| out := new(ListNICsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListNICs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) UpdateNIC(ctx context.Context, in *UpdateNICRequest, opts ...grpc.CallOption) (*NIC, error) { |
| out := new(NIC) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/UpdateNIC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) CreateDRAC(ctx context.Context, in *CreateDRACRequest, opts ...grpc.CallOption) (*DRAC, error) { |
| out := new(DRAC) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/CreateDRAC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListDRACs(ctx context.Context, in *ListDRACsRequest, opts ...grpc.CallOption) (*ListDRACsResponse, error) { |
| out := new(ListDRACsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListDRACs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) UpdateDRAC(ctx context.Context, in *UpdateDRACRequest, opts ...grpc.CallOption) (*DRAC, error) { |
| out := new(DRAC) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/UpdateDRAC", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) CreatePhysicalHost(ctx context.Context, in *CreatePhysicalHostRequest, opts ...grpc.CallOption) (*PhysicalHost, error) { |
| out := new(PhysicalHost) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/CreatePhysicalHost", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListPhysicalHosts(ctx context.Context, in *ListPhysicalHostsRequest, opts ...grpc.CallOption) (*ListPhysicalHostsResponse, error) { |
| out := new(ListPhysicalHostsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListPhysicalHosts", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) UpdatePhysicalHost(ctx context.Context, in *UpdatePhysicalHostRequest, opts ...grpc.CallOption) (*PhysicalHost, error) { |
| out := new(PhysicalHost) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/UpdatePhysicalHost", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) FindVMSlots(ctx context.Context, in *FindVMSlotsRequest, opts ...grpc.CallOption) (*FindVMSlotsResponse, error) { |
| out := new(FindVMSlotsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/FindVMSlots", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) CreateVM(ctx context.Context, in *CreateVMRequest, opts ...grpc.CallOption) (*VM, error) { |
| out := new(VM) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/CreateVM", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) ListVMs(ctx context.Context, in *ListVMsRequest, opts ...grpc.CallOption) (*ListVMsResponse, error) { |
| out := new(ListVMsResponse) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/ListVMs", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) UpdateVM(ctx context.Context, in *UpdateVMRequest, opts ...grpc.CallOption) (*VM, error) { |
| out := new(VM) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/UpdateVM", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *crimsonClient) DeleteHost(ctx context.Context, in *DeleteHostRequest, opts ...grpc.CallOption) (*empty.Empty, error) { |
| out := new(empty.Empty) |
| err := c.cc.Invoke(ctx, "/crimson.Crimson/DeleteHost", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| // CrimsonServer is the server API for Crimson service. |
| type CrimsonServer interface { |
| // Lists datacenters in the database. |
| ListDatacenters(context.Context, *ListDatacentersRequest) (*ListDatacentersResponse, error) |
| // Lists free IP addresses in the database. |
| ListFreeIPs(context.Context, *ListFreeIPsRequest) (*ListIPsResponse, error) |
| // Lists KVMs in the database. |
| ListKVMs(context.Context, *ListKVMsRequest) (*ListKVMsResponse, error) |
| // Lists operating systems in the database. |
| ListOSes(context.Context, *ListOSesRequest) (*ListOSesResponse, error) |
| // Lists platforms in the database. |
| ListPlatforms(context.Context, *ListPlatformsRequest) (*ListPlatformsResponse, error) |
| // Lists racks in the database. |
| ListRacks(context.Context, *ListRacksRequest) (*ListRacksResponse, error) |
| // Lists switches in the database. |
| ListSwitches(context.Context, *ListSwitchesRequest) (*ListSwitchesResponse, error) |
| // Lists VLANs in the database. |
| ListVLANs(context.Context, *ListVLANsRequest) (*ListVLANsResponse, error) |
| // Creates a new machine in the database. |
| CreateMachine(context.Context, *CreateMachineRequest) (*Machine, error) |
| // Deletes a machine from the database. |
| DeleteMachine(context.Context, *DeleteMachineRequest) (*empty.Empty, error) |
| // Lists machines in the database. |
| ListMachines(context.Context, *ListMachinesRequest) (*ListMachinesResponse, error) |
| // Renames a machine in the database. |
| RenameMachine(context.Context, *RenameMachineRequest) (*Machine, error) |
| // Updates a machine in the database. |
| UpdateMachine(context.Context, *UpdateMachineRequest) (*Machine, error) |
| // Creates a new NIC in the database. |
| CreateNIC(context.Context, *CreateNICRequest) (*NIC, error) |
| // Deletes a NIC from the database. |
| DeleteNIC(context.Context, *DeleteNICRequest) (*empty.Empty, error) |
| // Lists NICs in the database. |
| ListNICs(context.Context, *ListNICsRequest) (*ListNICsResponse, error) |
| // Updates a NIC in the database. |
| UpdateNIC(context.Context, *UpdateNICRequest) (*NIC, error) |
| // Creates a new DRAC in the database. |
| CreateDRAC(context.Context, *CreateDRACRequest) (*DRAC, error) |
| // Lists DRACs in the database. |
| ListDRACs(context.Context, *ListDRACsRequest) (*ListDRACsResponse, error) |
| // Updates a DRAC in the database. |
| UpdateDRAC(context.Context, *UpdateDRACRequest) (*DRAC, error) |
| // Creates a new physical host in the database. |
| CreatePhysicalHost(context.Context, *CreatePhysicalHostRequest) (*PhysicalHost, error) |
| // Lists physical hosts in the database. |
| ListPhysicalHosts(context.Context, *ListPhysicalHostsRequest) (*ListPhysicalHostsResponse, error) |
| // Updates a physical host in the database. |
| UpdatePhysicalHost(context.Context, *UpdatePhysicalHostRequest) (*PhysicalHost, error) |
| // Finds available VM slots in the database. |
| FindVMSlots(context.Context, *FindVMSlotsRequest) (*FindVMSlotsResponse, error) |
| // Creates a new VM in the database. |
| CreateVM(context.Context, *CreateVMRequest) (*VM, error) |
| // Lists VMs in the database. |
| ListVMs(context.Context, *ListVMsRequest) (*ListVMsResponse, error) |
| // Updates a VM in the database. |
| UpdateVM(context.Context, *UpdateVMRequest) (*VM, error) |
| // Deletes a physical or virtual host from the database. |
| DeleteHost(context.Context, *DeleteHostRequest) (*empty.Empty, error) |
| } |
| |
| func RegisterCrimsonServer(s prpc.Registrar, srv CrimsonServer) { |
| s.RegisterService(&_Crimson_serviceDesc, srv) |
| } |
| |
| func _Crimson_ListDatacenters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListDatacentersRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListDatacenters(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListDatacenters", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListDatacenters(ctx, req.(*ListDatacentersRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListFreeIPs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListFreeIPsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListFreeIPs(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListFreeIPs", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListFreeIPs(ctx, req.(*ListFreeIPsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListKVMs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListKVMsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListKVMs(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListKVMs", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListKVMs(ctx, req.(*ListKVMsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListOSes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListOSesRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListOSes(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListOSes", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListOSes(ctx, req.(*ListOSesRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListPlatforms_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListPlatformsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListPlatforms(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListPlatforms", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListPlatforms(ctx, req.(*ListPlatformsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListRacks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListRacksRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListRacks(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListRacks", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListRacks(ctx, req.(*ListRacksRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListSwitches_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListSwitchesRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListSwitches(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListSwitches", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListSwitches(ctx, req.(*ListSwitchesRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListVLANs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListVLANsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListVLANs(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListVLANs", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListVLANs(ctx, req.(*ListVLANsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_CreateMachine_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(CreateMachineRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).CreateMachine(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/CreateMachine", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).CreateMachine(ctx, req.(*CreateMachineRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_DeleteMachine_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(DeleteMachineRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).DeleteMachine(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/DeleteMachine", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).DeleteMachine(ctx, req.(*DeleteMachineRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListMachines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListMachinesRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListMachines(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListMachines", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListMachines(ctx, req.(*ListMachinesRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_RenameMachine_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(RenameMachineRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).RenameMachine(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/RenameMachine", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).RenameMachine(ctx, req.(*RenameMachineRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_UpdateMachine_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(UpdateMachineRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).UpdateMachine(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/UpdateMachine", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).UpdateMachine(ctx, req.(*UpdateMachineRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_CreateNIC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(CreateNICRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).CreateNIC(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/CreateNIC", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).CreateNIC(ctx, req.(*CreateNICRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_DeleteNIC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(DeleteNICRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).DeleteNIC(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/DeleteNIC", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).DeleteNIC(ctx, req.(*DeleteNICRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListNICs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListNICsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListNICs(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListNICs", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListNICs(ctx, req.(*ListNICsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_UpdateNIC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(UpdateNICRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).UpdateNIC(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/UpdateNIC", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).UpdateNIC(ctx, req.(*UpdateNICRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_CreateDRAC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(CreateDRACRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).CreateDRAC(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/CreateDRAC", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).CreateDRAC(ctx, req.(*CreateDRACRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListDRACs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListDRACsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListDRACs(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListDRACs", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListDRACs(ctx, req.(*ListDRACsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_UpdateDRAC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(UpdateDRACRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).UpdateDRAC(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/UpdateDRAC", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).UpdateDRAC(ctx, req.(*UpdateDRACRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_CreatePhysicalHost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(CreatePhysicalHostRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).CreatePhysicalHost(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/CreatePhysicalHost", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).CreatePhysicalHost(ctx, req.(*CreatePhysicalHostRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListPhysicalHosts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListPhysicalHostsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListPhysicalHosts(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListPhysicalHosts", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListPhysicalHosts(ctx, req.(*ListPhysicalHostsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_UpdatePhysicalHost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(UpdatePhysicalHostRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).UpdatePhysicalHost(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/UpdatePhysicalHost", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).UpdatePhysicalHost(ctx, req.(*UpdatePhysicalHostRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_FindVMSlots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(FindVMSlotsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).FindVMSlots(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/FindVMSlots", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).FindVMSlots(ctx, req.(*FindVMSlotsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_CreateVM_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(CreateVMRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).CreateVM(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/CreateVM", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).CreateVM(ctx, req.(*CreateVMRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_ListVMs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(ListVMsRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).ListVMs(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/ListVMs", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).ListVMs(ctx, req.(*ListVMsRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_UpdateVM_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(UpdateVMRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).UpdateVM(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/UpdateVM", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).UpdateVM(ctx, req.(*UpdateVMRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| func _Crimson_DeleteHost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(DeleteHostRequest) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(CrimsonServer).DeleteHost(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/crimson.Crimson/DeleteHost", |
| } |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(CrimsonServer).DeleteHost(ctx, req.(*DeleteHostRequest)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| |
| var _Crimson_serviceDesc = grpc.ServiceDesc{ |
| ServiceName: "crimson.Crimson", |
| HandlerType: (*CrimsonServer)(nil), |
| Methods: []grpc.MethodDesc{ |
| { |
| MethodName: "ListDatacenters", |
| Handler: _Crimson_ListDatacenters_Handler, |
| }, |
| { |
| MethodName: "ListFreeIPs", |
| Handler: _Crimson_ListFreeIPs_Handler, |
| }, |
| { |
| MethodName: "ListKVMs", |
| Handler: _Crimson_ListKVMs_Handler, |
| }, |
| { |
| MethodName: "ListOSes", |
| Handler: _Crimson_ListOSes_Handler, |
| }, |
| { |
| MethodName: "ListPlatforms", |
| Handler: _Crimson_ListPlatforms_Handler, |
| }, |
| { |
| MethodName: "ListRacks", |
| Handler: _Crimson_ListRacks_Handler, |
| }, |
| { |
| MethodName: "ListSwitches", |
| Handler: _Crimson_ListSwitches_Handler, |
| }, |
| { |
| MethodName: "ListVLANs", |
| Handler: _Crimson_ListVLANs_Handler, |
| }, |
| { |
| MethodName: "CreateMachine", |
| Handler: _Crimson_CreateMachine_Handler, |
| }, |
| { |
| MethodName: "DeleteMachine", |
| Handler: _Crimson_DeleteMachine_Handler, |
| }, |
| { |
| MethodName: "ListMachines", |
| Handler: _Crimson_ListMachines_Handler, |
| }, |
| { |
| MethodName: "RenameMachine", |
| Handler: _Crimson_RenameMachine_Handler, |
| }, |
| { |
| MethodName: "UpdateMachine", |
| Handler: _Crimson_UpdateMachine_Handler, |
| }, |
| { |
| MethodName: "CreateNIC", |
| Handler: _Crimson_CreateNIC_Handler, |
| }, |
| { |
| MethodName: "DeleteNIC", |
| Handler: _Crimson_DeleteNIC_Handler, |
| }, |
| { |
| MethodName: "ListNICs", |
| Handler: _Crimson_ListNICs_Handler, |
| }, |
| { |
| MethodName: "UpdateNIC", |
| Handler: _Crimson_UpdateNIC_Handler, |
| }, |
| { |
| MethodName: "CreateDRAC", |
| Handler: _Crimson_CreateDRAC_Handler, |
| }, |
| { |
| MethodName: "ListDRACs", |
| Handler: _Crimson_ListDRACs_Handler, |
| }, |
| { |
| MethodName: "UpdateDRAC", |
| Handler: _Crimson_UpdateDRAC_Handler, |
| }, |
| { |
| MethodName: "CreatePhysicalHost", |
| Handler: _Crimson_CreatePhysicalHost_Handler, |
| }, |
| { |
| MethodName: "ListPhysicalHosts", |
| Handler: _Crimson_ListPhysicalHosts_Handler, |
| }, |
| { |
| MethodName: "UpdatePhysicalHost", |
| Handler: _Crimson_UpdatePhysicalHost_Handler, |
| }, |
| { |
| MethodName: "FindVMSlots", |
| Handler: _Crimson_FindVMSlots_Handler, |
| }, |
| { |
| MethodName: "CreateVM", |
| Handler: _Crimson_CreateVM_Handler, |
| }, |
| { |
| MethodName: "ListVMs", |
| Handler: _Crimson_ListVMs_Handler, |
| }, |
| { |
| MethodName: "UpdateVM", |
| Handler: _Crimson_UpdateVM_Handler, |
| }, |
| { |
| MethodName: "DeleteHost", |
| Handler: _Crimson_DeleteHost_Handler, |
| }, |
| }, |
| Streams: []grpc.StreamDesc{}, |
| Metadata: "go.chromium.org/luci/machine-db/api/crimson/v1/crimson.proto", |
| } |