service

package
v0.0.0-...-c9f961e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 16, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ProviderSet = wire.NewSet(NewCanalService)

ProviderSet is service providers.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

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