Documentation
¶
Index ¶
- Constants
- type Client
- type MessagingClient
- type MessagingServer
- func (s *MessagingServer) AddBridge(ctx context.Context, in *api.AddCommand) (*api.AddResponse, error)
- func (s *MessagingServer) ListBridges(ctx context.Context, in *api.ListCommand) (*api.ListResponse, error)
- func (s *MessagingServer) RemoveBridge(ctx context.Context, in *api.RemoveCommand) (*api.RemoveResponse, error)
- func (s *MessagingServer) Start()
- func (s *MessagingServer) Stop()
- type Server
Constants ¶
View Source
const ( PROTOCOL = "unix" SOCKET = "/tmp/ebpf_bridge.sock" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
Close()
AddBridge(in *api.AddCommand) (*api.AddResponse, error)
RemoveBridge(in *api.RemoveCommand) (*api.RemoveResponse, error)
ListBridges(in *api.ListCommand) (*api.ListResponse, error)
}
type MessagingClient ¶
type MessagingClient struct {
// contains filtered or unexported fields
}
func NewMessagingClient ¶
func NewMessagingClient() *MessagingClient
func (*MessagingClient) AddBridge ¶
func (mc *MessagingClient) AddBridge(in *api.AddCommand) (*api.AddResponse, error)
func (*MessagingClient) Close ¶
func (mc *MessagingClient) Close()
func (*MessagingClient) ListBridges ¶
func (mc *MessagingClient) ListBridges(in *api.ListCommand) (*api.ListResponse, error)
func (*MessagingClient) RemoveBridge ¶
func (mc *MessagingClient) RemoveBridge(in *api.RemoveCommand) (*api.RemoveResponse, error)
type MessagingServer ¶
type MessagingServer struct {
api.UnimplementedEbpfBridgeControllerServer
// contains filtered or unexported fields
}
func NewMessagingServer ¶
func NewMessagingServer(manager manager.Manager) *MessagingServer
func (*MessagingServer) AddBridge ¶
func (s *MessagingServer) AddBridge(ctx context.Context, in *api.AddCommand) (*api.AddResponse, error)
func (*MessagingServer) ListBridges ¶
func (s *MessagingServer) ListBridges(ctx context.Context, in *api.ListCommand) (*api.ListResponse, error)
func (*MessagingServer) RemoveBridge ¶
func (s *MessagingServer) RemoveBridge(ctx context.Context, in *api.RemoveCommand) (*api.RemoveResponse, error)
func (*MessagingServer) Start ¶
func (s *MessagingServer) Start()
func (*MessagingServer) Stop ¶
func (s *MessagingServer) Stop()
type Server ¶
type Server interface {
Start()
Stop()
AddBridge(ctx context.Context, in *api.AddCommand) (*api.AddResponse, error)
RemoveBridge(ctx context.Context, in *api.RemoveCommand) (*api.RemoveResponse, error)
ListBridges(ctx context.Context, in *api.ListCommand) (*api.ListResponse, error)
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.