Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

compute

package

Go to main page

Versions in this module

v1

v1.6.0

Dec 16, 2024

Changes in this version

+ type Config struct

+ CheckpointInterval time.Duration

+ Checkpointer nclprotocol.Checkpointer

+ ClientFactory nats.ClientFactory

+ Clock clock.Clock

+ DataPlaneMessageCreator nclprotocol.MessageCreator

+ DataPlaneMessageHandler ncl.MessageHandler

+ DispatcherConfig dispatcher.Config

+ EventStore watcher.EventStore

+ HeartbeatInterval time.Duration

+ HeartbeatMissFactor int

+ LogStreamServer logstream.Server

+ MessageRegistry *envelope.Registry

+ MessageSerializer envelope.MessageSerializer

+ NodeID string

+ NodeInfoProvider models.NodeInfoProvider

+ NodeInfoUpdateInterval time.Duration

+ ReconnectBackoff backoff.Backoff

+ ReconnectInterval time.Duration

+ RequestTimeout time.Duration

+ func DefaultConfig() Config

+ func (c *Config) SetDefaults()

+ func (c *Config) Validate() error

+ type ConnectionManager struct

+ func NewConnectionManager(cfg Config) (*ConnectionManager, error)

+ func (cm *ConnectionManager) Close(ctx context.Context) error

+ func (cm *ConnectionManager) GetHealth() nclprotocol.ConnectionHealth

+ func (cm *ConnectionManager) OnStateChange(handler nclprotocol.ConnectionStateHandler)

+ func (cm *ConnectionManager) Start(ctx context.Context) error

+ type ControlPlane struct

+ func NewControlPlane(params ControlPlaneParams) (*ControlPlane, error)

+ func (cp *ControlPlane) Start(ctx context.Context) error

+ func (cp *ControlPlane) Stop(ctx context.Context) error

+ type ControlPlaneParams struct

+ CheckpointName string

+ Config Config

+ HealthTracker *HealthTracker

+ IncomingSeqTracker *nclprotocol.SequenceTracker

+ Requester ncl.Publisher

+ type DataPlane struct

+ Client *nats.Conn

+ Dispatcher *dispatcher.Dispatcher

+ Publisher ncl.OrderedPublisher

+ func NewDataPlane(params DataPlaneParams) (*DataPlane, error)

+ func (dp *DataPlane) IsRunning() bool

+ func (dp *DataPlane) Start(ctx context.Context) error

+ func (dp *DataPlane) Stop(ctx context.Context) error

+ type DataPlaneParams struct

+ Client *nats.Conn

+ Config Config

+ LastReceivedSeqNum uint64

+ type HealthTracker struct

+ func NewHealthTracker(clock clock.Clock) *HealthTracker

+ func (ht *HealthTracker) GetHealth() nclprotocol.ConnectionHealth

+ func (ht *HealthTracker) GetState() nclprotocol.ConnectionState

+ func (ht *HealthTracker) HandshakeRequired()

+ func (ht *HealthTracker) HeartbeatSuccess()

+ func (ht *HealthTracker) IsHandshakeRequired() bool

+ func (ht *HealthTracker) MarkConnected()

+ func (ht *HealthTracker) MarkConnecting()

+ func (ht *HealthTracker) MarkDisconnected(err error)

+ func (ht *HealthTracker) UpdateSuccess()

v1.6.0-rc4

Dec 16, 2024

v1.6.0-rc3

Dec 11, 2024

v1.6.0-rc2

Dec 11, 2024

v1.6.0-rc1

Dec 11, 2024