wire

Nov 18, 2024

Changes in this version

type Account

+ Sign func(msg []byte) ([]byte, error)

type Address

+ Verify func(msg []byte, sig []byte) error

type AuthResponseMsg

+ Signature []byte

Jul 15, 2022

Changes in this version

+ func SetNewAddressFunc(f NewAddressFunc)

type Account

+ Address func() Address

+ type AddrKey string

+ func Key(a Address) AddrKey

type Address

+ Cmp func(Address) int

+ Equal func(Address) bool

+ type NewAddressFunc = func() Address

Apr 14, 2022

Changes in this version

type Bus

+ func NewHybridBus(buses ...Bus) Bus

Feb 25, 2022

Changes in this version

+ func EncodeMsg(msg Msg, w io.Writer) error

type Address

+ func NewAddress() Address

type Cache

+ func MakeCache() Cache

+ func (c *Cache) Messages(p Predicate) []*Envelope

+ func (c *Cache) Release(p *Predicate)

+ type EnvelopeSerializer interface

+ Decode func(r io.Reader) (*Envelope, error)

+ Encode func(w io.Writer, env *Envelope) error

type Msg

+ func DecodeMsg(r io.Reader) (Msg, error)

+ type PingPongMsg struct

+ Created time.Time

+ func (m *PingPongMsg) Decode(reader io.Reader) error

+ func (m PingPongMsg) Encode(writer io.Writer) error

type Relay

+ func (p *Relay) ReleaseCache(predicate *Predicate)

Jul 14, 2021

Changes in this version

type Type

+ const VirtualChannelFundingProposal

+ const VirtualChannelProposal

+ const VirtualChannelProposalAcc

+ const VirtualChannelSettlementProposal

Nov 5, 2020

Changes in this version

type Type

+ const LedgerChannelProposalAcc

+ const SubChannelProposalAcc

Oct 17, 2020

Changes in this version

+ func IndexOfAddr(addrs []Address, addr Address) int

type Addresses

+ func (a Addresses) Decode(r stdio.Reader) error

+ func (a Addresses) Encode(w stdio.Writer) error

type AddressesWithLen

+ func (a *AddressesWithLen) Decode(r stdio.Reader) error

+ func (a AddressesWithLen) Encode(w stdio.Writer) error

type Type

+ const SubChannelProposal

Sep 22, 2020

Changes in this version

type Type

+ const LedgerChannelProposal

Jul 23, 2020

Changes in this version

+ func RegisterDecoder(t Type, decoder func(io.Reader) (Msg, error))

+ func RegisterExternalDecoder(t Type, decoder func(io.Reader) (Msg, error), name string)

+ func TestMsg(t *testing.T, msg Msg)

+ type Account = wallet.Account

+ type Address = wallet.Address

+ func DecodeAddress(r stdio.Reader) (Address, error)

+ type Addresses = wallet.Addresses

+ type AddressesWithLen = wallet.AddressesWithLen

+ type AuthResponseMsg struct

+ func (m *AuthResponseMsg) Decode(r io.Reader) (err error)

+ func (m *AuthResponseMsg) Encode(w io.Writer) error

+ func (m *AuthResponseMsg) Type() Type

+ type Bus interface

+ SubscribeClient func(c Consumer, clientAddr Address) error

+ type Cache struct

+ func (c *Cache) Cache(ctx context.Context, p Predicate)

+ func (c *Cache) Flush()

+ func (c *Cache) Get(p Predicate) []*Envelope

+ func (c *Cache) Put(e *Envelope) bool

+ func (c *Cache) Size() int

+ type Cacher interface

+ Cache func(context.Context, Predicate)

+ type Consumer interface

+ Put func(*Envelope)

+ type Envelope struct

+ Msg Msg

+ Recipient Address

+ Sender Address

+ func (env *Envelope) Decode(r io.Reader) (err error)

+ func (env *Envelope) Encode(w io.Writer) error

+ type LocalBus struct

+ func NewLocalBus() *LocalBus

+ func (h *LocalBus) Publish(ctx context.Context, e *Envelope) error

+ func (h *LocalBus) SubscribeClient(c Consumer, receiver Address) error

+ type Msg interface

+ Type func() Type

+ func NewAuthResponseMsg(_ Account) Msg

+ type PingMsg struct

+ func NewPingMsg() *PingMsg

+ func (m *PingMsg) Decode(reader io.Reader) error

+ func (m *PingMsg) Type() Type

+ func (m PingMsg) Encode(writer io.Writer) error

+ type PongMsg struct

+ func NewPongMsg() *PongMsg

+ func (m *PongMsg) Decode(reader io.Reader) error

+ func (m *PongMsg) Type() Type

+ func (m PongMsg) Encode(writer io.Writer) error

+ type Predicate = func(*Envelope) bool

+ type Publisher interface

+ Publish func(context.Context, *Envelope) error

+ type Receiver struct

+ func NewReceiver() *Receiver

+ func (r *Receiver) Next(ctx context.Context) (*Envelope, error)

+ func (r *Receiver) Put(e *Envelope)

+ type Relay struct

+ func NewRelay() *Relay

+ func (p *Relay) Cache(ctx context.Context, predicate Predicate)

+ func (p *Relay) Close() error

+ func (p *Relay) Put(e *Envelope)

+ func (p *Relay) SetDefaultMsgHandler(handler func(*Envelope))

+ func (p *Relay) Subscribe(c Consumer, predicate Predicate) error

+ type ShutdownMsg struct

+ Reason string

+ func (m *ShutdownMsg) Decode(r io.Reader) error

+ func (m *ShutdownMsg) Encode(w io.Writer) error

+ func (m *ShutdownMsg) Type() Type

+ type Subscriber interface

+ Subscribe func(Consumer, Predicate) error

+ type Type uint8

+ const AuthResponse

+ const ChannelProposal

+ const ChannelProposalAcc

+ const ChannelProposalRej

+ const ChannelSync

+ const ChannelUpdate

+ const ChannelUpdateAcc

+ const ChannelUpdateRej

+ const LastType

+ const Ping

+ const Pong

+ const Shutdown

+ func (t Type) String() string

+ func (t Type) Valid() bool

Dec 20, 2019

Changes in this version

+ func Decode(reader io.Reader, values ...interface{}) (err error)

+ func Encode(writer io.Writer, values ...interface{}) (err error)

+ type BigInt struct

+ func (b *BigInt) Decode(reader io.Reader) error

+ func (b BigInt) Encode(writer io.Writer) error

+ type ByteSlice []byte

+ func (b *ByteSlice) Decode(r io.Reader) error

+ func (b ByteSlice) Encode(w io.Writer) error