jay/go-honeybee
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Rename to initiator/responder pattern.

Browse Source
This commit is contained in:
Jay
2026-04-16 23:05:44 -04:00
parent 660324b7b3
commit 2fe269f128
2 changed files with 26 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
pool.go
View File

@@ -140,14 +140,14 @@ func (p *pool) send(id string, data []byte) error {
return peer.conn.Send(data) return peer.conn.Send(data)
} }
// Outbound Pool // Initiator Pool
type OutboundPool struct { type InitiatorPool struct {
*pool *pool
dialer Dialer dialer Dialer
} }
func NewOutboundPool(config *PoolConfig, logger *slog.Logger) (*OutboundPool, error) { func NewInitiatorPool(config *PoolConfig, logger *slog.Logger) (*InitiatorPool, error) {
if config == nil { if config == nil {
config = GetDefaultPoolConfig() config = GetDefaultPoolConfig()
} }
@@ -156,7 +156,7 @@ func NewOutboundPool(config *PoolConfig, logger *slog.Logger) (*OutboundPool, er
return nil, err return nil, err
} }
p := &OutboundPool{ p := &InitiatorPool{
pool: &pool{ pool: &pool{
peers: make(map[string]*peer), peers: make(map[string]*peer),
inbox: make(chan InboxMessage, 256), inbox: make(chan InboxMessage, 256),
@@ -172,27 +172,27 @@ func NewOutboundPool(config *PoolConfig, logger *slog.Logger) (*OutboundPool, er
return p, nil return p, nil
} }
func (p *OutboundPool) Peers() map[string]*peer { func (p *InitiatorPool) Peers() map[string]*peer {
return p.peers return p.peers
} }
func (p *OutboundPool) Inbox() chan InboxMessage { func (p *InitiatorPool) Inbox() chan InboxMessage {
return p.inbox return p.inbox
} }
func (p *OutboundPool) Events() chan PoolEvent { func (p *InitiatorPool) Events() chan PoolEvent {
return p.events return p.events
} }
func (p *OutboundPool) Errors() chan error { func (p *InitiatorPool) Errors() chan error {
return p.errors return p.errors
} }
func (p *OutboundPool) Close() { func (p *InitiatorPool) Close() {
p.closeAll() p.closeAll()
} }
func (p *OutboundPool) Connect(url string) error { func (p *InitiatorPool) Connect(url string) error {
url, err := NormalizeURL(url) url, err := NormalizeURL(url)
if err != nil { if err != nil {
return err return err
@@ -258,7 +258,7 @@ func (p *OutboundPool) Connect(url string) error {
return nil return nil
} }
func (p *OutboundPool) Remove(url string) error { func (p *InitiatorPool) Remove(url string) error {
url, err := NormalizeURL(url) url, err := NormalizeURL(url)
if err != nil { if err != nil {
return err return err
@@ -267,7 +267,7 @@ func (p *OutboundPool) Remove(url string) error {
return p.removePeer(url) return p.removePeer(url)
} }
func (p *OutboundPool) Send(url string, data []byte) error { func (p *InitiatorPool) Send(url string, data []byte) error {
url, err := NormalizeURL(url) url, err := NormalizeURL(url)
if err != nil { if err != nil {
return err return err
@@ -276,29 +276,29 @@ func (p *OutboundPool) Send(url string, data []byte) error {
return p.send(url, data) return p.send(url, data)
} }
// Inbound Pool // Responder Pool
type InboundPool struct { type ResponderPool struct {
*pool *pool
idGenerator func() string idGenerator func() string
} }
func (p *InboundPool) Peers() map[string]*peer { func (p *ResponderPool) Peers() map[string]*peer {
return p.peers return p.peers
} }
func (p *InboundPool) Inbox() chan InboxMessage { func (p *ResponderPool) Inbox() chan InboxMessage {
return p.inbox return p.inbox
} }
func (p *InboundPool) Events() chan PoolEvent { func (p *ResponderPool) Events() chan PoolEvent {
return p.events return p.events
} }
func (p *InboundPool) Errors() chan error { func (p *ResponderPool) Errors() chan error {
return p.errors return p.errors
} }
func (p *InboundPool) Close() { func (p *ResponderPool) Close() {
p.closeAll() p.closeAll()
} }

14
pool_test.go
View File

@@ -18,7 +18,7 @@ func TestPoolConnect(t *testing.T) {
}, },
} }
pool, err := NewOutboundPool(nil, nil) pool, err := NewInitiatorPool(nil, nil)
assert.NoError(t, err) assert.NoError(t, err)
pool.dialer = mockDialer pool.dialer = mockDialer
@@ -49,7 +49,7 @@ func TestPoolConnect(t *testing.T) {
}, },
} }
pool, err := NewOutboundPool(nil, nil) pool, err := NewInitiatorPool(nil, nil)
assert.NoError(t, err) assert.NoError(t, err)
pool.dialer = mockDialer pool.dialer = mockDialer
@@ -69,7 +69,7 @@ func TestPoolConnect(t *testing.T) {
}) })
t.Run("fails to add connection", func(t *testing.T) { t.Run("fails to add connection", func(t *testing.T) {
pool, err := NewOutboundPool( pool, err := NewInitiatorPool(
&PoolConfig{ &PoolConfig{
ConnectionConfig: &ConnectionConfig{ ConnectionConfig: &ConnectionConfig{
Retry: &RetryConfig{ Retry: &RetryConfig{
@@ -111,7 +111,7 @@ func TestPoolRemove(t *testing.T) {
}, },
} }
pool, err := NewOutboundPool(nil, nil) pool, err := NewInitiatorPool(nil, nil)
assert.NoError(t, err) assert.NoError(t, err)
pool.dialer = mockDialer pool.dialer = mockDialer
@@ -139,7 +139,7 @@ func TestPoolRemove(t *testing.T) {
}, },
} }
pool, err := NewOutboundPool(nil, nil) pool, err := NewInitiatorPool(nil, nil)
assert.NoError(t, err) assert.NoError(t, err)
pool.dialer = mockDialer pool.dialer = mockDialer
@@ -156,7 +156,7 @@ func TestPoolRemove(t *testing.T) {
}, },
} }
pool, err := NewOutboundPool(nil, nil) pool, err := NewInitiatorPool(nil, nil)
assert.NoError(t, err) assert.NoError(t, err)
pool.dialer = mockDialer pool.dialer = mockDialer
@@ -183,7 +183,7 @@ func TestPoolSend(t *testing.T) {
}, },
} }
pool, err := NewOutboundPool(nil, nil) pool, err := NewInitiatorPool(nil, nil)
assert.NoError(t, err) assert.NoError(t, err)
pool.dialer = mockDialer pool.dialer = mockDialer