tars

package
v0.0.0-...-69ab156 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 10, 2019 License: BSD-3-Clause Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PACKAGE_LESS = iota
	PACKAGE_FULL
	PACKAGE_ERROR
)
View Source
const (

	//TarsVersion is tars vesion
	TarsVersion string = "1.1.0"

	//AcceptTimeout accept timeout
	AcceptTimeout time.Duration = 500 * time.Millisecond
	//ReadTimeout zero for not set read deadline for Conn (better  performance)
	ReadTimeout time.Duration = 0 * time.Millisecond
	//WriteTimeout zero for not set write deadline for Conn (better performance)
	WriteTimeout time.Duration = 0 * time.Millisecond
	//HandleTimeout zero for not set deadline for invoke user interface (better performance)
	HandleTimeout time.Duration = 0 * time.Millisecond
	//IdleTimeout idle timeout
	IdleTimeout time.Duration = 600000 * time.Millisecond
	//ZombileTimeout zombile timeout
	ZombileTimeout time.Duration = time.Second * 10
	//QueueCap queue gap
	QueueCap int = 10000000

	//ClientQueueLen client queue length
	ClientQueueLen int = 10000
	//ClientIdleTimeout client idle timeout
	ClientIdleTimeout time.Duration = time.Second * 600
	//ClientReadTimeout client read timeout
	ClientReadTimeout time.Duration = time.Millisecond * 100
	//ClientWriteTimeout client write timeout
	ClientWriteTimeout time.Duration = time.Millisecond * 3000
	//ReqDefaultTimeout request default timeout
	ReqDefaultTimeout int32 = 3000
	//ObjQueueMax obj queue max number
	ObjQueueMax int32 = 10000

	//MaxlogOneTime is the max logs for reporting in one time.
	MaxlogOneTime int = 2000

	//PropertyReportInterval property report interval
	PropertyReportInterval time.Duration = 10 * time.Second
	//StatReportInterval stat report interval
	StatReportInterval time.Duration = 10 * time.Second

	//MainLoopTicker main loop ticker
	MainLoopTicker time.Duration = 10 * time.Second

	//AdapterProxyTicker adapter proxy ticker
	AdapterProxyTicker time.Duration = 10 * time.Second
	//AdapterProxyResetCount adapter proxy reset count
	AdapterProxyResetCount int = 5

	//AsyncInvokeTimeout async invoke timeout
	AsyncInvokeTimeout int = 3000

	//TCPReadBuffer tcp read buffer length
	TCPReadBuffer = 128 * 1024 * 1024
	//TCPWriteBuffer tcp write buffer length
	TCPWriteBuffer = 128 * 1024 * 1024
	//TCPNoDelay set tcp no delay
	TCPNoDelay = false
)

Variables

View Source
var MaxInvoke = 0

MaxInvoke number of woker routine to handle client request zero means no contorl ,just one goroutine for a client request. runtime.NumCpu() usually best performance in the benchmark.

View Source
var TLOG = rogger.GetLogger("TLOG")

TLOG is the logger for tars framework.

Functions

func AddHttpServant

func AddHttpServant(mux *TarsHttpMux, obj string)

AddHttpServant add http servant handler for obj.

func AddServant

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

AddServant add dispatch and interface for object.

func AddServantWithContext

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

AddServantWithContext add dispatch and interface for object, which have ctx,context

func GetClientConfig

func GetClientConfig() *clientConfig

GetClientConfig : Get client config

func GetDayLogger

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

GetDayLogger Get a logger roll by day

func GetHourLogger

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

GetHourLogger Get a logger roll by hour

func GetLogger

func GetLogger(name string) *rogger.Logger

GetLogger Get a logger

func GetRemoteLogger

func GetRemoteLogger(name string) *rogger.Logger

GetRemoteLogger returns a remote logger

func GetServerConfig

func GetServerConfig() *serverConfig

GetServerConfig : Get server config

func Init

func Init()

Init should run before GetServerConfig & GetClientConfig , or before run and Init should be only run once

func RegisterAdmin

func RegisterAdmin(name string, fn adminFn)

RegisterAdmin register admin functions

func RegisterClientFilter

func RegisterClientFilter(f ClientFilter)

RegisterClientFilter registers the Client filter , and will be executed in every request.

func RegisterServerFilter

func RegisterServerFilter(f ServerFilter)

RegisterServerFilter register the server filter.

func ReportStat

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

ReportStat is same as ReportStatFromClient.

func ReportStatBase

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

ReportStatBase is base method for report statitics.

func ReportStatFromClient

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

ReportStatFromClient report the statics from client.

func ReportStatFromServer

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

ReportStatFromServer reports statics from server side.

func Run

func Run()

Run the application

func TarsRequest

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

TarsRequest parse full tars request from package

Types

type AdapterProxy

type AdapterProxy struct {
	// contains filtered or unexported fields
}

AdapterProxy : Adapter proxy

func (*AdapterProxy) Close

func (c *AdapterProxy) Close()

Close : Close the client

func (*AdapterProxy) GetPoint

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

GetPoint : Get an endpoint

func (*AdapterProxy) New

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

New : Construct an adapter proxy

func (*AdapterProxy) ParsePackage

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

ParsePackage : Parse packet from bytes

func (*AdapterProxy) Recv

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

Recv : Recover read channel when closed for timeout

func (*AdapterProxy) Send

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

Send : Send packet

type Admin

type Admin struct {
}

Admin struct

func (*Admin) Notify

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

Notify handler for cmds from admin

func (*Admin) Shutdown

func (a *Admin) Shutdown() error

Shutdown shutdown all servant by admin

type Avg

type Avg struct {
	// contains filtered or unexported fields
}

Avg for counting average for the report value.

func NewAvg

func NewAvg() *Avg

NewAvg new and init the average struct.

func (*Avg) Desc

func (a *Avg) Desc() string

Desc return the Desc methods for the Avg struct.

func (*Avg) Get

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

Get gets the result of the average counting.

func (*Avg) Set

func (a *Avg) Set(in int)

Set sets the value for the average counting.

type ClientFilter

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

ClientFilter is used for filter request & response for client, for implementing plugins like opentracing

type Communicator

type Communicator struct {
	Client *clientConfig
	// contains filtered or unexported fields
}

Communicator struct

func NewCommunicator

func NewCommunicator() *Communicator

NewCommunicator returns a new communicator. A Communicator is used for communicating with the server side which should only init once and be global!!!

func (*Communicator) GetLocator

func (c *Communicator) GetLocator() string

GetLocator returns locator as string

func (*Communicator) GetProperty

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

GetProperty returns communicator property value as string and true for key, or empty string and false for not exists key

func (*Communicator) GetPropertyBool

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

GetPropertyBool returns communicator property value as bool and true for key, or false and false for not exists key

func (*Communicator) GetPropertyInt

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

GetPropertyInt returns communicator property value as int and true for key, or 0 and false for not exists key

func (*Communicator) SetLocator

func (c *Communicator) SetLocator(obj string)

SetLocator sets locator with obj

func (*Communicator) SetProperty

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

SetProperty sets communicator property with a string key and an interface value. var comm *tars.Communicator comm = tars.NewCommunicator() e.g. comm.SetProperty("locator", "tars.tarsregistry.QueryObj@tcp -h ... -p ...")

func (*Communicator) StringToProxy

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

StringToProxy sets the servant of ProxyPrx p with a string servant

type Count

type Count struct {
	// contains filtered or unexported fields
}

Count is for counting the total of reporting

func NewCount

func NewCount() *Count

NewCount new and init the counting struct.

func (*Count) Desc

func (c *Count) Desc() string

Desc return the Count string.

func (*Count) Get

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

Get gets the total times of the reporting values.

func (*Count) Set

func (c *Count) Set(in int)

Set sets the value for counting.

type Dispatch

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

Dispatch server side Dispatch

type Distr

type Distr struct {
	// contains filtered or unexported fields
}

Distr is used for counting the distribution of the reporting values.

func NewDistr

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

NewDistr new and int the Distr

func (*Distr) Desc

func (d *Distr) Desc() string

Desc return the descrition string of the Distr struct.

func (*Distr) Get

func (d *Distr) Get() string

Get get the distribution of the reporting values.

func (*Distr) Set

func (d *Distr) Set(in int)

Set sets the value for counting distribution.

type EndpointManager

type EndpointManager struct {
	// contains filtered or unexported fields
}

EndpointManager is a struct which contains endpoint information.

func (*EndpointManager) GetAllEndpoint

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

GetAllEndpoint returns all endpoint information as a array(support not tars service).

func (*EndpointManager) GetHashEndpoint

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

GetHashEndpoint returns hash endpoint information.

func (*EndpointManager) GetHashProxy

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

GetHashProxy returns hash adapter information.

func (*EndpointManager) GetNextEndpoint

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

GetNextEndpoint returns the endpoint basic information.

func (*EndpointManager) GetNextValidProxy

func (e *EndpointManager) GetNextValidProxy() *AdapterProxy

GetNextValidProxy returns polling adapter information.

func (*EndpointManager) Init

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

Init endpoint struct.

func (*EndpointManager) SelectAdapterProxy

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

SelectAdapterProxy returns selected adapter.

type Invoke

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

Invoke is used for Invoke tars server service

type Max

type Max struct {
	// contains filtered or unexported fields
}

Max struct is for counting the Max value for the reporting value.

func NewMax

func NewMax() *Max

NewMax new and init the Max struct.

func (*Max) Desc

func (m *Max) Desc() string

Desc return the descrition for the Max struct.

func (*Max) Get

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

Get gets the max value.

func (*Max) Set

func (m *Max) Set(in int)

Set sets a value for counting max.

type Message

type Message struct {
	Req  *requestf.RequestPacket
	Resp *requestf.ResponsePacket

	Obj *ObjectProxy
	Ser *ServantProxy
	Adp *AdapterProxy

	BeginTime int64
	EndTime   int64
	Status    int32
	// contains filtered or unexported fields
}

Message is a struct contains servant information

func (*Message) Cost

func (m *Message) Cost() int64

Cost calculate the cost time

func (*Message) End

func (m *Message) End()

End define the endtime

func (*Message) Init

func (m *Message) Init()

Init define the begintime

func (*Message) SetHashCode

func (m *Message) SetHashCode(code int64)

SetHashCode set hash code

type Min

type Min struct {
	// contains filtered or unexported fields
}

Min is the struct for counting the min value.

func NewMin

func NewMin() *Min

NewMin new and init the min struct.

func (*Min) Desc

func (m *Min) Desc() string

Desc return the descrition string of the Min strcut.

func (*Min) Get

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

Get get the min value for the Min struct.

func (*Min) Set

func (m *Min) Set(in int)

Set sets a value for counting min value.

type NodeFHelper

type NodeFHelper struct {
	// contains filtered or unexported fields
}

NodeFHelper is helper struct.

func (*NodeFHelper) KeepAlive

func (n *NodeFHelper) KeepAlive(adapter string)

KeepAlive sends the keepalive pacakage to the node.

func (*NodeFHelper) ReportVersion

func (n *NodeFHelper) ReportVersion(version string)

ReportVersion report the tars version to the node.

func (*NodeFHelper) SetNodeInfo

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

SetNodeInfo sets the node location for the given Communicator.

type NotifyHelper

type NotifyHelper struct {
	// contains filtered or unexported fields
}

NotifyHelper is the helper struct for the Notify service.

func (*NotifyHelper) ReportNotifyInfo

func (n *NotifyHelper) ReportNotifyInfo(info string)

ReportNotifyInfo report the info to the notify server.

func (*NotifyHelper) SetNotifyInfo

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

SetNotifyInfo sets the notify server location for the Communicator.

type ObjectProxy

type ObjectProxy struct {
	// contains filtered or unexported fields
}

ObjectProxy is struct contains proxy information

func (*ObjectProxy) Init

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

Init proxy

func (*ObjectProxy) Invoke

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

Invoke get proxy information

type ObjectProxyFactory

type ObjectProxyFactory struct {
	// contains filtered or unexported fields
}

ObjectProxyFactory is a struct contains proxy information(add)

func (*ObjectProxyFactory) GetObjectProxy

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

GetObjectProxy get objectproxy

func (*ObjectProxyFactory) Init

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

Init ObjectProxyFactory

type PropertyReport

type PropertyReport struct {
	// contains filtered or unexported fields
}

PropertyReport struct.

func CreatePropertyReport

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

CreatePropertyReport creats the property report instance with the key.

func (*PropertyReport) Report

func (p *PropertyReport) Report(in int)

Report reports a value.

type PropertyReportHelper

type PropertyReportHelper struct {
	// contains filtered or unexported fields
}

PropertyReportHelper is helper struct for property report.

var ProHelper *PropertyReportHelper

ProHelper is global.

func (*PropertyReportHelper) AddToReport

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

AddToReport adds the user's PropertyReport to the PropertyReportHelper

func (*PropertyReportHelper) Init

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

Init inits the PropertyReportHelper

func (*PropertyReportHelper) ReportToServer

func (p *PropertyReportHelper) ReportToServer()

ReportToServer report to the remote propertyreport server.

func (*PropertyReportHelper) Run

func (p *PropertyReportHelper) Run()

Run start the properting report goroutine.

type ProxyPrx

type ProxyPrx interface {
	SetServant(s.Servant)
}

ProxyPrx interface

type RConf

type RConf struct {
	// contains filtered or unexported fields
}

RConf struct for geting remote config.

func NewRConf

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

NewRConf init a Rconf, path should be getting from GetServerConfig().BasePath

func (*RConf) GetConfig

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

GetConfig gets the remote config and save it to the path, also return the content.

func (*RConf) GetConfigList

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

GetConfigList is discarded.

type RemoteTimeWriter

type RemoteTimeWriter struct {
	// contains filtered or unexported fields
}

RemoteTimeWriter writer for writing remote log.

func NewRemoteTimeWriter

func NewRemoteTimeWriter() *RemoteTimeWriter

NewRemoteTimeWriter new and init RemoteTimeWriter

func (*RemoteTimeWriter) EnablePrefix

func (rw *RemoteTimeWriter) EnablePrefix(hasAppNamePrefix bool)

EnablePrefix puts prefix before logs.

func (*RemoteTimeWriter) EnableSqarewrapper

func (rw *RemoteTimeWriter) EnableSqarewrapper(hasSquareBracket bool)

EnableSqarewrapper enables SquareBracket wrapper for the logs.

func (*RemoteTimeWriter) EnableSufix

func (rw *RemoteTimeWriter) EnableSufix(hasSufix bool)

EnableSufix puts sufix after logs.

func (*RemoteTimeWriter) InitFormat

func (rw *RemoteTimeWriter) InitFormat(s string)

InitFormat sets the log format.

func (*RemoteTimeWriter) InitServerInfo

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

InitServerInfo init the remote log server info.

func (*RemoteTimeWriter) NeedPrefix

func (rw *RemoteTimeWriter) NeedPrefix() bool

NeedPrefix return if need prefix for the logger.

func (*RemoteTimeWriter) SetFileNameConcatStr

func (rw *RemoteTimeWriter) SetFileNameConcatStr(s string)

SetFileNameConcatStr sets the filename concat string.

func (*RemoteTimeWriter) SetLogType

func (rw *RemoteTimeWriter) SetLogType(logType string)

SetLogType sets the log type.

func (*RemoteTimeWriter) SetPrefix

func (rw *RemoteTimeWriter) SetPrefix(enable bool)

func (*RemoteTimeWriter) SetSeparator

func (rw *RemoteTimeWriter) SetSeparator(s string)

SetSeparator set seprator between logs.

func (*RemoteTimeWriter) Sync2remote

func (rw *RemoteTimeWriter) Sync2remote()

Sync2remote syncs the log buffer to remote.

func (*RemoteTimeWriter) Write

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

Write Writes the logs to the buffer.

type ReportMethod

type ReportMethod interface {
	Desc() string
	Set(int)
	Get() string
	// contains filtered or unexported methods
}

ReportMethod is the interface for all kinds of report methods.

type ServantProxy

type ServantProxy struct {
	// contains filtered or unexported fields
}

ServantProxy is the struct for proxy servants.

func Dail

func Dail(servant string) *ServantProxy

Dail returns servant proxy

func (*ServantProxy) Init

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

Init init the ServantProxy struct.

func (*ServantProxy) TarsSetProtocol

func (s *ServantProxy) TarsSetProtocol(p model.Protocol)

func (*ServantProxy) TarsSetTimeout

func (s *ServantProxy) TarsSetTimeout(t int)

TarsSetTimeout sets the timeout for client calling the server , which is in ms.

func (*ServantProxy) Tars_invoke

func (s *ServantProxy) Tars_invoke(ctx context.Context, ctype byte,
	sFuncName string,
	buf []byte,
	status map[string]string,
	reqContext map[string]string,
	Resp *requestf.ResponsePacket) error

Tars_invoke is use for client inoking server.

type ServantProxyFactory

type ServantProxyFactory struct {
	// contains filtered or unexported fields
}

ServantProxyFactory is ServantProxy' factory struct.

func (*ServantProxyFactory) GetServantProxy

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

GetServantProxy gets the ServanrProxy for the object.

func (*ServantProxyFactory) Init

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

Init init the ServantProxyFactory.

type ServerFilter

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

ServerFilter is used for add Filter for server dispatcher ,for implementing plugins like opentracing.

type StatFHelper

type StatFHelper struct {
	// contains filtered or unexported fields
}

StatFHelper is helper struct for stat reporting.

var StatReport *StatFHelper

StatReport is global.

func (*StatFHelper) Init

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

Init init the StatFHelper.

func (*StatFHelper) ReportMicMsg

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

ReportMicMsg report the Statinfo ,from server shows whether it comes from server.

func (*StatFHelper) Run

func (s *StatFHelper) Run()

Run runs the reporting

type StatInfo

type StatInfo struct {
	Head statf.StatMicMsgHead
	Body statf.StatMicMsgBody
}

StatInfo struct contains stat info' head and body.

type Sum

type Sum struct {
	// contains filtered or unexported fields
}

Sum report methods.

func NewSum

func NewSum() *Sum

NewSum new and init the sum report methods.

func (*Sum) Desc

func (s *Sum) Desc() string

Desc return the descriptor string for the sum method.

func (*Sum) Get

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

Get gets the result of the sum report method.

func (*Sum) Set

func (s *Sum) Set(in int)

Set sets a value tho the sum method.

type TarsHttpConf

type TarsHttpConf struct {
	Container string
	AppName   string
	IP        string
	Port      int32
	Version   string
	SetId     string
}

TarsHttpConf is configuration for tars http server.

type TarsHttpMux

type TarsHttpMux struct {
	http.ServeMux
	// contains filtered or unexported fields
}

TarsHttpMux is http.ServeMux for tars http server.

func (*TarsHttpMux) ServeHTTP

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

ServeHTTP is the server for the TarsHttpMux.

func (*TarsHttpMux) SetConfig

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

SetConfig sets the cfg tho the TarsHttpMux.

type TarsProtocol

type TarsProtocol struct {
	// contains filtered or unexported fields
}

TarsProtocol is struct for dispatch with tars protocol.

func NewTarsProtocol

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

NewTarsProtocol return a Tarsprotocol with dipatcher and implement interface. withContext explain using context or not.

func (*TarsProtocol) Invoke

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

Invoke puts the request as []byte and call the dispather, and then return the response as []byte.

func (*TarsProtocol) InvokeTimeout

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

InvokeTimeout indicates how to deal with timeout.

func (*TarsProtocol) ParsePackage

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

ParsePackage parse the []byte according to the tars protocol.

type TarsResponseWriter

type TarsResponseWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

TarsResponseWriter is http.ResponseWriter for tars.

func (*TarsResponseWriter) WriteHeader

func (w *TarsResponseWriter) WriteHeader(code int)

WriteHeader is used for write the http header with the http code.

Directories

Path Synopsis
plugin
res/adminf
Package adminf comment This file war generated by tars2go 1.1 Generated from AdminF.tars
Package adminf comment This file war generated by tars2go 1.1 Generated from AdminF.tars
res/basef
Package basef comment This file war generated by tars2go 1.1 Generated from BaseF.tars
Package basef comment This file war generated by tars2go 1.1 Generated from BaseF.tars
res/configf
Package configf comment This file war generated by tars2go 1.1 Generated from Config.tars Package configf comment This file war generated by tars2go 1.1 Generated from Config.tars Package configf comment This file war generated by tars2go 1.1 Generated from Config.tars
Package configf comment This file war generated by tars2go 1.1 Generated from Config.tars Package configf comment This file war generated by tars2go 1.1 Generated from Config.tars Package configf comment This file war generated by tars2go 1.1 Generated from Config.tars
res/endpointf
Package endpointf comment This file war generated by tars2go 1.1 Generated from EndpointF.tars
Package endpointf comment This file war generated by tars2go 1.1 Generated from EndpointF.tars
res/logf
Package logf comment This file war generated by tars2go 1.1 Generated from LogF.tars Package logf comment This file war generated by tars2go 1.1 Generated from LogF.tars
Package logf comment This file war generated by tars2go 1.1 Generated from LogF.tars Package logf comment This file war generated by tars2go 1.1 Generated from LogF.tars
res/nodef
Package nodef comment This file war generated by tars2go 1.1 Generated from NodeF.tars Package nodef comment This file war generated by tars2go 1.1 Generated from NodeF.tars
Package nodef comment This file war generated by tars2go 1.1 Generated from NodeF.tars Package nodef comment This file war generated by tars2go 1.1 Generated from NodeF.tars
res/notifyf
Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars
Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars Package notifyf comment This file war generated by tars2go 1.1 Generated from NotifyF.tars
res/propertyf
Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars
Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars Package propertyf comment This file war generated by tars2go 1.1 Generated from PropertyF.tars
res/queryf
Package queryf comment This file war generated by tars2go 1.1 Generated from QueryF.tars
Package queryf comment This file war generated by tars2go 1.1 Generated from QueryF.tars
res/requestf
Package requestf comment This file war generated by tars2go 1.1 Generated from RequestF.tars Package requestf comment This file war generated by tars2go 1.1 Generated from RequestF.tars
Package requestf comment This file war generated by tars2go 1.1 Generated from RequestF.tars Package requestf comment This file war generated by tars2go 1.1 Generated from RequestF.tars
res/statf
Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars
Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars Package statf comment This file war generated by tars2go 1.1 Generated from StatF.tars
tools
pb2tarsgo/protoc-gen-go/tarsrpc
Package tarsrpc outputs tars service descriptions in Go code.
Package tarsrpc outputs tars service descriptions in Go code.
util
conf
Package conf implements parse the taf config.
Package conf implements parse the taf config.
set
Package set implement
Package set implement

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL