Versions in this module Expand all Collapse all v0 v0.1.0 Apr 10, 2024 Changes in this version + type Address interface + ConnectionType func() AddressConnectionType + Equal func(other Address) bool + String func() string + type AddressConnectionType int32 + const ACTgRPC + const ACTgRPCS + const ACThttps + type AddressFactory interface + FromText func(text []byte) Address + type AddressIterator interface + GetNext func() Address + HasNext func() bool + Seek func(int) + func NewAddressIterator(addrs []Address) AddressIterator + type Filter struct + Indices []int + func ApplyFilters(filters []FilterUpdater) *Filter + type FilterUpdater func(*Filter) + func IndexFilter(index int) FilterUpdater + func ListFilter(indices []int) FilterUpdater + func RangeFilter(start, end int) FilterUpdater + func RotateFilter(n int) FilterUpdater + type Handler interface + Process func(req Request) (resp serde.Message, err error) + Stream func(out Sender, in Receiver) error + type Mino interface + CreateRPC func(name string, h Handler, f serde.Factory) (RPC, error) + GetAddress func() Address + GetAddressFactory func() AddressFactory + WithSegment func(segment string) Mino + type Players interface + AddressIterator func() AddressIterator + Len func() int + Take func(...FilterUpdater) Players + func NewAddresses(addrs ...Address) Players + type RPC interface + Call func(ctx context.Context, req serde.Message, players Players) (<-chan Response, error) + Stream func(ctx context.Context, players Players) (Sender, Receiver, error) + func MustCreateRPC(m Mino, name string, h Handler, f serde.Factory) RPC + type Receiver interface + Recv func(context.Context) (Address, serde.Message, error) + type Request struct + Address Address + Message serde.Message + type Response interface + GetFrom func() Address + GetMessageOrError func() (serde.Message, error) + func NewResponse(from Address, msg serde.Message) Response + func NewResponseWithError(from Address, err error) Response + type Sender interface + Send func(msg serde.Message, addrs ...Address) <-chan error + type UnsupportedHandler struct + func (h UnsupportedHandler) Process(req Request) (serde.Message, error) + func (h UnsupportedHandler) Stream(in Sender, out Receiver) error v0.0.1-alpha Mar 30, 2024
Go to main page