service

Documentation

Index

• Variables
• type HookInterflowService
  • func NewHookInterflowService(interflowConf *conf.Interflow, logger log.Logger) *HookInterflowService
  • func (s *HookInterflowService) Receive(ctx context.Context, req *pb.ReceiveRequest) (*pb.ReceiveResponse, error)
• type HookService
  • func NewHookService(logger log.Logger) *HookService
  • func (s *HookService) V1(ctx context.Context, req *pb.HookV1Request) (*pb.HookV1Reply, error)
• type LoadService
  • func NewLoadService(alarmBiz *biz.AlarmBiz, logger log.Logger) *LoadService
  • func (s *LoadService) Evaluate(_ context.Context, req *pb.EvaluateRequest) (*pb.EvaluateReply, error)
• type PingService
  • func NewPingService(uc *biz.PingBiz, logger log.Logger) *PingService
  • func (s *PingService) Check(ctx context.Context, in *ping.PingRequest) (*ping.PingReply, error)

Variables

var ProviderSetService = wire.NewSet(
	NewPingService,
	NewLoadService,
	NewHookService,
	NewHookInterflowService,
)

ProviderSetService is service providers.

Types

type HookInterflowService

type HookInterflowService struct {
	pb.UnimplementedHookInterflowServer
	// contains filtered or unexported fields
}

func NewHookInterflowService

func NewHookInterflowService(interflowConf *conf.Interflow, logger log.Logger) *HookInterflowService

func (*HookInterflowService) Receive

func (s *HookInterflowService) Receive(ctx context.Context, req *pb.ReceiveRequest) (*pb.ReceiveResponse, error)

type HookService

type HookService struct {
	pb.UnimplementedHookServer
	// contains filtered or unexported fields
}

func NewHookService

func NewHookService(logger log.Logger) *HookService

func (*HookService) V1

func (s *HookService) V1(ctx context.Context, req *pb.HookV1Request) (*pb.HookV1Reply, error)

type LoadService

type LoadService struct {
	pb.UnimplementedLoadServer
	// contains filtered or unexported fields
}

func NewLoadService

func NewLoadService(alarmBiz *biz.AlarmBiz, logger log.Logger) *LoadService

func (*LoadService) Evaluate

func (s *LoadService) Evaluate(_ context.Context, req *pb.EvaluateRequest) (*pb.EvaluateReply, error)

type PingService

type PingService struct {
	ping.UnimplementedPingServer
	// contains filtered or unexported fields
}

PingService is a Ping service.

func NewPingService

func NewPingService(uc *biz.PingBiz, logger log.Logger) *PingService

NewPingService new a Ping service.

func (*PingService) Check

func (s *PingService) Check(ctx context.Context, in *ping.PingRequest) (*ping.PingReply, error)

Check implements ping.Check