This is an automated email from the ASF dual-hosted git repository. gaoxingcun pushed a commit to branch reconfiguration_scheduling in repository https://gitbox.apache.org/repos/asf/hertzbeat-collector-go.git
commit ed86475a26c3349eaefc36cdc48e835da50a6480 Author: yuluo-yx <[email protected]> AuthorDate: Sun Aug 31 21:44:43 2025 +0800 feat Signed-off-by: yuluo-yx <[email protected]> --- pkg/collector/common/job/job_server.go | 28 ++++++++++++++++++++++++++++ pkg/collector/common/transport/transport.go | 29 ++++++++++++++++++++++++++++- pkg/collector/internel/server.go | 11 +++++++++++ pkg/collector/internel/server_test.go | 1 + 4 files changed, 68 insertions(+), 1 deletion(-) diff --git a/pkg/collector/common/job/job_server.go b/pkg/collector/common/job/job_server.go new file mode 100644 index 0000000..8a63e54 --- /dev/null +++ b/pkg/collector/common/job/job_server.go @@ -0,0 +1,28 @@ +package job + +import ( + "context" + + "hertzbeat.apache.org/hertzbeat-collector-go/pkg/logger" +) + +type Server struct { + logger logger.Logger +} + +func NewServer(logger logger.Logger) *Server { + + return &Server{ + logger: logger, + } +} + +func (s *Server) Start(ctx context.Context) error { + + return nil +} + +func (s *Server) Close() error { + + return nil +} diff --git a/pkg/collector/common/transport/transport.go b/pkg/collector/common/transport/transport.go index 1deb96d..923553f 100644 --- a/pkg/collector/common/transport/transport.go +++ b/pkg/collector/common/transport/transport.go @@ -1,13 +1,40 @@ package transport +import ( + "context" + + "hertzbeat.apache.org/hertzbeat-collector-go/pkg/logger" +) + type RemotingService interface { Start() error Shutdown() error isStart() error } -type TransportClient interface { +type RemotingClient interface { RemotingService // todo add } + +type Server struct { + logger logger.Logger +} + +func NewServer(logger logger.Logger) *Server { + + return &Server{ + logger: logger, + } +} + +func (s *Server) Start(ctx context.Context) error { + + return nil +} + +func (s *Server) Close() error { + + return nil +} diff --git a/pkg/collector/internel/server.go b/pkg/collector/internel/server.go index 7bb79fd..b921d3e 100644 --- a/pkg/collector/internel/server.go +++ b/pkg/collector/internel/server.go @@ -4,6 +4,8 @@ import ( "context" "os" + "hertzbeat.apache.org/hertzbeat-collector-go/pkg/collector/common/job" + "hertzbeat.apache.org/hertzbeat-collector-go/pkg/collector/common/transport" "hertzbeat.apache.org/hertzbeat-collector-go/pkg/logger" "hertzbeat.apache.org/hertzbeat-collector-go/pkg/types" ) @@ -21,6 +23,9 @@ type Run interface { type CollectorServer struct { Version string Logger logger.Logger + + job *job.Server + transport *transport.Server } func NewCollectorServer(version string) *CollectorServer { @@ -39,6 +44,12 @@ func (s *CollectorServer) Start(ctx context.Context) error { s.Logger.Info("hi, starting collector server...") + // start job server + s.job = job.NewServer(s.Logger.WithName("job")) + + // init and start transport server + s.transport = transport.NewServer(s.Logger.WithName("transport")) + // Wait until done <-ctx.Done() diff --git a/pkg/collector/internel/server_test.go b/pkg/collector/internel/server_test.go new file mode 100644 index 0000000..65287b2 --- /dev/null +++ b/pkg/collector/internel/server_test.go @@ -0,0 +1 @@ +package internel --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
