adaptiveservice

Nov 7, 2023

Changes in this version

+ const DefaultQSizePerCore

+ const DefaultQWeight

type Client

+ func (c *Client) SetProviderSelectionMethod(method ProviderSelectionMethod) *Client

+ type MsgQInfo struct

+ BusyWorkerNum int

+ IdleWorkerNum int

+ NumCPU int

+ QueueLen int

+ QueueSize int

+ QueueWeight int

+ ResidentWorkers int

+ type ProviderSelectionMethod uint16

+ const Capacity

+ const Invalid

+ const Latency

+ type QueryMsgQInfo struct

+ func (msg QueryMsgQInfo) Handle(stream ContextStream) (reply any)

Oct 7, 2023

Changes in this version

+ func TraceMsgByNameWithFilters(name string, count uint32, filters []string) (token string, err error)

+ func TraceMsgByTypeWithFilters(msg any, count uint32, filters []string) (token string, err error)

Sep 22, 2023

Changes in this version

+ const MaxTracingSessions

+ func ReadAllTracedMsg() (string, error)

+ func TraceMsgByNameWithCount(name string, count uint32) (token string, err error)

+ func TraceMsgByTypeWithCount(msg any, count uint32) (token string, err error)

+ func UnTraceMsgAll()

Sep 19, 2023

Changes in this version

+ func GetKnownMessageTypes() []string

+ func GetRegisteredTypeByName(name string) reflect.Type

+ func TraceMsgByName(name string) (token string, err error)

Sep 18, 2023

Changes in this version

+ const SrvMessageTracing

+ func ReadTracedMsg(token string) (string, error)

+ func TraceMsgByType(msg any) (token string, err error)

type Server

+ func (s *Server) EnableMessageTracer() *Server

type ServiceOption

+ func OnStreamCloseFunc(fn func(Context)) ServiceOption

type Stream

+ Close func()

Aug 18, 2023

Changes in this version

+ func RegisterTypeNoPanic(i interface{}) (err error)

Jul 11, 2022

Changes in this version

type Server

+ func (s *Server) SetScaleFactors(residentWorkers, qSizePerCore int) *Server

Dec 31, 2021

Changes in this version

+ var ErrRecvTimeout = errors.New("receive timeout")

type Stream

+ SetRecvTimeout func(d time.Duration)

Dec 7, 2021

Changes in this version

type Server

+ func (s *Server) CloseWait()

Nov 17, 2021

Changes in this version

+ const ScopeNetwork

type Server

+ func (s *Server) PublishIn(scope Scope, serviceName string, knownMessages []KnownMessage, ...) error

Oct 31, 2021

Changes in this version

+ const SrvIPObserver

+ const SrvLANRegistry

+ const SrvProviderInfo

+ const SrvRegistryInfo

+ const SrvReverseProxy

+ const SrvServiceLister

+ func NewStreamIO(stream Stream) io.ReadWriteCloser

+ type GetObservedIP struct

+ func (msg GetObservedIP) Handle(stream ContextStream) (reply interface{})

type Server

+ func (s *Server) EnableIPObserver() *Server

type Stream

+ GetNetconn func() Netconn

Sep 27, 2021

Changes in this version

type Stream

+ Read func(p []byte) (n int, err error)

+ Write func(p []byte) (n int, err error)

Sep 9, 2021

Changes in this version

+ const BuiltinPublisher

+ var ErrBadMessage = errors.New("message not supported")

+ var ErrConnReset = errors.New("connection reset by peer")

+ var ErrServerClosed = errors.New("server closed by signal")

+ var ErrServiceNotFound = errors.New("service not found")

+ var ErrServiceNotReachable = errors.New("service not reachable")

+ func RegisterType(i interface{})

+ type Client struct

+ func NewClient(options ...Option) *Client

+ func (c *Client) Discover(publisher, service string, providerIDs ...string) <-chan Connection

+ func (c *Client) SetDeepCopy() *Client

+ func (c *Client) SetDiscoverTimeout(timeout int) *Client

+ type Connection interface

+ Close func()

+ NewStream func() Stream

+ type Context interface

+ GetContext func() interface{}

+ GetVar func(v interface{})

+ PutVar func(v interface{})

+ SetContext func(v interface{})

+ type ContextStream interface

+ type HighPriorityMessage interface

+ IsHighPriority func()

+ type KnownMessage interface

+ Handle func(stream ContextStream) (reply interface{})

+ type ListService struct

+ Publisher string

+ Service string

+ TargetScope Scope

+ func (msg *ListService) Handle(stream ContextStream) (reply interface{})

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type LoggerAll struct

+ func (LoggerAll) Debugf(format string, args ...interface{})

+ func (LoggerAll) Errorf(format string, args ...interface{})

+ func (LoggerAll) Infof(format string, args ...interface{})

+ func (LoggerAll) Warnf(format string, args ...interface{})

+ type LoggerNull struct

+ func (LoggerNull) Debugf(format string, args ...interface{})

+ func (LoggerNull) Errorf(format string, args ...interface{})

+ func (LoggerNull) Infof(format string, args ...interface{})

+ func (LoggerNull) Warnf(format string, args ...interface{})

+ type LowPriorityMessage interface

+ IsLowPriority func()

+ type Netconn interface

+ Close func() error

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ type Option func(*conf)

+ func WithLogger(lg Logger) Option

+ func WithProviderID(id string) Option

+ func WithQsize(size int) Option

+ func WithRegistryAddr(addr string) Option

+ func WithScope(scope Scope) Option

+ type ReqProviderInfo struct

+ func (msg *ReqProviderInfo) Handle(stream ContextStream) (reply interface{})

+ type Scope int

+ const OK

+ const ScopeAll

+ const ScopeLAN

+ const ScopeOS

+ const ScopeProcess

+ const ScopeWAN

+ type Server struct

+ func NewServer(options ...Option) *Server

+ func (s *Server) Close()

+ func (s *Server) DisableMsgTypeCheck() *Server

+ func (s *Server) EnableAutoReverseProxy() *Server

+ func (s *Server) EnableRootRegistry() *Server

+ func (s *Server) EnableServiceLister() *Server

+ func (s *Server) Publish(serviceName string, knownMessages []KnownMessage, options ...ServiceOption) error

+ func (s *Server) Serve() error

+ func (s *Server) SetBroadcastPort(port string) *Server

+ func (s *Server) SetPublisher(publisher string) *Server

+ func (s *Server) SetScaleFactor(qWeight, qScale int) *Server

+ type ServiceInfo struct

+ Addr string

+ ProviderID string

+ Publisher string

+ Service string

+ type ServiceOption func(*service)

+ func OnConnectFunc(fn func(Netconn) bool) ServiceOption

+ func OnDisconnectFunc(fn func(Netconn)) ServiceOption

+ func OnNewStreamFunc(fn func(Context)) ServiceOption

+ type Stream interface

+ Recv func(msgPtr interface{}) error

+ Send func(msg interface{}) error

+ SendRecv func(msgSnd interface{}, msgRcvPtr interface{}) error