service

Documentation

Index

• Variables
• type CanalService
  • func NewCanalService(uc *biz.Canal) *CanalService
  • func (s *CanalService) CheckMaster(ctx context.Context, arg *pb.CheckMasterRequest) (reply *pb.CheckMasterReply, err error)
  • func (s *CanalService) Errors(ctx context.Context, req *pb.ErrorsRequest) (reply *pb.ErrorsReply, err error)
  • func (s *CanalService) InfocCurrent(ctx context.Context, req *pb.InfocCurrentRequest) (reply *pb.InfocCurrentReply, err error)
  • func (s *CanalService) InfocPost(ctx context.Context, req *pb.InfocPostRequest) (reply *pb.InfocPostReply, err error)
  • func (s *CanalService) SyncPos(ctx context.Context, arg *pb.SyncPosRequest) (reply *pb.SyncPosReply, err error)

Variables

var ProviderSet = wire.NewSet(NewCanalService)

ProviderSet is service providers.

Types

type CanalService

type CanalService struct {
	pb.UnimplementedCanalServer
	// contains filtered or unexported fields
}

func NewCanalService

func NewCanalService(uc *biz.Canal) *CanalService

func (*CanalService) CheckMaster

func (s *CanalService) CheckMaster(ctx context.Context, arg *pb.CheckMasterRequest) (reply *pb.CheckMasterReply, err error)

func (*CanalService) Errors

func (s *CanalService) Errors(ctx context.Context, req *pb.ErrorsRequest) (reply *pb.ErrorsReply, err error)

func (*CanalService) InfocCurrent

func (s *CanalService) InfocCurrent(ctx context.Context, req *pb.InfocCurrentRequest) (reply *pb.InfocCurrentReply, err error)

func (*CanalService) InfocPost

func (s *CanalService) InfocPost(ctx context.Context, req *pb.InfocPostRequest) (reply *pb.InfocPostReply, err error)

func (*CanalService) SyncPos

func (s *CanalService) SyncPos(ctx context.Context, arg *pb.SyncPosRequest) (reply *pb.SyncPosReply, err error)