rpc

package
v0.0.18 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 7, 2020 License: AGPL-3.0 Imports: 35 Imported by: 0

Documentation

Overview

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_mmesh_protobuf_network_v1_rpc_api_proto protoreflect.FileDescriptor
View Source 
var File_mmesh_protobuf_network_v1_rpc_network_proto protoreflect.FileDescriptor
View Source 
var File_mmesh_protobuf_network_v1_rpc_version_proto protoreflect.FileDescriptor

Functions

func RegisterNxAPIHandler 

func RegisterNxAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterNxAPIHandler registers the http handlers for service NxAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterNxAPIHandlerClient 

func RegisterNxAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NxAPIClient) error

RegisterNxAPIHandlerClient registers the http handlers for service NxAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "NxAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "NxAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "NxAPIClient" to call the correct interceptors.

func RegisterNxAPIHandlerFromEndpoint 

func RegisterNxAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterNxAPIHandlerFromEndpoint is same as RegisterNxAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterNxAPIHandlerServer 

func RegisterNxAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NxAPIServer) error

RegisterNxAPIHandlerServer registers the http handlers for service NxAPI to "mux". UnaryRPC :call NxAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterNxAPIServer 

func RegisterNxAPIServer(s *grpc.Server, srv NxAPIServer)

func RegisterNxNetworkServer 

func RegisterNxNetworkServer(s *grpc.Server, srv NxNetworkServer)

func RegisterVersionRPCHandler 

func RegisterVersionRPCHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterVersionRPCHandler registers the http handlers for service VersionRPC to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterVersionRPCHandlerClient 

func RegisterVersionRPCHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VersionRPCClient) error

RegisterVersionRPCHandlerClient registers the http handlers for service VersionRPC to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "VersionRPCClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "VersionRPCClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "VersionRPCClient" to call the correct interceptors.

func RegisterVersionRPCHandlerFromEndpoint 

func RegisterVersionRPCHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterVersionRPCHandlerFromEndpoint is same as RegisterVersionRPCHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterVersionRPCHandlerServer 

func RegisterVersionRPCHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VersionRPCServer) error

RegisterVersionRPCHandlerServer registers the http handlers for service VersionRPC to "mux". UnaryRPC :call VersionRPCServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterVersionRPCServer 

func RegisterVersionRPCServer(s *grpc.Server, srv VersionRPCServer)

Types

type NxAPIClient 

type NxAPIClient interface {
	ListResources(ctx context.Context, in *resource.Resource, opts ...grpc.CallOption) (*resource.Resources, error)
	GetFederation(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*controller.Federation, error)
	ListFederationControllers(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*controller.Controllers, error)
	GetFederationController(ctx context.Context, in *controller.Controller, opts ...grpc.CallOption) (*controller.Controller, error)
	DeleteFederationController(ctx context.Context, in *controller.Controller, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ControllerCapabilities(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*controller.Capabilities, error)
	ExistsCustomer(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ExistsAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ShowUserAccount(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*iam.User, error)
	EditUserAccount(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*iam.User, error)
	UserPasswordReset(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*status.StatusResponse, error)
	NewAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*account.Account, error)
	ListAccounts(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*account.Accounts, error)
	GetAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*blob.Blob, error)
	SetAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*account.Account, error)
	DeleteAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*status.StatusResponse, error)
	EnableAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*account.Account, error)
	DisableAccount(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*account.Account, error)
	ListTenants(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*tenant.Tenants, error)
	GetTenant(ctx context.Context, in *tenant.Tenant, opts ...grpc.CallOption) (*blob.Blob, error)
	SetTenant(ctx context.Context, in *tenant.Tenant, opts ...grpc.CallOption) (*tenant.Tenant, error)
	DeleteTenant(ctx context.Context, in *tenant.Tenant, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListNetworks(ctx context.Context, in *tenant.Tenant, opts ...grpc.CallOption) (*network.Networks, error)
	GetNetwork(ctx context.Context, in *network.Network, opts ...grpc.CallOption) (*blob.Blob, error)
	SetNetwork(ctx context.Context, in *network.Network, opts ...grpc.CallOption) (*network.Network, error)
	DeleteNetwork(ctx context.Context, in *network.Network, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListVRFs(ctx context.Context, in *network.Network, opts ...grpc.CallOption) (*network.VRFs, error)
	GetVRF(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*blob.Blob, error)
	SetVRF(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*network.VRF, error)
	DeleteVRF(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*status.StatusResponse, error)
	GetNetworkPolicy(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*network.Policy, error)
	SetNetworkPolicy(ctx context.Context, in *object.NetworkPolicyConfigRequest, opts ...grpc.CallOption) (*network.Policy, error)
	DeleteNetworkPolicy(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*network.Policy, error)
	ListRoutes(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*routing.RoutingTable, error)
	GenerateNodeConfig(ctx context.Context, in *network.NetworkAgent, opts ...grpc.CallOption) (*network.NodeConfig, error)
	ListNodeMMIDs(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*network.MMIDs, error)
	ListNodes(ctx context.Context, in *network.VRF, opts ...grpc.CallOption) (*network.Nodes, error)
	GetNode(ctx context.Context, in *network.Node, opts ...grpc.CallOption) (*blob.Blob, error)
	// rpc SetNode (network.Node) returns (network.Node) {}
	DeleteNode(ctx context.Context, in *network.Node, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ResetNodeNetworkTraffic(ctx context.Context, in *network.Node, opts ...grpc.CallOption) (*network.Node, error)
	//rpc GetNetworkEndpoint(network.Endpoint) returns (blob.Blob) {}
	DeleteNetworkEndpoint(ctx context.Context, in *network.Endpoint, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListUsers(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*iam.Users, error)
	GetUser(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*blob.Blob, error)
	SetUser(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*iam.User, error)
	DeleteUser(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*status.StatusResponse, error)
	SetUserCredentialsPassword(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*iam.User, error)
	SetUserCredentialsTOTP(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*iam.User, error)
	EnableUser(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*iam.User, error)
	DisableUser(ctx context.Context, in *iam.User, opts ...grpc.CallOption) (*iam.User, error)
	ListSecurityGroups(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*iam.SecurityGroups, error)
	GetSecurityGroup(ctx context.Context, in *iam.SecurityGroup, opts ...grpc.CallOption) (*blob.Blob, error)
	SetSecurityGroup(ctx context.Context, in *iam.SecurityGroup, opts ...grpc.CallOption) (*iam.SecurityGroup, error)
	DeleteSecurityGroup(ctx context.Context, in *iam.SecurityGroup, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListRoles(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*iam.Roles, error)
	GetRole(ctx context.Context, in *iam.Role, opts ...grpc.CallOption) (*blob.Blob, error)
	SetRole(ctx context.Context, in *iam.Role, opts ...grpc.CallOption) (*iam.Role, error)
	DeleteRole(ctx context.Context, in *iam.Role, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListACLs(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*iam.ACLs, error)
	GetACL(ctx context.Context, in *iam.ACL, opts ...grpc.CallOption) (*blob.Blob, error)
	SetACL(ctx context.Context, in *iam.ACL, opts ...grpc.CallOption) (*iam.ACL, error)
	DeleteACL(ctx context.Context, in *iam.ACL, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListProjects(ctx context.Context, in *account.Account, opts ...grpc.CallOption) (*project.Projects, error)
	GetProject(ctx context.Context, in *project.Project, opts ...grpc.CallOption) (*blob.Blob, error)
	SetProject(ctx context.Context, in *project.Project, opts ...grpc.CallOption) (*project.Project, error)
	DeleteProject(ctx context.Context, in *project.Project, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListWorkflows(ctx context.Context, in *project.Project, opts ...grpc.CallOption) (*workflow.Workflows, error)
	GetWorkflow(ctx context.Context, in *workflow.Workflow, opts ...grpc.CallOption) (*blob.Blob, error)
	SetWorkflow(ctx context.Context, in *workflow.Workflow, opts ...grpc.CallOption) (*workflow.Workflow, error)
	DeleteWorkflow(ctx context.Context, in *workflow.Workflow, opts ...grpc.CallOption) (*status.StatusResponse, error)
	ListOperations(ctx context.Context, in *workflow.Workflow, opts ...grpc.CallOption) (*operation.Operations, error)
	GetOperation(ctx context.Context, in *operation.Operation, opts ...grpc.CallOption) (*blob.Blob, error)
	// rpc SetOperation (operation.Operation) returns (status.StatusResponse) {}
	DeleteOperation(ctx context.Context, in *operation.Operation, opts ...grpc.CallOption) (*status.StatusResponse, error)
	Echo(ctx context.Context, in *echo.EchoMessage, opts ...grpc.CallOption) (*echo.EchoMessage, error)
}

NxAPIClient is the client API for NxAPI service.

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

func NewNxAPIClient 

func NewNxAPIClient(cc grpc.ClientConnInterface) NxAPIClient

type NxAPIServer 

type NxAPIServer interface {
	ListResources(context.Context, *resource.Resource) (*resource.Resources, error)
	GetFederation(context.Context, *empty.Empty) (*controller.Federation, error)
	ListFederationControllers(context.Context, *empty.Empty) (*controller.Controllers, error)
	GetFederationController(context.Context, *controller.Controller) (*controller.Controller, error)
	DeleteFederationController(context.Context, *controller.Controller) (*status.StatusResponse, error)
	ControllerCapabilities(context.Context, *empty.Empty) (*controller.Capabilities, error)
	ExistsCustomer(context.Context, *iam.User) (*status.StatusResponse, error)
	ExistsAccount(context.Context, *account.Account) (*status.StatusResponse, error)
	ShowUserAccount(context.Context, *empty.Empty) (*iam.User, error)
	EditUserAccount(context.Context, *iam.User) (*iam.User, error)
	UserPasswordReset(context.Context, *iam.User) (*status.StatusResponse, error)
	NewAccount(context.Context, *account.Account) (*account.Account, error)
	ListAccounts(context.Context, *empty.Empty) (*account.Accounts, error)
	GetAccount(context.Context, *account.Account) (*blob.Blob, error)
	SetAccount(context.Context, *account.Account) (*account.Account, error)
	DeleteAccount(context.Context, *account.Account) (*status.StatusResponse, error)
	EnableAccount(context.Context, *account.Account) (*account.Account, error)
	DisableAccount(context.Context, *account.Account) (*account.Account, error)
	ListTenants(context.Context, *account.Account) (*tenant.Tenants, error)
	GetTenant(context.Context, *tenant.Tenant) (*blob.Blob, error)
	SetTenant(context.Context, *tenant.Tenant) (*tenant.Tenant, error)
	DeleteTenant(context.Context, *tenant.Tenant) (*status.StatusResponse, error)
	ListNetworks(context.Context, *tenant.Tenant) (*network.Networks, error)
	GetNetwork(context.Context, *network.Network) (*blob.Blob, error)
	SetNetwork(context.Context, *network.Network) (*network.Network, error)
	DeleteNetwork(context.Context, *network.Network) (*status.StatusResponse, error)
	ListVRFs(context.Context, *network.Network) (*network.VRFs, error)
	GetVRF(context.Context, *network.VRF) (*blob.Blob, error)
	SetVRF(context.Context, *network.VRF) (*network.VRF, error)
	DeleteVRF(context.Context, *network.VRF) (*status.StatusResponse, error)
	GetNetworkPolicy(context.Context, *network.VRF) (*network.Policy, error)
	SetNetworkPolicy(context.Context, *object.NetworkPolicyConfigRequest) (*network.Policy, error)
	DeleteNetworkPolicy(context.Context, *network.VRF) (*network.Policy, error)
	ListRoutes(context.Context, *network.VRF) (*routing.RoutingTable, error)
	GenerateNodeConfig(context.Context, *network.NetworkAgent) (*network.NodeConfig, error)
	ListNodeMMIDs(context.Context, *account.Account) (*network.MMIDs, error)
	ListNodes(context.Context, *network.VRF) (*network.Nodes, error)
	GetNode(context.Context, *network.Node) (*blob.Blob, error)
	// rpc SetNode (network.Node) returns (network.Node) {}
	DeleteNode(context.Context, *network.Node) (*status.StatusResponse, error)
	ResetNodeNetworkTraffic(context.Context, *network.Node) (*network.Node, error)
	//rpc GetNetworkEndpoint(network.Endpoint) returns (blob.Blob) {}
	DeleteNetworkEndpoint(context.Context, *network.Endpoint) (*status.StatusResponse, error)
	ListUsers(context.Context, *account.Account) (*iam.Users, error)
	GetUser(context.Context, *iam.User) (*blob.Blob, error)
	SetUser(context.Context, *iam.User) (*iam.User, error)
	DeleteUser(context.Context, *iam.User) (*status.StatusResponse, error)
	SetUserCredentialsPassword(context.Context, *iam.User) (*iam.User, error)
	SetUserCredentialsTOTP(context.Context, *iam.User) (*iam.User, error)
	EnableUser(context.Context, *iam.User) (*iam.User, error)
	DisableUser(context.Context, *iam.User) (*iam.User, error)
	ListSecurityGroups(context.Context, *account.Account) (*iam.SecurityGroups, error)
	GetSecurityGroup(context.Context, *iam.SecurityGroup) (*blob.Blob, error)
	SetSecurityGroup(context.Context, *iam.SecurityGroup) (*iam.SecurityGroup, error)
	DeleteSecurityGroup(context.Context, *iam.SecurityGroup) (*status.StatusResponse, error)
	ListRoles(context.Context, *account.Account) (*iam.Roles, error)
	GetRole(context.Context, *iam.Role) (*blob.Blob, error)
	SetRole(context.Context, *iam.Role) (*iam.Role, error)
	DeleteRole(context.Context, *iam.Role) (*status.StatusResponse, error)
	ListACLs(context.Context, *account.Account) (*iam.ACLs, error)
	GetACL(context.Context, *iam.ACL) (*blob.Blob, error)
	SetACL(context.Context, *iam.ACL) (*iam.ACL, error)
	DeleteACL(context.Context, *iam.ACL) (*status.StatusResponse, error)
	ListProjects(context.Context, *account.Account) (*project.Projects, error)
	GetProject(context.Context, *project.Project) (*blob.Blob, error)
	SetProject(context.Context, *project.Project) (*project.Project, error)
	DeleteProject(context.Context, *project.Project) (*status.StatusResponse, error)
	ListWorkflows(context.Context, *project.Project) (*workflow.Workflows, error)
	GetWorkflow(context.Context, *workflow.Workflow) (*blob.Blob, error)
	SetWorkflow(context.Context, *workflow.Workflow) (*workflow.Workflow, error)
	DeleteWorkflow(context.Context, *workflow.Workflow) (*status.StatusResponse, error)
	ListOperations(context.Context, *workflow.Workflow) (*operation.Operations, error)
	GetOperation(context.Context, *operation.Operation) (*blob.Blob, error)
	// rpc SetOperation (operation.Operation) returns (status.StatusResponse) {}
	DeleteOperation(context.Context, *operation.Operation) (*status.StatusResponse, error)
	Echo(context.Context, *echo.EchoMessage) (*echo.EchoMessage, error)
}

NxAPIServer is the server API for NxAPI service.

type NxNetworkClient 

type NxNetworkClient interface {
	NATProbe(ctx context.Context, in *natProbe.NATProbe, opts ...grpc.CallOption) (*natProbe.NATProbe, error)
	RegisterEndpoint(ctx context.Context, in *register.EndpointRegRequest, opts ...grpc.CallOption) (*register.EndpointRegResponse, error)
	RemoveEndpoint(ctx context.Context, in *register.EndpointRegRequest, opts ...grpc.CallOption) (*network.Node, error)
	RegisterNode(ctx context.Context, in *register.NodeRegRequest, opts ...grpc.CallOption) (*register.NodeRegResponse, error)
	DNS(ctx context.Context, in *dns.Host, opts ...grpc.CallOption) (*dns.IPv4, error)
	Routing(ctx context.Context, opts ...grpc.CallOption) (NxNetwork_RoutingClient, error)
	Cmd(ctx context.Context, opts ...grpc.CallOption) (NxNetwork_CmdClient, error)
	Metrics(ctx context.Context, in *network.Node, opts ...grpc.CallOption) (*status.StatusResponse, error)
	FederationEndpoints(ctx context.Context, in *network.Node, opts ...grpc.CallOption) (*controller.FederationEndpoints, error)
}

NxNetworkClient is the client API for NxNetwork service.

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

func NewNxNetworkClient 

func NewNxNetworkClient(cc grpc.ClientConnInterface) NxNetworkClient

type NxNetworkServer 

type NxNetworkServer interface {
	NATProbe(context.Context, *natProbe.NATProbe) (*natProbe.NATProbe, error)
	RegisterEndpoint(context.Context, *register.EndpointRegRequest) (*register.EndpointRegResponse, error)
	RemoveEndpoint(context.Context, *register.EndpointRegRequest) (*network.Node, error)
	RegisterNode(context.Context, *register.NodeRegRequest) (*register.NodeRegResponse, error)
	DNS(context.Context, *dns.Host) (*dns.IPv4, error)
	Routing(NxNetwork_RoutingServer) error
	Cmd(NxNetwork_CmdServer) error
	Metrics(context.Context, *network.Node) (*status.StatusResponse, error)
	FederationEndpoints(context.Context, *network.Node) (*controller.FederationEndpoints, error)
}

NxNetworkServer is the server API for NxNetwork service.

type NxNetwork_CmdClient 

type NxNetwork_CmdClient interface {
	Send(*mmsp.Payload) error
	Recv() (*mmsp.Payload, error)
	grpc.ClientStream
}

type NxNetwork_CmdServer 

type NxNetwork_CmdServer interface {
	Send(*mmsp.Payload) error
	Recv() (*mmsp.Payload, error)
	grpc.ServerStream
}

type NxNetwork_RoutingClient 

type NxNetwork_RoutingClient interface {
	Send(*routing.RTRequest) error
	Recv() (*routing.RTResponse, error)
	grpc.ClientStream
}

type NxNetwork_RoutingServer 

type NxNetwork_RoutingServer interface {
	Send(*routing.RTResponse) error
	Recv() (*routing.RTRequest, error)
	grpc.ServerStream
}

type UnimplementedNxAPIServer 

type UnimplementedNxAPIServer struct {
}

UnimplementedNxAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedNxAPIServer) ControllerCapabilities 

func (*UnimplementedNxAPIServer) ControllerCapabilities(context.Context, *empty.Empty) (*controller.Capabilities, error)

func (*UnimplementedNxAPIServer) DeleteACL 

func (*UnimplementedNxAPIServer) DeleteACL(context.Context, *iam.ACL) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteAccount 

func (*UnimplementedNxAPIServer) DeleteAccount(context.Context, *account.Account) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteFederationController 

func (*UnimplementedNxAPIServer) DeleteFederationController(context.Context, *controller.Controller) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteNetwork 

func (*UnimplementedNxAPIServer) DeleteNetwork(context.Context, *network.Network) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteNetworkEndpoint 

func (*UnimplementedNxAPIServer) DeleteNetworkEndpoint(context.Context, *network.Endpoint) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteNetworkPolicy 

func (*UnimplementedNxAPIServer) DeleteNetworkPolicy(context.Context, *network.VRF) (*network.Policy, error)

func (*UnimplementedNxAPIServer) DeleteNode 

func (*UnimplementedNxAPIServer) DeleteNode(context.Context, *network.Node) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteOperation 

func (*UnimplementedNxAPIServer) DeleteOperation(context.Context, *operation.Operation) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteProject 

func (*UnimplementedNxAPIServer) DeleteProject(context.Context, *project.Project) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteRole 

func (*UnimplementedNxAPIServer) DeleteRole(context.Context, *iam.Role) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteSecurityGroup 

func (*UnimplementedNxAPIServer) DeleteSecurityGroup(context.Context, *iam.SecurityGroup) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteTenant 

func (*UnimplementedNxAPIServer) DeleteTenant(context.Context, *tenant.Tenant) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteUser 

func (*UnimplementedNxAPIServer) DeleteUser(context.Context, *iam.User) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteVRF 

func (*UnimplementedNxAPIServer) DeleteVRF(context.Context, *network.VRF) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DeleteWorkflow 

func (*UnimplementedNxAPIServer) DeleteWorkflow(context.Context, *workflow.Workflow) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) DisableAccount 

func (*UnimplementedNxAPIServer) DisableAccount(context.Context, *account.Account) (*account.Account, error)

func (*UnimplementedNxAPIServer) DisableUser 

func (*UnimplementedNxAPIServer) DisableUser(context.Context, *iam.User) (*iam.User, error)

func (*UnimplementedNxAPIServer) Echo 

func (*UnimplementedNxAPIServer) Echo(context.Context, *echo.EchoMessage) (*echo.EchoMessage, error)

func (*UnimplementedNxAPIServer) EditUserAccount 

func (*UnimplementedNxAPIServer) EditUserAccount(context.Context, *iam.User) (*iam.User, error)

func (*UnimplementedNxAPIServer) EnableAccount 

func (*UnimplementedNxAPIServer) EnableAccount(context.Context, *account.Account) (*account.Account, error)

func (*UnimplementedNxAPIServer) EnableUser 

func (*UnimplementedNxAPIServer) EnableUser(context.Context, *iam.User) (*iam.User, error)

func (*UnimplementedNxAPIServer) ExistsAccount 

func (*UnimplementedNxAPIServer) ExistsAccount(context.Context, *account.Account) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) ExistsCustomer 

func (*UnimplementedNxAPIServer) ExistsCustomer(context.Context, *iam.User) (*status.StatusResponse, error)

func (*UnimplementedNxAPIServer) GenerateNodeConfig 

func (*UnimplementedNxAPIServer) GenerateNodeConfig(context.Context, *network.NetworkAgent) (*network.NodeConfig, error)

func (*UnimplementedNxAPIServer) GetACL 

func (*UnimplementedNxAPIServer) GetACL(context.Context, *iam.ACL) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetAccount 

func (*UnimplementedNxAPIServer) GetAccount(context.Context, *account.Account) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetFederation 

func (*UnimplementedNxAPIServer) GetFederation(context.Context, *empty.Empty) (*controller.Federation, error)

func (*UnimplementedNxAPIServer) GetFederationController 

func (*UnimplementedNxAPIServer) GetFederationController(context.Context, *controller.Controller) (*controller.Controller, error)

func (*UnimplementedNxAPIServer) GetNetwork 

func (*UnimplementedNxAPIServer) GetNetwork(context.Context, *network.Network) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetNetworkPolicy 

func (*UnimplementedNxAPIServer) GetNetworkPolicy(context.Context, *network.VRF) (*network.Policy, error)

func (*UnimplementedNxAPIServer) GetNode 

func (*UnimplementedNxAPIServer) GetNode(context.Context, *network.Node) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetOperation 

func (*UnimplementedNxAPIServer) GetOperation(context.Context, *operation.Operation) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetProject 

func (*UnimplementedNxAPIServer) GetProject(context.Context, *project.Project) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetRole 

func (*UnimplementedNxAPIServer) GetRole(context.Context, *iam.Role) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetSecurityGroup 

func (*UnimplementedNxAPIServer) GetSecurityGroup(context.Context, *iam.SecurityGroup) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetTenant 

func (*UnimplementedNxAPIServer) GetTenant(context.Context, *tenant.Tenant) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetUser 

func (*UnimplementedNxAPIServer) GetUser(context.Context, *iam.User) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetVRF 

func (*UnimplementedNxAPIServer) GetVRF(context.Context, *network.VRF) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) GetWorkflow 

func (*UnimplementedNxAPIServer) GetWorkflow(context.Context, *workflow.Workflow) (*blob.Blob, error)

func (*UnimplementedNxAPIServer) ListACLs 

func (*UnimplementedNxAPIServer) ListACLs(context.Context, *account.Account) (*iam.ACLs, error)

func (*UnimplementedNxAPIServer) ListAccounts 

func (*UnimplementedNxAPIServer) ListAccounts(context.Context, *empty.Empty) (*account.Accounts, error)

func (*UnimplementedNxAPIServer) ListFederationControllers 

func (*UnimplementedNxAPIServer) ListFederationControllers(context.Context, *empty.Empty) (*controller.Controllers, error)

func (*UnimplementedNxAPIServer) ListNetworks 

func (*UnimplementedNxAPIServer) ListNetworks(context.Context, *tenant.Tenant) (*network.Networks, error)

func (*UnimplementedNxAPIServer) ListNodeMMIDs 

func (*UnimplementedNxAPIServer) ListNodeMMIDs(context.Context, *account.Account) (*network.MMIDs, error)

func (*UnimplementedNxAPIServer) ListNodes 

func (*UnimplementedNxAPIServer) ListNodes(context.Context, *network.VRF) (*network.Nodes, error)

func (*UnimplementedNxAPIServer) ListOperations 

func (*UnimplementedNxAPIServer) ListOperations(context.Context, *workflow.Workflow) (*operation.Operations, error)

func (*UnimplementedNxAPIServer) ListProjects 

func (*UnimplementedNxAPIServer) ListProjects(context.Context, *account.Account) (*project.Projects, error)

func (*UnimplementedNxAPIServer) ListResources 

func (*UnimplementedNxAPIServer) ListResources(context.Context, *resource.Resource) (*resource.Resources, error)

func (*UnimplementedNxAPIServer) ListRoles 

func (*UnimplementedNxAPIServer) ListRoles(context.Context, *account.Account) (*iam.Roles, error)

func (*UnimplementedNxAPIServer) ListRoutes 

func (*UnimplementedNxAPIServer) ListRoutes(context.Context, *network.VRF) (*routing.RoutingTable, error)

func (*UnimplementedNxAPIServer) ListSecurityGroups 

func (*UnimplementedNxAPIServer) ListSecurityGroups(context.Context, *account.Account) (*iam.SecurityGroups, error)

func (*UnimplementedNxAPIServer) ListTenants 

func (*UnimplementedNxAPIServer) ListTenants(context.Context, *account.Account) (*tenant.Tenants, error)

func (*UnimplementedNxAPIServer) ListUsers 

func (*UnimplementedNxAPIServer) ListUsers(context.Context, *account.Account) (*iam.Users, error)

func (*UnimplementedNxAPIServer) ListVRFs 

func (*UnimplementedNxAPIServer) ListVRFs(context.Context, *network.Network) (*network.VRFs, error)

func (*UnimplementedNxAPIServer) ListWorkflows 

func (*UnimplementedNxAPIServer) ListWorkflows(context.Context, *project.Project) (*workflow.Workflows, error)

func (*UnimplementedNxAPIServer) NewAccount 

func (*UnimplementedNxAPIServer) NewAccount(context.Context, *account.Account) (*account.Account, error)

func (*UnimplementedNxAPIServer) ResetNodeNetworkTraffic 

func (*UnimplementedNxAPIServer) ResetNodeNetworkTraffic(context.Context, *network.Node) (*network.Node, error)

func (*UnimplementedNxAPIServer) SetACL 

func (*UnimplementedNxAPIServer) SetACL(context.Context, *iam.ACL) (*iam.ACL, error)

func (*UnimplementedNxAPIServer) SetAccount 

func (*UnimplementedNxAPIServer) SetAccount(context.Context, *account.Account) (*account.Account, error)

func (*UnimplementedNxAPIServer) SetNetwork 

func (*UnimplementedNxAPIServer) SetNetwork(context.Context, *network.Network) (*network.Network, error)

func (*UnimplementedNxAPIServer) SetNetworkPolicy 

func (*UnimplementedNxAPIServer) SetNetworkPolicy(context.Context, *object.NetworkPolicyConfigRequest) (*network.Policy, error)

func (*UnimplementedNxAPIServer) SetProject 

func (*UnimplementedNxAPIServer) SetProject(context.Context, *project.Project) (*project.Project, error)

func (*UnimplementedNxAPIServer) SetRole 

func (*UnimplementedNxAPIServer) SetRole(context.Context, *iam.Role) (*iam.Role, error)

func (*UnimplementedNxAPIServer) SetSecurityGroup 

func (*UnimplementedNxAPIServer) SetSecurityGroup(context.Context, *iam.SecurityGroup) (*iam.SecurityGroup, error)

func (*UnimplementedNxAPIServer) SetTenant 

func (*UnimplementedNxAPIServer) SetTenant(context.Context, *tenant.Tenant) (*tenant.Tenant, error)

func (*UnimplementedNxAPIServer) SetUser 

func (*UnimplementedNxAPIServer) SetUser(context.Context, *iam.User) (*iam.User, error)

func (*UnimplementedNxAPIServer) SetUserCredentialsPassword 

func (*UnimplementedNxAPIServer) SetUserCredentialsPassword(context.Context, *iam.User) (*iam.User, error)

func (*UnimplementedNxAPIServer) SetUserCredentialsTOTP 

func (*UnimplementedNxAPIServer) SetUserCredentialsTOTP(context.Context, *iam.User) (*iam.User, error)

func (*UnimplementedNxAPIServer) SetVRF 

func (*UnimplementedNxAPIServer) SetVRF(context.Context, *network.VRF) (*network.VRF, error)

func (*UnimplementedNxAPIServer) SetWorkflow 

func (*UnimplementedNxAPIServer) SetWorkflow(context.Context, *workflow.Workflow) (*workflow.Workflow, error)

func (*UnimplementedNxAPIServer) ShowUserAccount 

func (*UnimplementedNxAPIServer) ShowUserAccount(context.Context, *empty.Empty) (*iam.User, error)

func (*UnimplementedNxAPIServer) UserPasswordReset 

func (*UnimplementedNxAPIServer) UserPasswordReset(context.Context, *iam.User) (*status.StatusResponse, error)

type UnimplementedNxNetworkServer 

type UnimplementedNxNetworkServer struct {
}

UnimplementedNxNetworkServer can be embedded to have forward compatible implementations.

func (*UnimplementedNxNetworkServer) Cmd 

func (*UnimplementedNxNetworkServer) Cmd(NxNetwork_CmdServer) error

func (*UnimplementedNxNetworkServer) DNS 

func (*UnimplementedNxNetworkServer) DNS(context.Context, *dns.Host) (*dns.IPv4, error)

func (*UnimplementedNxNetworkServer) FederationEndpoints 

func (*UnimplementedNxNetworkServer) FederationEndpoints(context.Context, *network.Node) (*controller.FederationEndpoints, error)

func (*UnimplementedNxNetworkServer) Metrics 

func (*UnimplementedNxNetworkServer) Metrics(context.Context, *network.Node) (*status.StatusResponse, error)

func (*UnimplementedNxNetworkServer) NATProbe 

func (*UnimplementedNxNetworkServer) NATProbe(context.Context, *natProbe.NATProbe) (*natProbe.NATProbe, error)

func (*UnimplementedNxNetworkServer) RegisterEndpoint 

func (*UnimplementedNxNetworkServer) RegisterEndpoint(context.Context, *register.EndpointRegRequest) (*register.EndpointRegResponse, error)

func (*UnimplementedNxNetworkServer) RegisterNode 

func (*UnimplementedNxNetworkServer) RegisterNode(context.Context, *register.NodeRegRequest) (*register.NodeRegResponse, error)

func (*UnimplementedNxNetworkServer) RemoveEndpoint 

func (*UnimplementedNxNetworkServer) RemoveEndpoint(context.Context, *register.EndpointRegRequest) (*network.Node, error)

func (*UnimplementedNxNetworkServer) Routing 

func (*UnimplementedNxNetworkServer) Routing(NxNetwork_RoutingServer) error

type UnimplementedVersionRPCServer 

type UnimplementedVersionRPCServer struct {
}

UnimplementedVersionRPCServer can be embedded to have forward compatible implementations.

func (*UnimplementedVersionRPCServer) Version 

func (*UnimplementedVersionRPCServer) Version(context.Context, *empty.Empty) (*version.VersionResponse, error)

type VersionRPCClient 

type VersionRPCClient interface {
	Version(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*version.VersionResponse, error)
}

VersionRPCClient is the client API for VersionRPC service.

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

func NewVersionRPCClient 

func NewVersionRPCClient(cc grpc.ClientConnInterface) VersionRPCClient

type VersionRPCServer 

type VersionRPCServer interface {
	Version(context.Context, *empty.Empty) (*version.VersionResponse, error)
}

VersionRPCServer is the server API for VersionRPC service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.