types

type Conduit interface {
	// Connect requests the connection to NSM and, if success, open all streams added
	// and confiure the VIPs
	Connect(ctx context.Context) error
	// Disconnect closes the connection from NSM, closes all streams
	// and removes the VIP configuration
	Disconnect(ctx context.Context) error
	// AddStream creates a stream and will open it in background
	AddStream(context.Context, *ambassadorAPI.Stream) error
	// RemoveStream closes and removes the stream (if existing)
	RemoveStream(context.Context, *ambassadorAPI.Stream) error
	GetStreams() []*ambassadorAPI.Stream
	Equals(*ambassadorAPI.Conduit) bool
	GetConduit() *ambassadorAPI.Conduit
}

type ConduitStatus int

type Registry interface {
	SetStatus(*ambassadorAPI.Stream, ambassadorAPI.StreamStatus_Status)
	Remove(*ambassadorAPI.Stream)
	Watch(context.Context, *ambassadorAPI.Stream) (Watcher, error)
}

type Stream interface {
	// Open the stream in the conduit by generating a identifier and registering
	// the target to the NSP service while avoiding the identifier collisions.
	Open(ctx context.Context, nspStream *nspAPI.Stream) error
	// Close the stream in the conduit by unregistering target from the NSP service.
	Close(ctx context.Context) error
	Equals(*ambassadorAPI.Stream) bool
	GetStream() *ambassadorAPI.Stream
}

type StreamStatus int

type Trench interface {
	Delete(ctx context.Context) error
	// AddConduit creates a conduit and will connect it in background
	AddConduit(context.Context, *ambassadorAPI.Conduit) (Conduit, error)
	// RemoveConduit disconnects and removes the conduit (if existing).
	RemoveConduit(context.Context, *ambassadorAPI.Conduit) error
	GetConduits() []Conduit
	// GetConduit returns the conduit matching to the one in parameter if it exists.
	GetConduit(*ambassadorAPI.Conduit) Conduit
	Equals(*ambassadorAPI.Trench) bool
	GetTrench() *ambassadorAPI.Trench
}

type Watcher interface {
	Stop()
	ResultChan() <-chan []*ambassadorAPI.StreamStatus
}