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

test

package

Go to main page

Versions in this module

v1

v1.6.1-rc1

Jan 12, 2025

v1.6.0

Dec 16, 2024

Changes in this version

+ type MockCheckpointer struct

+ func NewMockCheckpointer() *MockCheckpointer

+ func (m *MockCheckpointer) Checkpoint(ctx context.Context, name string, sequenceNumber uint64) error

+ func (m *MockCheckpointer) GetCheckpoint(ctx context.Context, name string) (uint64, error)

+ func (m *MockCheckpointer) GetStoredCheckpoint(name string) (uint64, error)

+ func (m *MockCheckpointer) OnCheckpointGet(callback func(name string))

+ func (m *MockCheckpointer) OnCheckpointSet(callback func(name string, value uint64))

+ func (m *MockCheckpointer) Reset()

+ func (m *MockCheckpointer) SetCheckpoint(name string, value uint64)

+ func (m *MockCheckpointer) SetCheckpointError(name string, err error)

+ func (m *MockCheckpointer) SetGetCheckpointError(name string, err error)

+ type MockLogStreamServer struct

+ func (m *MockLogStreamServer) GetLogStream(ctx context.Context, request messages.ExecutionLogsRequest) (<-chan *concurrency.AsyncResult[models.ExecutionLog], error)

+ type MockMessageCreator struct

+ Error error

+ Message *envelope.Message

+ func (c *MockMessageCreator) CreateMessage(event watcher.Event) (*envelope.Message, error)

+ func (c *MockMessageCreator) SetNextMessage(msg *envelope.Message)

+ type MockMessageCreatorFactory struct

+ func NewMockMessageCreatorFactory(nodeID string) *MockMessageCreatorFactory

+ func (f *MockMessageCreatorFactory) CreateMessageCreator(ctx context.Context, nodeID string) (nclprotocol.MessageCreator, error)

+ func (f *MockMessageCreatorFactory) GetCreator() *MockMessageCreator

+ func (f *MockMessageCreatorFactory) SetCreateError(err error)

+ type MockMessageHandler struct

+ func NewMockMessageHandler() *MockMessageHandler

+ func (m *MockMessageHandler) GetMessages() []envelope.Message

+ func (m *MockMessageHandler) HandleMessage(ctx context.Context, msg *envelope.Message) error

+ func (m *MockMessageHandler) SetError(err error)

+ func (m *MockMessageHandler) ShouldProcess(ctx context.Context, msg *envelope.Message) bool

+ type MockNodeInfoProvider struct

+ func NewMockNodeInfoProvider() *MockNodeInfoProvider

+ func (m *MockNodeInfoProvider) GetNodeInfo(ctx context.Context) models.NodeInfo

+ func (m *MockNodeInfoProvider) SetNodeInfo(nodeInfo models.NodeInfo)

+ type MockResponder struct

+ func NewMockResponder(ctx context.Context, conn *nats.Conn, behavior *MockResponderBehavior) (*MockResponder, error)

+ func (m *MockResponder) Behaviour() *MockResponderBehavior

+ func (m *MockResponder) Close(ctx context.Context) error

+ func (m *MockResponder) GetHandshakes() []messages.HandshakeRequest

+ func (m *MockResponder) GetHeartbeats() []messages.HeartbeatRequest

+ func (m *MockResponder) GetNodeInfos() []messages.UpdateNodeInfoRequest

+ func (m *MockResponder) GetShutdowns() []messages.ShutdownNoticeRequest

+ type MockResponderBehavior struct

+ HandshakeResponse struct{ ... }

+ HeartbeatResponse struct{ ... }

+ NodeInfoResponse struct{ ... }

+ OnHandshake func(messages.HandshakeRequest)

+ OnHeartbeat func(messages.HeartbeatRequest)

+ OnNodeInfo func(messages.UpdateNodeInfoRequest)

+ OnShutdown func(messages.ShutdownNoticeRequest)

+ ShutdownResponse struct{ ... }

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