core

Documentation

Index

• Variables
• func StringInSlice(s string, list []string) bool
• type ConnectorCore
  • func NewConnectorCore(logger *zap.Logger, cfg config.Config, discovery discover.Discover, ...) *ConnectorCore
  • func (c *ConnectorCore) CheckAndUpdateSocket(ctx context.Context, apiSocket, localSocket models.Socket) (*models.Socket, error)
  • func (c *ConnectorCore) CheckSocketsToCreate(ctx context.Context, localSockets []models.Socket, ...) ([]models.Socket, error)
  • func (c *ConnectorCore) CheckSocketsToDelete(ctx context.Context, socketsFromApi []models.Socket, ...) error
  • func (c *ConnectorCore) CreateSocketAndTunnel(ctx context.Context, s *models.Socket) (*models.Socket, error)
  • func (c *ConnectorCore) DiscoverNewSocketChanges(ctx context.Context, ch chan []models.Socket)
  • func (c *ConnectorCore) HandleUpdates(ctx context.Context, sockets []models.Socket) error
  • func (c *ConnectorCore) IsSocketConnected(key string) bool
  • func (c *ConnectorCore) RecreateSocket(ctx context.Context, socketID string, localSocket models.Socket) (*models.Socket, error)
  • func (c *ConnectorCore) SocketsCoreHandler(ctx context.Context, socketsToUpdate []models.Socket) ([]models.Socket, error)
  • func (c *ConnectorCore) TunnelConnectJob(ctx context.Context, group *errgroup.Group)
  • func (c *ConnectorCore) TunnelConnnect(ctx context.Context, socket models.Socket) error
• type PolicyManager
  • func NewPolicyManager(logger *zap.Logger, api api.API) *PolicyManager
  • func (p *PolicyManager) ApplyPolicies(ctx context.Context, socket models.Socket, localPolicies []string) ([]string, error)
• type SyncMap
  • func NewSyncMap() *SyncMap
  • func (s *SyncMap) Add(key, value interface{})
  • func (s *SyncMap) Delete(key interface{})
  • func (s *SyncMap) Get(key interface{}) (interface{}, bool)
  • func (s *SyncMap) Len() int

Variables

var ErrEmptyPolicyList = errors.New("policy list is empty")

var ErrPolicyNotFound = errors.New("we couldn't find the policy")

Functions

func StringInSlice

func StringInSlice(s string, list []string) bool

Types

type ConnectorCore

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

func NewConnectorCore

func NewConnectorCore(logger *zap.Logger, cfg config.Config, discovery discover.Discover, mysocketAPI api.API) *ConnectorCore

func (*ConnectorCore) CheckAndUpdateSocket

func (c *ConnectorCore) CheckAndUpdateSocket(ctx context.Context, apiSocket, localSocket models.Socket) (*models.Socket, error)

func (*ConnectorCore) CheckSocketsToCreate

func (c *ConnectorCore) CheckSocketsToCreate(ctx context.Context, localSockets []models.Socket, socketsFromApiMap map[string]models.Socket) ([]models.Socket, error)

func (*ConnectorCore) CheckSocketsToDelete

func (c *ConnectorCore) CheckSocketsToDelete(ctx context.Context, socketsFromApi []models.Socket, localSocketsMap map[string]models.Socket) error

func (*ConnectorCore) CreateSocketAndTunnel

func (c *ConnectorCore) CreateSocketAndTunnel(ctx context.Context, s *models.Socket) (*models.Socket, error)

func (*ConnectorCore) DiscoverNewSocketChanges

func (c *ConnectorCore) DiscoverNewSocketChanges(ctx context.Context, ch chan []models.Socket)

func (*ConnectorCore) HandleUpdates

func (c *ConnectorCore) HandleUpdates(ctx context.Context, sockets []models.Socket) error

func (*ConnectorCore) IsSocketConnected

func (c *ConnectorCore) IsSocketConnected(key string) bool

func (*ConnectorCore) RecreateSocket

func (c *ConnectorCore) RecreateSocket(ctx context.Context, socketID string, localSocket models.Socket) (*models.Socket, error)

func (*ConnectorCore) SocketsCoreHandler

func (c *ConnectorCore) SocketsCoreHandler(ctx context.Context, socketsToUpdate []models.Socket) ([]models.Socket, error)

func (*ConnectorCore) TunnelConnectJob

func (c *ConnectorCore) TunnelConnectJob(ctx context.Context, group *errgroup.Group)

func (*ConnectorCore) TunnelConnnect

func (c *ConnectorCore) TunnelConnnect(ctx context.Context, socket models.Socket) error

type PolicyManager

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

func NewPolicyManager

func NewPolicyManager(logger *zap.Logger, api api.API) *PolicyManager

func (*PolicyManager) ApplyPolicies

func (p *PolicyManager) ApplyPolicies(ctx context.Context, socket models.Socket, localPolicies []string) ([]string, error)

type SyncMap

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

func NewSyncMap

func NewSyncMap() *SyncMap

func (*SyncMap) Add

func (s *SyncMap) Add(key, value interface{})

func (*SyncMap) Delete

func (s *SyncMap) Delete(key interface{})

func (*SyncMap) Get

func (s *SyncMap) Get(key interface{}) (interface{}, bool)

func (*SyncMap) Len

func (s *SyncMap) Len() int