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

replicaclient

package module

Go to main page

Versions in this module

v0

v0.1.7

Jan 12, 2023

Changes in this version

type ReplicaClient

+ func (c *ReplicaClient) SendMessageWithID(id string, t string, to types.ReplicaID, msg []byte) error

v0.1.6

Sep 26, 2022

Changes in this version

type MessageQueue

+ func (q *MessageQueue) Block()

+ func (q *MessageQueue) UnBlock()

v0.1.5

Jun 3, 2022

v0.1.4

Jun 3, 2022

v0.1.3

Jun 2, 2022

v0.1.2

May 20, 2022

v0.1.1

May 16, 2022

v0.1.0

Feb 11, 2022

Changes in this version

+ var ErrNoClientServerAddr = errors.New("client server address should not be empty")

+ var ErrNoNetrixAddr = errors.New("Netrix addr should not be empty")

+ var ErrNoReplicaID = errors.New("replica ID config should not be empty")

+ var MessageReceiveEventType = "MessageReceive"

+ var MessageSendEventType = "MessageSend"

+ var TimeoutEndEventType = "TimeoutEnd"

+ var TimeoutStartEventType = "TimeoutStart"

+ func Init(config *Config, d DirectiveHandler, logger Logger) error

+ type Config struct

+ ClientAdvAddr string

+ ClientServerAddr string

+ Info map[string]interface{}

+ NetrixAddr string

+ ReplicaID types.ReplicaID

+ type Counter struct

+ func NewCounter() *Counter

+ func (id *Counter) Next() int

+ func (id *Counter) NextID(from, to types.ReplicaID) string

+ func (id *Counter) Reset()

+ type DirectiveHandler interface

+ Restart func() error

+ Start func() error

+ Stop func() error

+ type Logger interface

+ Debug func(msg string, keyvals ...interface{})

+ Error func(msg string, keyvals ...interface{})

+ Info func(msg string, keyvals ...interface{})

+ type MessageQueue struct

+ func NewMessageQueue() *MessageQueue

+ func (q *MessageQueue) Add(m *types.Message)

+ func (q *MessageQueue) Flush()

+ func (q *MessageQueue) Pop() (*types.Message, bool)

+ type ReplicaClient struct

+ func GetClient() (*ReplicaClient, error)

+ func NewReplicaClient(config *Config, directiveHandler DirectiveHandler, logger Logger) (*ReplicaClient, error)

+ func (c *ReplicaClient) IsReady() bool

+ func (c *ReplicaClient) IsRunning() bool

+ func (c *ReplicaClient) Log(params map[string]interface{}, message string)

+ func (c *ReplicaClient) LogAsync(params map[string]interface{}, message string)

+ func (c *ReplicaClient) NotReady()

+ func (c *ReplicaClient) PublishEvent(t string, params map[string]string)

+ func (c *ReplicaClient) PublishEventAsync(t string, params map[string]string)

+ func (c *ReplicaClient) Ready()

+ func (c *ReplicaClient) ReceiveMessage() (*types.Message, bool)

+ func (c *ReplicaClient) SendMessage(t string, to types.ReplicaID, msg []byte, intercept bool) error

+ func (c *ReplicaClient) Start() error

+ func (c *ReplicaClient) StartTimer(i TimeoutInfo)

+ func (c *ReplicaClient) Stop() error

+ func (c *ReplicaClient) TimeoutChan() chan TimeoutInfo

+ type TimeoutInfo interface

+ Duration func() time.Duration

+ Key func() string