server

package

v0.0.0-...-d704305 Latest Latest Go to latest Published: Apr 23, 2023 License: GPL-3.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/BitTraceProject/BitTrace-Receiver

Links

Open Source Insights

Documentation ¶

Index ¶

type MetaServer
- func NewMetaServer(addr string) *MetaServer
- func (s *MetaServer) Address() string
- func (s *MetaServer) Run() error
type MetaServerAPI
- func NewMetaServerAPI() *MetaServerAPI
type Mq
type MqServer
- func NewMqServer(addr string) *MqServer
- func (s *MqServer) Address() string
- func (s *MqServer) Run() error
type MqServerAPI
- func NewMqServerAPI() *MqServerAPI
type ReceiverServer
- func NewReceiverServer(r *gin.Engine, conf config.ReceiverConfig) *ReceiverServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MetaServer ¶

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

func NewMetaServer ¶

func NewMetaServer(addr string) *MetaServer

func (*MetaServer) Address ¶

func (s *MetaServer) Address() string

func (*MetaServer) Run ¶

func (s *MetaServer) Run() error

type MetaServerAPI ¶

type MetaServerAPI struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

MetaServerAPI 目前只提供同步的接口，且目前元信息只在内存中维护一份

func NewMetaServerAPI ¶

func NewMetaServerAPI() *MetaServerAPI

func (*MetaServerAPI) ClearAllExporterInfo ¶

func (api *MetaServerAPI) ClearAllExporterInfo(args *protocol.MetaClearAllExporterInfoArgs, reply *protocol.MetaClearAllExporterInfoReply) error

func (*MetaServerAPI) DeleteExporterInfo ¶

func (api *MetaServerAPI) DeleteExporterInfo(args *protocol.MetaDeleteExporterInfoArgs, reply *protocol.MetaDeleteExporterInfoReply) error

func (*MetaServerAPI) ExporterHasJoin ¶

func (api *MetaServerAPI) ExporterHasJoin(args *protocol.MetaExporterHasJoinArgs, reply *protocol.MetaExporterHasJoinReply) error

func (*MetaServerAPI) GetAllExporterInfo ¶

func (api *MetaServerAPI) GetAllExporterInfo(args *protocol.MetaGetAllExporterInfoArgs, reply *protocol.MetaGetAllExporterInfoReply) error

func (*MetaServerAPI) GetExporterInfo ¶

func (api *MetaServerAPI) GetExporterInfo(args *protocol.MetaGetExporterInfoArgs, reply *protocol.MetaGetExporterInfoReply) error

func (*MetaServerAPI) GetExporterProgress ¶

func (api *MetaServerAPI) GetExporterProgress(args *protocol.MetaGetExporterProgressArgs, reply *protocol.MetaGetExporterProgressReply) error

func (*MetaServerAPI) GetExporterResolver ¶

func (api *MetaServerAPI) GetExporterResolver(args *protocol.MetaGetExporterResolverArgs, reply *protocol.MetaGetExporterResolverReply) error

func (*MetaServerAPI) GetExporterStatus ¶

func (api *MetaServerAPI) GetExporterStatus(args *protocol.MetaGetExporterStatusArgs, reply *protocol.MetaGetExporterStatusReply) error

func (*MetaServerAPI) GetExporterTable ¶

func (api *MetaServerAPI) GetExporterTable(args *protocol.MetaGetExporterTableArgs, reply *protocol.MetaGetExporterTableReply) error

func (*MetaServerAPI) NewExporterInfo ¶

func (api *MetaServerAPI) NewExporterInfo(args *protocol.MetaNewExporterInfoArgs, reply *protocol.MetaNewExporterInfoReply) error

func (*MetaServerAPI) UpdateExporterProgress ¶

func (api *MetaServerAPI) UpdateExporterProgress(args *protocol.MetaUpdateExporterProgressArgs, reply *protocol.MetaUpdateExporterProgressReply) error

func (*MetaServerAPI) UpdateExporterStatus ¶

func (api *MetaServerAPI) UpdateExporterStatus(args *protocol.MetaUpdateExporterStatusArgs, reply *protocol.MetaUpdateExporterStatusReply) error

type Mq ¶

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

func (*Mq) Dequeue ¶

func (mq *Mq) Dequeue() (protocol.MqMessage, bool)

func (*Mq) Enqueue ¶

func (mq *Mq) Enqueue(message protocol.MqMessage) bool

func (*Mq) HasNext ¶

func (mq *Mq) HasNext() bool

func (*Mq) Len ¶

func (mq *Mq) Len() int

type MqServer ¶

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

func NewMqServer ¶

func NewMqServer(addr string) *MqServer

func (*MqServer) Address ¶

func (s *MqServer) Address() string

func (*MqServer) Run ¶

func (s *MqServer) Run() error

type MqServerAPI ¶

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

MqServerAPI 目前只提供同步的接口

func NewMqServerAPI ¶

func NewMqServerAPI() *MqServerAPI

func (*MqServerAPI) ClearMessage ¶

func (api *MqServerAPI) ClearMessage(args *protocol.MqClearMessageArgs, reply *protocol.MqClearMessageReply) error

func (*MqServerAPI) FilterMessage ¶

func (api *MqServerAPI) FilterMessage(args *protocol.MqFilterMessageArgs, reply *protocol.MqFilterMessageReply) error

func (*MqServerAPI) PushMessage ¶

func (api *MqServerAPI) PushMessage(args *protocol.MqPushMessageArgs, reply *protocol.MqPushMessageReply) error

type ReceiverServer ¶

type ReceiverServer struct {
	*gin.Engine
	// contains filtered or unexported fields
}

func NewReceiverServer ¶

func NewReceiverServer(r *gin.Engine, conf config.ReceiverConfig) *ReceiverServer

func (*ReceiverServer) CallMetaServer ¶

func (s *ReceiverServer) CallMetaServer(serviceMethod string, args any, reply any) error

func (*ReceiverServer) CallMqServer ¶

func (s *ReceiverServer) CallMqServer(serviceMethod string, args any, reply any) error

func (*ReceiverServer) CallResolverMgrServer ¶

func (s *ReceiverServer) CallResolverMgrServer(serviceMethod string, args any, reply any) error

Source Files ¶

View all Source files

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