stream

Feb 16, 2022

Changes in this version

+ const MaxNumberOfTargets

+ const PendingTime

+ func NewFactory(targetRegistryClient nspAPI.TargetRegistryClient, maxNumberOfTargets int, ...) *streamFactory

+ type Conduit interface

+ GetIPs func() []string

+ type Stream struct

+ Conduit Conduit

+ MaxNumberOfTargets int

+ Stream *ambassadorAPI.Stream

+ TargetRegistry TargetRegistry

+ func New(stream *ambassadorAPI.Stream, targetRegistryClient nspAPI.TargetRegistryClient, ...) (*Stream, error)

+ func (s *Stream) Close(ctx context.Context) error

+ func (s *Stream) Equals(stream *ambassadorAPI.Stream) bool

+ func (s *Stream) GetStream() *ambassadorAPI.Stream

+ func (s *Stream) Open(ctx context.Context) error

+ type TargetRegistry interface

+ GetTargets func(context.Context, *nspAPI.Target) ([]*nspAPI.Target, error)

+ Register func(context.Context, *nspAPI.Target) error

+ Unregister func(context.Context, *nspAPI.Target) error