api

type Config interface{}

type ConfigProvider interface {
	// Load returns configuration data,
	// should not throw an error if underlying storage does not exist
	Load() ([]byte, error)
	// Save stores data into storage
	Save([]byte) error
}

type EventBroadcaster interface {
	// Reset the history for the connection, called when listener starts accepting new connections
	Reset(ctx context.Context, id string) error
	// Update provides a peer connection state change updates
	Update(ctx context.Context, evt *pb.ConnectionStatusUpdate) error
	// Subscribe to updates for the tunnel; the channel will close when context provided is canceled
	Subscribe(ctx context.Context, id string) (chan *pb.ConnectionStatusUpdate, error)
}

type FileConfigProvider string

type ListenerStatus interface {
	// Lock marks a particular ID locked and provides a function to be called on unlock
	SetListening(id string, onUnlock context.CancelFunc, addr string) error
	// IsListening checks whether particular ID is currently locked
	GetListenerStatus(id string) *pb.ListenerStatus
	// Unlock unlocks the ID and calls onUnlock function and clears listener status
	SetNotListening(id string) error
	// SetListenError sets listener status to an error
	SetListenerError(id string, err error) error
}

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

type Server interface {
	pb.ConfigServer
	pb.ListenerServer
}

type ServerOption func(*server) error

type Tunnel interface {
	Run(context.Context, io.ReadWriter, tcptunnel.TunnelEvents) error
}