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

nodes

package

Go to main page

Versions in this module

v1

v1.6.5

Mar 6, 2025

v1.6.4

Feb 20, 2025

v1.6.3

Feb 4, 2025

v1.6.2

Jan 28, 2025

v1.6.2-rc1

Jan 28, 2025

v1.6.1

Jan 12, 2025

v1.6.1-rc1

Jan 12, 2025

v1.6.0

Dec 16, 2024

Changes in this version

+ const ConcurrentUpdate

+ const ConflictNodeState

+ const HandshakeRequired

+ const MultipleNodesFound

+ func NewErrConcurrentModification() bacerrors.Error

+ func NewErrHandshakeRequired(nodeID string) bacerrors.Error

+ func NewErrMultipleNodesFound(nodeIDPrefix string, matchingNodeIDs []string) bacerrors.Error

+ func NewErrNodeAlreadyApproved(nodeID string) bacerrors.Error

+ func NewErrNodeAlreadyRejected(nodeID string) bacerrors.Error

+ func NewErrNodeNotFound(nodeID string) bacerrors.Error

+ type ConnectionStateChangeHandler func(NodeConnectionEvent)

+ type ExtendedHeartbeatRequest struct

+ LastComputeSeqNum uint64

+ type ExtendedShutdownNoticeRequest struct

+ LastComputeSeqNum uint64

+ type Lookup interface

+ Get func(ctx context.Context, nodeID string) (models.NodeState, error)

+ GetByPrefix func(ctx context.Context, prefix string) (models.NodeState, error)

+ List func(ctx context.Context, filters ...NodeStateFilter) ([]models.NodeState, error)

+ type Manager interface

+ ApproveNode func(ctx context.Context, nodeID string) error

+ DeleteNode func(ctx context.Context, nodeID string) error

+ Handshake func(ctx context.Context, request messages.HandshakeRequest) (messages.HandshakeResponse, error)

+ Heartbeat func(ctx context.Context, request ExtendedHeartbeatRequest) (messages.HeartbeatResponse, error)

+ OnConnectionStateChange func(handler ConnectionStateChangeHandler)

+ RejectNode func(ctx context.Context, nodeID string) error

+ Running func() bool

+ ShutdownNotice func(ctx context.Context, request ExtendedShutdownNoticeRequest) (messages.ShutdownNoticeResponse, error)

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ UpdateNodeInfo func(ctx context.Context, request messages.UpdateNodeInfoRequest) (messages.UpdateNodeInfoResponse, error)

+ func NewManager(params ManagerParams) (Manager, error)

+ type ManagerParams struct

+ Clock clock.Clock

+ EventStore watcher.EventStore

+ HealthCheckFrequency time.Duration

+ ManualApproval bool

+ NodeDisconnectedAfter time.Duration

+ NodeInfoProvider models.NodeInfoProvider

+ PersistInterval time.Duration

+ PersistTimeout time.Duration

+ ShutdownTimeout time.Duration

+ Store Store

+ type MockLookup struct

+ func NewMockLookup(ctrl *gomock.Controller) *MockLookup

+ func (m *MockLookup) EXPECT() *MockLookupMockRecorder

+ func (m *MockLookup) Get(ctx context.Context, nodeID string) (models.NodeState, error)

+ func (m *MockLookup) GetByPrefix(ctx context.Context, prefix string) (models.NodeState, error)

+ func (m *MockLookup) List(ctx context.Context, filters ...NodeStateFilter) ([]models.NodeState, error)

+ type MockLookupMockRecorder struct

+ func (mr *MockLookupMockRecorder) Get(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockLookupMockRecorder) GetByPrefix(ctx, prefix interface{}) *gomock.Call

+ func (mr *MockLookupMockRecorder) List(ctx interface{}, filters ...interface{}) *gomock.Call

+ type MockManager struct

+ func NewMockManager(ctrl *gomock.Controller) *MockManager

+ func (m *MockManager) ApproveNode(ctx context.Context, nodeID string) error

+ func (m *MockManager) DeleteNode(ctx context.Context, nodeID string) error

+ func (m *MockManager) EXPECT() *MockManagerMockRecorder

+ func (m *MockManager) Get(ctx context.Context, nodeID string) (models.NodeState, error)

+ func (m *MockManager) GetByPrefix(ctx context.Context, prefix string) (models.NodeState, error)

+ func (m *MockManager) Handshake(ctx context.Context, request messages.HandshakeRequest) (messages.HandshakeResponse, error)

+ func (m *MockManager) Heartbeat(ctx context.Context, request ExtendedHeartbeatRequest) (messages.HeartbeatResponse, error)

+ func (m *MockManager) List(ctx context.Context, filters ...NodeStateFilter) ([]models.NodeState, error)

+ func (m *MockManager) OnConnectionStateChange(handler ConnectionStateChangeHandler)

+ func (m *MockManager) RejectNode(ctx context.Context, nodeID string) error

+ func (m *MockManager) Running() bool

+ func (m *MockManager) Start(ctx context.Context) error

+ func (m *MockManager) Stop(ctx context.Context) error

+ func (m *MockManager) UpdateNodeInfo(ctx context.Context, request messages.UpdateNodeInfoRequest) (messages.UpdateNodeInfoResponse, error)

+ type MockManagerMockRecorder struct

+ func (mr *MockManagerMockRecorder) ApproveNode(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) DeleteNode(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Get(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) GetByPrefix(ctx, prefix interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Handshake(ctx, request interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Heartbeat(ctx, request interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) List(ctx interface{}, filters ...interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) OnConnectionStateChange(handler interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) RejectNode(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Running() *gomock.Call

+ func (mr *MockManagerMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) Stop(ctx interface{}) *gomock.Call

+ func (mr *MockManagerMockRecorder) UpdateNodeInfo(ctx, request interface{}) *gomock.Call

+ type MockStore struct

+ func NewMockStore(ctrl *gomock.Controller) *MockStore

+ func (m *MockStore) Delete(ctx context.Context, nodeID string) error

+ func (m *MockStore) EXPECT() *MockStoreMockRecorder

+ func (m *MockStore) Get(ctx context.Context, nodeID string) (models.NodeState, error)

+ func (m *MockStore) GetByPrefix(ctx context.Context, prefix string) (models.NodeState, error)

+ func (m *MockStore) List(ctx context.Context, filters ...NodeStateFilter) ([]models.NodeState, error)

+ func (m *MockStore) Put(ctx context.Context, nodeInfo models.NodeState) error

+ type MockStoreMockRecorder struct

+ func (mr *MockStoreMockRecorder) Delete(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) Get(ctx, nodeID interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) GetByPrefix(ctx, prefix interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) List(ctx interface{}, filters ...interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) Put(ctx, nodeInfo interface{}) *gomock.Call

+ type NodeConnectionEvent struct

+ Current models.NodeConnectionState

+ NodeID string

+ Previous models.NodeConnectionState

+ Timestamp time.Time

+ type NodeStateFilter func(models.NodeState) bool

+ type Store interface

+ Delete func(ctx context.Context, nodeID string) error

+ Put func(ctx context.Context, state models.NodeState) error

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