coordinator

Documentation

Index

• func RunCoordinator()
• func Version() string
• type Config
• type ConnectionRegistry
  • func NewConnectionRegistry() *ConnectionRegistry
  • func (r *ConnectionRegistry) Hello(_ context.Context, msg *proto.HELOMessage) (*proto.EHLOMessage, error)
  • func (r *ConnectionRegistry) OnReverseTunnelClose(tc tunnel.TunnelChannel)
  • func (r *ConnectionRegistry) OnReverseTunnelOpen(tc tunnel.TunnelChannel) error

Functions

func RunCoordinator

func RunCoordinator()

func Version

func Version() string

Types

type Config

type Config struct {
	Web struct {
		Enabled bool   `fig:"enabled" default:"bool"`
		Host    string `fig:"host" default:"127.0.0.1"`
		Port    int    `fig:"port" default:"8080"`
	}
	GRPC struct {
		Enabled bool   `fig:"enabled" default:"bool"`
		Host    string `fig:"host" default:"unix://tmp/cloak.sock"`
		Port    int    `fig:"port" default:"8000"`
	}
	Logging struct {
		Http     string `fig:"http" default:"all"`
		Database string `fig:"db" default:"all"`
		GRPC     string `fig:"grpc" default:"error"`
	}
	Database struct {
		URI string `fig:"uri" default:"postgres://postgres:@localhost:5432/cloak?sslmode=disable"`
	}
}

type ConnectionRegistry

type ConnectionRegistry struct {
	proto.UnimplementedHelloServer
	// contains filtered or unexported fields
}

func NewConnectionRegistry

func NewConnectionRegistry() *ConnectionRegistry

func (*ConnectionRegistry) Hello

func (r *ConnectionRegistry) Hello(_ context.Context, msg *proto.HELOMessage) (*proto.EHLOMessage, error)

func (*ConnectionRegistry) OnReverseTunnelClose

func (r *ConnectionRegistry) OnReverseTunnelClose(tc tunnel.TunnelChannel)

func (*ConnectionRegistry) OnReverseTunnelOpen

func (r *ConnectionRegistry) OnReverseTunnelOpen(tc tunnel.TunnelChannel) error