messaging

Documentation

Index

• Constants
• type Client
• type MessagingClient
  • func NewMessagingClient() *MessagingClient
  • func (mc *MessagingClient) AddBridge(in *api.AddCommand) (*api.AddResponse, error)
  • func (mc *MessagingClient) Close()
  • func (mc *MessagingClient) ListBridges(in *api.ListCommand) (*api.ListResponse, error)
  • func (mc *MessagingClient) RemoveBridge(in *api.RemoveCommand) (*api.RemoveResponse, error)
• type MessagingServer
  • func NewMessagingServer(manager manager.Manager) *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

const (
	PROTOCOL = "unix"
	SOCKET   = "/tmp/ebpf_bridge.sock"
)

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)
}