tars

Jan 11, 2024

Changes in this version

+ type Option func(o *options)

+ func Registrar(r registry.Registrar) Option

Apr 26, 2023

Changes in this version

type ServantProxy

+ func (s *ServantProxy) Endpoints() []*endpoint.Endpoint

Feb 14, 2023

Changes in this version

type ObjCache

+ SetID string

+ type ServerConfOption func(*transport.TarsServerConf)

+ func WithMaxInvoke(maxInvoke int32) ServerConfOption

+ func WithQueueCap(queueCap int) ServerConfOption

+ func WithTlsConfig(tlsConfig *tls.Config) ServerConfOption

Aug 9, 2022

Changes in this version

+ func Hash(str string) uint32

+ func HashNew(str string) uint32

+ func HashString(str string) uint32

+ func MagicStringHash(str string) uint32

+ type HttpHandler interface

+ SetConfig func(cfg *TarsHttpConf)

type Message

+ func (m *Message) HashCode() uint32

+ func (m *Message) HashType() selector.HashType

+ func (m *Message) IsHash() bool

type TarsHttpMux

+ func (mux *TarsHttpMux) GetGinEngine() *gin.Engine

Jun 27, 2022

Changes in this version

+ func AddAppConfig(filename string) (config string, err error)

+ func AddConfig(filename string) (config string, err error)

+ func GetConf() *conf.Conf

+ func GetConfigList() (fList []string, err error)

type Communicator

+ func GetCommunicator() *Communicator

+ type EndpointManagerOption interface

+ type OptionFunc struct

+ func WithSet(setDivision string) OptionFunc

type RConf

+ func GetRConf() *RConf

+ func (c *RConf) GetAppConfig(filename string) (config string, err error)

Apr 2, 2022

Changes in this version

type ServantProxy

+ func (s *ServantProxy) SetPushCallback(callback func([]byte))

Mar 12, 2022

Changes in this version

+ const NotifyError

+ const NotifyNormal

+ const NotifyWarn

+ const StatFailed

+ const StatSuccess

+ const Version

+ type Protocol struct

+ func (s *Protocol) DoClose(ctx context.Context)

+ func (s *Protocol) GetCloseMsg() []byte

+ func (s *Protocol) Invoke(ctx context.Context, req []byte) (rsp []byte)

+ func (s *Protocol) InvokeTimeout(pkg []byte) []byte

+ func (s *Protocol) ParsePackage(buff []byte) (int, int)

type RemoteTimeWriter

+ func (rw *RemoteTimeWriter) EnableSquareWrapper(hasSquareBracket bool)

+ func (rw *RemoteTimeWriter) EnableSuffix(hasSufix bool)

type ServantProxy

+ func (s *ServantProxy) TarsInvoke(ctx context.Context, cType byte, sFuncName string, buf []byte, ...) error

Mar 7, 2022

Changes in this version

+ const ZombieTimeout

+ func Trace(traceKey, annotation, client, server, funcName string, ret int, ...)

type Communicator

+ func (c *Communicator) SetTraceParam(name string)

type ServantProxy

+ func (s *ServantProxy) Name() string

Jan 13, 2022

Changes in this version

+ const ModuleName

+ const Property

+ const Stat

Jan 12, 2022

Changes in this version

+ func RegisterDispatchReporter(f DispatchReporter)

+ type DispatchReporter func(ctx context.Context, req []interface{}, rsp []interface{}, ...)

+ func GetDispatchReporter() DispatchReporter

Feb 9, 2021

Changes in this version

+ func GetErrorCode(err error) int32

+ func UseClientFilterMiddleware(cfm ...ClientFilterMiddleware)

+ func UseServerFilterMiddleware(sfm ...ServerFilterMiddleware)

+ type ClientFilterMiddleware func(next ClientFilter) ClientFilter

+ type Error struct

+ Code int32

+ Message string

+ func Errorf(code int32, format string, args ...interface{}) *Error

+ func (e *Error) Error() string

+ type ServerFilterMiddleware func(next ServerFilter) ServerFilter

type TarsProtocol

+ func (s *TarsProtocol) DoClose(ctx context.Context)

Jul 20, 2020

Changes in this version

type ServantProxy

+ func NewServantProxy(comm *Communicator, objName string) *ServantProxy

Jun 2, 2020

Changes in this version

+ var ServerConfigPath string

Apr 23, 2020

Changes in this version

+ const ClientDialTimeout

+ const MaxPackageLength

+ const NOTIFY_ERROR

+ const NOTIFY_NORMAL

+ const NOTIFY_WARN

+ const STAT_FAILED

+ const STAT_SUCCESS

+ const StatReportChannelBufLen

+ func AddHttpServantWithExceptionStatusChecker(mux *TarsHttpMux, obj string, exceptionStatusChecker func(int) bool)

+ func AddServantWithProtocol(proto transport.ServerProtocol, obj string)

+ func CheckPanic()

+ func DefaultExceptionStatusChecker(statusCode int) bool

+ func RegisterPostClientFilter(f ClientFilter)

+ func RegisterPostServerFilter(f ServerFilter)

+ func RegisterPreClientFilter(f ClientFilter)

+ func RegisterPreServerFilter(f ServerFilter)

+ func ReportAvg(key string, i int)

+ func ReportCount(key string, i int)

+ func ReportDistr(key string, in []int, i int)

+ func ReportMax(key string, i int)

+ func ReportMin(key string, i int)

+ func ReportSum(key string, i int)

type AdapterProxy

+ func NewAdapterProxy(point *endpointf.EndpointF, comm *Communicator) *AdapterProxy

+ type AppCache struct

+ LogLevel string

+ ModifyTime string

+ ObjCaches []ObjCache

+ TarsVersion string

+ func GetAppCache() AppCache

type Avg

+ func (a *Avg) Enum() ReportPolicy

type Count

+ func (c *Count) Enum() ReportPolicy

type Distr

+ func (d *Distr) Enum() ReportPolicy

type EndpointManager

+ func GetManager(comm *Communicator, objName string) EndpointManager

+ type HashType int

+ const ConsistentHash

+ const ModHash

type Max

+ func (m *Max) Enum() ReportPolicy

type Message

+ func (m *Message) SetHash(code uint32, h HashType)

type Min

+ func (m *Min) Enum() ReportPolicy

+ type ObjCache struct

+ Endpoints []endpointf.EndpointF

+ InactiveEndpoints []endpointf.EndpointF

+ Locator string

+ Name string

type PropertyReport

+ func GetPropertyReport(key string) *PropertyReport

type ReportMethod

+ Enum func() ReportPolicy

+ type ReportPolicy int

+ const ReportPolicyAvg

+ const ReportPolicyCount

+ const ReportPolicyDistr

+ const ReportPolicyMax

+ const ReportPolicyMin

+ const ReportPolicySum

+ const ReportPolicyUnknown

+ func (p ReportPolicy) String() string

type ServantProxy

+ func (s *ServantProxy) TarsSetProtocol(proto model.Protocol)

+ func (s *ServantProxy) TarsSetVersion(iVersion int16)

type Sum

+ func (s *Sum) Enum() ReportPolicy

type TarsHttpConf

+ ExceptionStatusChecker func(int) bool

type TarsResponseWriter

+ StatusCode int

+ func (w *TarsResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)

Apr 4, 2020

Changes in this version

+ const AcceptTimeout

+ const AdapterProxyResetCount

+ const AdapterProxyTicker

+ const AsyncInvokeTimeout

+ const ClientIdleTimeout

+ const ClientQueueLen

+ const ClientReadTimeout

+ const ClientWriteTimeout

+ const GracedownTimeout

+ const HandleTimeout

+ const IdleTimeout

+ const MainLoopTicker

+ const MaxlogOneTime

+ const ObjQueueMax

+ const PACKAGE_ERROR

+ const PACKAGE_FULL

+ const PACKAGE_LESS

+ const PropertyReportInterval

+ const QueueCap

+ const ReadTimeout

+ const ReqDefaultTimeout

+ const StatReportInterval

+ const TCPNoDelay

+ const TCPReadBuffer

+ const TCPWriteBuffer

+ const TarsVersion

+ const WriteTimeout

+ const ZombileTimeout

+ var MaxInvoke int32

+ var TLOG = rogger.GetLogger("TLOG")

+ func AddHttpServant(mux *TarsHttpMux, obj string)

+ func AddServant(v dispatch, f interface{}, obj string)

+ func AddServantWithContext(v dispatch, f interface{}, obj string)

+ func GetClientConfig() *clientConfig

+ func GetDayLogger(name string, numDay int) *rogger.Logger

+ func GetHourLogger(name string, numHour int) *rogger.Logger

+ func GetLogger(name string) *rogger.Logger

+ func GetRemoteLogger(name string) *rogger.Logger

+ func GetServerConfig() *serverConfig

+ func Init()

+ func RegisterAdmin(name string, fn adminFn)

+ func RegisterClientFilter(f ClientFilter)

+ func RegisterServerFilter(f ServerFilter)

+ func ReportNotifyInfo(info string)

+ func ReportStat(msg *Message, succ int32, timeout int32, exec int32)

+ func ReportStatBase(head *statf.StatMicMsgHead, body *statf.StatMicMsgBody, FromServer bool)

+ func ReportStatFromClient(msg *Message, succ int32, timeout int32, exec int32)

+ func ReportStatFromServer(InterfaceName, MasterName string, ReturnValue int32, TotalRspTime int64)

+ func Run()

+ func TarsRequest(rev []byte) (int, int)

+ type AdapterProxy struct

+ func (c *AdapterProxy) Close()

+ func (c *AdapterProxy) GetPoint() *endpointf.EndpointF

+ func (c *AdapterProxy) New(point *endpointf.EndpointF, comm *Communicator) error

+ func (c *AdapterProxy) ParsePackage(buff []byte) (int, int)

+ func (c *AdapterProxy) Recv(pkg []byte)

+ func (c *AdapterProxy) Send(req *requestf.RequestPacket) error

+ type Admin struct

+ func (a *Admin) Notify(command string) (string, error)

+ func (a *Admin) Shutdown() error

+ type Avg struct

+ func NewAvg() *Avg

+ func (a *Avg) Desc() string

+ func (a *Avg) Get() (out string)

+ func (a *Avg) Set(in int)

+ type ClientFilter func(ctx context.Context, msg *Message, invoke Invoke, timeout time.Duration) (err error)

+ type Communicator struct

+ Client *clientConfig

+ func NewCommunicator() *Communicator

+ func (c *Communicator) GetLocator() string

+ func (c *Communicator) GetProperty(key string) (string, bool)

+ func (c *Communicator) GetPropertyBool(key string) (bool, bool)

+ func (c *Communicator) GetPropertyInt(key string) (int, bool)

+ func (c *Communicator) SetLocator(obj string)

+ func (c *Communicator) SetProperty(key string, value interface{})

+ func (c *Communicator) StringToProxy(servant string, p ProxyPrx)

+ type Count struct

+ func NewCount() *Count

+ func (c *Count) Desc() string

+ func (c *Count) Get() (out string)

+ func (c *Count) Set(in int)

+ type Dispatch func(context.Context, interface{}, *requestf.RequestPacket, ...) error

+ type Distr struct

+ func NewDistr(in []int) (d *Distr)

+ func (d *Distr) Desc() string

+ func (d *Distr) Get() string

+ func (d *Distr) Set(in int)

+ type EndpointManager struct

+ func (e *EndpointManager) GetAllEndpoint() []*endpoint.Endpoint

+ func (e *EndpointManager) GetHashEndpoint(hashcode int64) *endpoint.Endpoint

+ func (e *EndpointManager) GetHashProxy(hashcode int64) *AdapterProxy

+ func (e *EndpointManager) GetNextEndpoint() *endpoint.Endpoint

+ func (e *EndpointManager) GetNextValidProxy() *AdapterProxy

+ func (e *EndpointManager) Init(objName string, comm *Communicator) error

+ func (e *EndpointManager) SelectAdapterProxy(msg *Message) *AdapterProxy

+ type Invoke func(ctx context.Context, msg *Message, timeout time.Duration) (err error)

+ type Max struct

+ func NewMax() *Max

+ func (m *Max) Desc() string

+ func (m *Max) Get() (out string)

+ func (m *Max) Set(in int)

+ type Message struct

+ Adp *AdapterProxy

+ BeginTime int64

+ EndTime int64

+ Obj *ObjectProxy

+ Req *requestf.RequestPacket

+ Resp *requestf.ResponsePacket

+ Ser *ServantProxy

+ Status int32

+ func (m *Message) Cost() int64

+ func (m *Message) End()

+ func (m *Message) Init()

+ func (m *Message) SetHashCode(code int64)

+ type Min struct

+ func NewMin() *Min

+ func (m *Min) Desc() string

+ func (m *Min) Get() (out string)

+ func (m *Min) Set(in int)

+ type NodeFHelper struct

+ func (n *NodeFHelper) KeepAlive(adapter string)

+ func (n *NodeFHelper) ReportVersion(version string)

+ func (n *NodeFHelper) SetNodeInfo(comm *Communicator, node string, app string, server string)

+ type NotifyHelper struct

+ func (n *NotifyHelper) ReportNotifyInfo(info string)

+ func (n *NotifyHelper) SetNotifyInfo(comm *Communicator, notify string, app string, server string, container string)

+ type ObjectProxy struct

+ func (obj *ObjectProxy) Init(comm *Communicator, objName string)

+ func (obj *ObjectProxy) Invoke(ctx context.Context, msg *Message, timeout time.Duration) error

+ type ObjectProxyFactory struct

+ func (o *ObjectProxyFactory) GetObjectProxy(objName string) *ObjectProxy

+ func (o *ObjectProxyFactory) Init(comm *Communicator)

+ type PropertyReport struct

+ func CreatePropertyReport(key string, argvs ...ReportMethod) (ptr *PropertyReport)

+ func (p *PropertyReport) Report(in int)

+ type PropertyReportHelper struct

+ var ProHelper *PropertyReportHelper

+ func (p *PropertyReportHelper) AddToReport(pr *PropertyReport)

+ func (p *PropertyReportHelper) Init(comm *Communicator, node string)

+ func (p *PropertyReportHelper) ReportToServer()

+ func (p *PropertyReportHelper) Run()

+ type ProxyPrx interface

+ SetServant func(s.Servant)

+ type RConf struct

+ func NewRConf(app string, server string, path string) *RConf

+ func (c *RConf) GetConfig(filename string) (config string, err error)

+ func (c *RConf) GetConfigList() (flist []string, err error)

+ type RemoteTimeWriter struct

+ func NewRemoteTimeWriter() *RemoteTimeWriter

+ func (rw *RemoteTimeWriter) EnablePrefix(hasAppNamePrefix bool)

+ func (rw *RemoteTimeWriter) EnableSqarewrapper(hasSquareBracket bool)

+ func (rw *RemoteTimeWriter) EnableSufix(hasSufix bool)

+ func (rw *RemoteTimeWriter) InitFormat(s string)

+ func (rw *RemoteTimeWriter) InitServerInfo(app string, server string, filename string, setdivision string)

+ func (rw *RemoteTimeWriter) NeedPrefix() bool

+ func (rw *RemoteTimeWriter) SetFileNameConcatStr(s string)

+ func (rw *RemoteTimeWriter) SetLogType(logType string)

+ func (rw *RemoteTimeWriter) SetPrefix(enable bool)

+ func (rw *RemoteTimeWriter) SetSeparator(s string)

+ func (rw *RemoteTimeWriter) Sync2remote()

+ func (rw *RemoteTimeWriter) Write(b []byte)

+ type ReportMethod interface

+ Desc func() string

+ Get func() string

+ Set func(int)

+ type ServantProxy struct

+ func Dail(servant string) *ServantProxy

+ func (s *ServantProxy) Init(comm *Communicator, objName string)

+ func (s *ServantProxy) TarsSetHashCode(code int64)

+ func (s *ServantProxy) TarsSetTimeout(t int)

+ func (s *ServantProxy) Tars_invoke(ctx context.Context, ctype byte, sFuncName string, buf []byte, ...) error

+ type ServantProxyFactory struct

+ func (o *ServantProxyFactory) GetServantProxy(objName string) *ServantProxy

+ func (o *ServantProxyFactory) Init(comm *Communicator)

+ type ServerFilter func(ctx context.Context, d Dispatch, f interface{}, req *requestf.RequestPacket, ...) (err error)

+ type StatFHelper struct

+ var StatReport *StatFHelper

+ func (s *StatFHelper) Init(comm *Communicator, node string)

+ func (s *StatFHelper) ReportMicMsg(stStatInfo StatInfo, fromServer bool)

+ func (s *StatFHelper) Run()

+ type StatInfo struct

+ Body statf.StatMicMsgBody

+ Head statf.StatMicMsgHead

+ type Sum struct

+ func NewSum() *Sum

+ func (s *Sum) Desc() string

+ func (s *Sum) Get() (out string)

+ func (s *Sum) Set(in int)

+ type TarsHttpConf struct

+ AppName string

+ Container string

+ IP string

+ Port int32

+ SetId string

+ Version string

+ type TarsHttpMux struct

+ func (mux *TarsHttpMux) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (mux *TarsHttpMux) SetConfig(cfg *TarsHttpConf)

+ type TarsProtocol struct

+ func NewTarsProtocol(dispatcher dispatch, imp interface{}, withContext bool) *TarsProtocol

+ func (s *TarsProtocol) GetCloseMsg() []byte

+ func (s *TarsProtocol) Invoke(ctx context.Context, req []byte) (rsp []byte)

+ func (s *TarsProtocol) InvokeTimeout(pkg []byte) []byte

+ func (s *TarsProtocol) ParsePackage(buff []byte) (int, int)

+ type TarsResponseWriter struct

+ func (w *TarsResponseWriter) WriteHeader(code int)