package example
import (  "context"  "fmt"  "time"
  "github.com/erda-project/erda-infra/base/logs"  "github.com/erda-project/erda-infra/base/servicehub")
// Interface 以接口的形式，对外提供本模块的功能type Interface interface {  Hello(name string) string}
// config 声明式的配置定义type config struct {  Message string `file:"message" flag:"msg" default:"hi" desc:"message to print"`}
// provider 代表一个模块type provider struct {  Cfg *config     // 框架会自动注入  Log logs.Logger // 框架会自动注入}
// Init 初始化模块。可选，如果存在，会被框架自动调用func (p *provider) Init(ctx servicehub.Context) error {  p.Log.Info("message: ", p.Cfg.Message)  return nil}
// Run 启动异步任务。可选，如果存在，会被框架自动调用func (p *provider) Run(ctx context.Context) error {  tick := time.NewTicker(3 * time.Second)  defer tick.Stop()  for {    select {    case <-tick.C:      p.Log.Info("do something...")    case <-ctx.Done():      return nil    }  }}
// Hello 实现接口func (p *provider) Hello(name string) string {  return fmt.Sprintf("hello %s", p.Cfg.Message)}
func init() {  // 注册模块  servicehub.Register("helloworld", &servicehub.Spec{    Services:    []string{"helloworld-service"}, // 代表模块的服务列表    Description: "here is description of helloworld",    ConfigFunc:  func() interface{} { return &config{} }, // 配置的构造函数    Creator: func() servicehub.Provider { // 模块的构造函数      return &provider{}    },  })}

package main
import (  _ ".../example" // your package import path  "github.com/erda-project/erda-infra/base/servicehub")
func main() {  servicehub.Run(&servicehub.RunOptions{    ConfigFile: "example.yaml",  })}package main
import (  "github.com/erda-project/erda-infra/base/servicehub"  _ ".../example" // your package import path)
func main() {  servicehub.Run(&servicehub.RunOptions{    ConfigFile: "example.yaml",  })}

# example.yamlhelloworld:  message: "erda"

package example2
// 以下省略号非关键代码
import (  ".../example" // your package import path  "github.com/erda-project/erda-infra/base/servicehub")
type provider struct {  Example example.Interface `autowired:"helloworld-service"` // 框架会自动注入实例}
func (p *provider) Init(ctx servicehub.Context) error {  p.Example.Hello("i am module 2")  return nil}
func init() {  // 注册模块 ...}

syntax = "proto3";
package erda.infra.example;import "google/api/annotations.proto";option go_package = "github.com/erda-project/erda-infra/examples/service/protocol/pb";
// the greeting service definition.service GreeterService {  // say hello  rpc SayHello (HelloRequest) returns (HelloResponse)  {    option (google.api.http) = {      get: "/api/greeter/{name}",    };  }}
message HelloRequest {  string name = 1;}
message HelloResponse {  bool success = 1;  string data = 2;}

cd protocolgohub protoc protocol *.proto 

cd server/helloworldgohub protoc imp ../../protocol/*.proto

package example
import (  "context"
  "github.com/erda-project/erda-infra/examples/service/protocol/pb")
type greeterService struct {  p *provider}
func (s *greeterService) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) {  // TODO: 编写业务逻辑  return &pb.HelloResponse{    Success: true,    Data:    "hello " + req.Name,  }, nil}

package caller
import (  "context"  "time"
  "github.com/erda-project/erda-infra/base/logs"  "github.com/erda-project/erda-infra/base/servicehub"  "github.com/erda-project/erda-infra/examples/service/protocol/pb")
type config struct {  Name string `file:"name" default:"recallsong"`}
type provider struct {  Cfg     *config  Log     logs.Logger  Greeter pb.GreeterServiceServer // 由 本地模块 或 远程模块 提供}
// 调用 GreeterService 服务的例子func (p *provider) Run(ctx context.Context) error {  tick := time.NewTicker(3 * time.Second)  defer tick.Stop()  for {    select {    case <-tick.C:      resp, err := p.Greeter.SayHello(context.Background(), &pb.HelloRequest{        Name: p.Cfg.Name,      })      if err != nil {        p.Log.Error(err)      }      p.Log.Info(resp)    case <-ctx.Done():      return nil    }  }}
func init() {  servicehub.Register("caller", &servicehub.Spec{    Services:     []string{},    Description:  "this is caller example",    Dependencies: []string{"erda.infra.example.GreeterService"},    ConfigFunc: func() interface{} {      return &config{}    },    Creator: func() servicehub.Provider {      return &provider{}    },  })}