Method AddBind

pkg/service/rpc_meta.go:284–299

(ctx context.Context, req *rpcpb.AddBindReq)

}

func (s *metaService) AddBind(ctx context.Context, req *rpcpb.AddBindReq) (*rpcpb.AddBindRsp, error) {
	select {
	case <-ctx.Done():
		return nil, errRPCCancel
	default:
		err := s.db.AddBind(&metapb.Bind{
			ClusterID: req.Cluster,
			ServerID:  req.Server,
		})
		if err != nil {
			return nil, err
		}

		return &rpcpb.AddBindRsp{}, nil
	}
}

func (s *metaService) Batch(ctx context.Context, req *rpcpb.BatchReq) (*rpcpb.BatchRsp, error) {
	select {