Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stream

package

Go to main page

Versions in this module

v1

v1.3.14

May 13, 2026

Changes in this version

type Stats

+ func (s *Stats) IncrementConfiguredObjectMutations()

v1.3.13

Apr 17, 2026

Changes in this version

+ const ConnectionRetryInterval

+ const ConnectionRetryJitter

+ const ResetInitialBackoff

+ const ResetMaxBackoff

+ const ResetMaxJitterPct

+ const ResourceProcessingTimeout

+ const StreamExponentialFactor

+ const StreamInitialBackoff

+ const StreamMaxBackoff

+ const StreamMaxJitterPct

+ const StreamSevereErrorThreshold

+ var ErrStopRetries = errors.New("stop retries")

+ func ConnectStreams(ctx context.Context, logger *zap.Logger, envMap Config, ...)

+ func ManageStream(ctx context.Context, logger *zap.Logger, conn grpc.ClientConnInterface, ...)

+ func NewAuthenticatedConnection(ctx context.Context, logger *zap.Logger, envMap Config) (*grpc.ClientConn, error)

+ func ServerIsHealthy() bool

+ func SetProcessingResources(processing bool)

+ func StartStatsLogger(ctx context.Context, logger *zap.Logger, stats *Stats, period time.Duration)

+ type Action func() error

+ type Config struct

+ ClusterCreds string

+ ClusterName string

+ HttpsProxy string

+ OnboardingClientID string

+ OnboardingClientSecret string

+ OnboardingEndpoint string

+ PodNamespace string

+ StatsLogPeriod time.Duration

+ SuccessPeriods SuccessPeriods

+ TlsSkipVerify bool

+ TokenEndpoint string

+ type FactoryConfig struct

+ Factories []ManagedFactory

+ Stats *Stats

+ StatsLogPeriod time.Duration

+ SuccessPeriods SuccessPeriods

+ type ManagedFactory struct

+ Factory StreamClientFactory

+ KeepalivePeriod time.Duration

+ type Stats struct

+ func NewStats() *Stats

+ func (s *Stats) GetAndResetStats() (flowsReceived, flowsSent, mutations uint64)

+ func (s *Stats) IncrementFlowsReceived()

+ func (s *Stats) IncrementFlowsSentToClusterSync()

+ func (s *Stats) IncrementResourceMutations()

+ type StreamClient interface

+ Close func() error

+ Run func(ctx context.Context) error

+ SendKeepalive func(ctx context.Context) error

+ type StreamClientFactory interface

+ Name func() string

+ NewStreamClient func(ctx context.Context, grpcConn grpc.ClientConnInterface) (StreamClient, error)

+ type SuccessPeriods struct

+ Auth time.Duration

+ Connect time.Duration