api_handler

package
v0.0.0-...-30f0efb Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MAX_PER_DIR_RULES = 8

Functions

func CloseGNMIConn 

func CloseGNMIConn()

func CloseP4RtCCon 

func CloseP4RtCCon()

func GetFwdPipe 

func GetFwdPipe(ctx context.Context,
	responseType client.GetFwdPipeResponseType) (*client.FwdPipeConfig, error)

func GetLogLevel 

func GetLogLevel() string

func InitModCtr 

func InitModCtr()

func InsertDefaultRule 

func InsertDefaultRule()

func OpenGNMICCon 

func OpenGNMICCon() error

func OpenP4RtC 

func OpenP4RtC(ctx context.Context, high uint64, low uint64, stopCh <-chan struct{}) error

func PutConf 

func PutConf(c *conf.Configuration)

func SetFwdPipe 

func SetFwdPipe(ctx context.Context, binPath string,
	p4InfoPath string, cookie uint64) (*client.FwdPipeConfig, error)

func SetHostInterface 

func SetHostInterface()

Types

type ApiServer 

type ApiServer struct {
	// contains filtered or unexported fields
}

func CreateServer 

func CreateServer(log *log.Entry) *ApiServer

func NewApiServer 

func NewApiServer() *ApiServer

func (*ApiServer) ActivePolicyRemove 

func (s *ApiServer) ActivePolicyRemove(ctx context.Context, in *proto.ActivePolicyRemove) (*proto.Reply, error)

func (*ApiServer) ActivePolicyUpdate 

func (s *ApiServer) ActivePolicyUpdate(ctx context.Context, in *proto.ActivePolicyUpdate) (*proto.Reply, error)

func (*ApiServer) AddDelSnatPrefix 

func (s *ApiServer) AddDelSnatPrefix(ctx context.Context, in *proto.AddDelSnatPrefixRequest) (*proto.Reply, error)

func (*ApiServer) Check 

func (s *ApiServer) Check(ctx context.Context, in *healthgrpc.HealthCheckRequest) (*healthgrpc.HealthCheckResponse, error)

Check is used to check the status of GRPC service

func (*ApiServer) CreateNetwork 

func (s *ApiServer) CreateNetwork(ctx context.Context, in *proto.CreateNetworkRequest) (*proto.AddReply, error)

func (*ApiServer) DeleteNetwork 

func (s *ApiServer) DeleteNetwork(ctx context.Context, in *proto.DeleteNetworkRequest) (*proto.DelReply, error)

func (*ApiServer) NatTranslationAdd 

func (s *ApiServer) NatTranslationAdd(ctx context.Context, in *proto.NatTranslation) (*proto.Reply, error)

func (*ApiServer) NatTranslationDelete 

func (s *ApiServer) NatTranslationDelete(ctx context.Context, in *proto.NatTranslation) (*proto.Reply, error)

func (*ApiServer) RemoveActiveProfile 

func (s *ApiServer) RemoveActiveProfile(ctx context.Context, in *proto.ActiveProfileRemove) (*proto.Reply, error)

func (*ApiServer) RemoveHostEndpoint 

func (s *ApiServer) RemoveHostEndpoint(ctx context.Context, in *proto.HostEndpointRemove) (*proto.Reply, error)

func (*ApiServer) RemoveHostMetaData 

func (s *ApiServer) RemoveHostMetaData(ctx context.Context, in *proto.HostMetadataRemove) (*proto.Reply, error)

func (*ApiServer) RemoveIPAMPool 

func (s *ApiServer) RemoveIPAMPool(ctx context.Context, in *proto.IPAMPoolRemove) (*proto.Reply, error)

func (*ApiServer) RemoveIPSet 

func (s *ApiServer) RemoveIPSet(ctx context.Context, in *proto.IPSetRemove) (*proto.Reply, error)

func (*ApiServer) RemoveLocalEndpoint 

func (s *ApiServer) RemoveLocalEndpoint(ctx context.Context, in *proto.WorkloadEndpointRemove) (*proto.Reply, error)

func (*ApiServer) RemoveNamespace 

func (s *ApiServer) RemoveNamespace(ctx context.Context, in *proto.NamespaceRemove) (*proto.Reply, error)

func (*ApiServer) RemoveRoute 

func (s *ApiServer) RemoveRoute(ctx context.Context, in *proto.RouteRemove) (*proto.Reply, error)

func (*ApiServer) RemoveServiceAccount 

func (s *ApiServer) RemoveServiceAccount(ctx context.Context, in *proto.ServiceAccountRemove) (*proto.Reply, error)

func (*ApiServer) RemoveVXLANTunnelEndpoint 

func (s *ApiServer) RemoveVXLANTunnelEndpoint(ctx context.Context, in *proto.VXLANTunnelEndpointRemove) (*proto.Reply, error)

func (*ApiServer) RemoveWireguardEndpoint 

func (s *ApiServer) RemoveWireguardEndpoint(ctx context.Context, in *proto.WireguardEndpointRemove) (*proto.Reply, error)

func (*ApiServer) SetSnatAddress 

func (s *ApiServer) SetSnatAddress(ctx context.Context, in *proto.SetSnatAddressRequest) (*proto.Reply, error)

func (*ApiServer) SetupHostInterface 

func (s *ApiServer) SetupHostInterface(ctx context.Context, in *proto.SetupHostInterfaceRequest) (*proto.Reply, error)

func (*ApiServer) Start 

func (s *ApiServer) Start(t *tomb.Tomb)

func (*ApiServer) Stop 

func (s *ApiServer) Stop()

func (*ApiServer) UpdateActiveProfile 

func (s *ApiServer) UpdateActiveProfile(ctx context.Context, in *proto.ActiveProfileUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateGlobalBGPConfig 

func (s *ApiServer) UpdateGlobalBGPConfig(ctx context.Context, in *proto.GlobalBGPConfigUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateHostEndpoint 

func (s *ApiServer) UpdateHostEndpoint(ctx context.Context, in *proto.HostEndpointUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateHostMetaData 

func (s *ApiServer) UpdateHostMetaData(ctx context.Context, in *proto.HostMetadataUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateIPAMPool 

func (s *ApiServer) UpdateIPAMPool(ctx context.Context, in *proto.IPAMPoolUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateIPSet 

func (s *ApiServer) UpdateIPSet(ctx context.Context, in *proto.IPSetUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateIPSetDelta 

func (s *ApiServer) UpdateIPSetDelta(ctx context.Context, in *proto.IPSetDeltaUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateLocalEndpoint 

func (s *ApiServer) UpdateLocalEndpoint(ctx context.Context, in *proto.WorkloadEndpointUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateNamespace 

func (s *ApiServer) UpdateNamespace(ctx context.Context, in *proto.NamespaceUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateRoute 

func (s *ApiServer) UpdateRoute(ctx context.Context, in *proto.RouteUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateServiceAccount 

func (s *ApiServer) UpdateServiceAccount(ctx context.Context, in *proto.ServiceAccountUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateVXLANTunnelEndpoint 

func (s *ApiServer) UpdateVXLANTunnelEndpoint(ctx context.Context, in *proto.VXLANTunnelEndpointUpdate) (*proto.Reply, error)

func (*ApiServer) UpdateWireguardEndpoint 

func (s *ApiServer) UpdateWireguardEndpoint(ctx context.Context, in *proto.WireguardEndpointUpdate) (*proto.Reply, error)

func (*ApiServer) Watch 

func (s *ApiServer) Watch(in *healthgrpc.HealthCheckRequest, _ healthgrpc.Health_WatchServer) error

Watch was created to fulfil interface requirements, unused

type Protocol 

type Protocol int

type RuleGroupIDX 

type RuleGroupIDX struct {
	RuleGroup store.RuleGroup
	// contains filtered or unexported fields
}

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.