Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BufferingMetadata ¶
type BufferingMetadata struct {
// contains filtered or unexported fields
}
BufferingMetadata contains the cold data's buffering information
type Port ¶
type Port struct {
// contains filtered or unexported fields
}
Port contains the rpcx client and the buffering information
type SubmitFunc ¶
type SubmitFunc func(*rpc.LogMessage, rpcx.XClient) error
SubmitFunc is a type for submission the packet to rpcx
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
Transport contains the rpcx and communcation information
func InitTransport ¶
func InitTransport(configFileName string, customFilterFunc s.CustomFilterFunc) (*Transport, error)
InitTransport returns the instance of the Transport structure
Source Files
Click to show internal directories.
Click to hide internal directories.